今天我們公司封裝的類中沒有加上Observable觀察者模式，但是很多地方需要用到Observable觀察者模式

接下來就向大家介紹一下我的使用吧！

在介紹之前我們寫了一個(gè)方法

1 public class RefreshSender extends Observable { 2 3 private static RefreshSender instances; 4 5 6 public static RefreshSender getInstances(){ 7 if(instances==null) 8 instances=new RefreshSender(); 9 10 return instances; 11 } 12 13 14 /** 15 * 發(fā)送消息 16 * @param type 17 */ 18 public void sendMessage(String type){ 19 setChanged(); 20 this.notifyObservers(type); 21 } 22 23 24 }

這個(gè)方法可以注冊(cè)也可以取消注冊(cè)，還有一個(gè)發(fā)消息的方法

首先我使用最基本的直接使用Observable

1.發(fā)消息

在發(fā)消息的界面調(diào)Observable接口

1 @Override 2 protected void onCreate(Bundle savedInstanceState) { 3 super.onCreate(savedInstanceState); 4 RefreshSender.getInstances().addObserver(this); 5 } 6 7 @Override 8 protected void onDestroy() { 9 super.onDestroy(); 10 RefreshSender.getInstances().deleteObserver(this); 11 }

在對(duì)應(yīng)的進(jìn)程中注冊(cè)和取消注冊(cè)

然后發(fā)消息

JSONObject object1 =new JSONObject();object1.put("type","childrenaction");object1.put("school",strValue);RefreshSender.getInstances().sendMessage(object1.toJSONString());

好消息發(fā)好了，接下來接收消息了

2接收消息

同樣用到Observeable就要注冊(cè)和取消注冊(cè)然后調(diào)Observeable這個(gè)接口

調(diào)接口大家就會(huì)發(fā)現(xiàn)有update這個(gè)方法，在這個(gè)方法里就可以獲取到你傳遞的數(shù)據(jù)了

@Overridepublic void update(Observable observable, Object data) {try {JSONObject object = JSON.parseObject(data.toString());String type = object.getString("type");if ("childrenmess".equals(type)) {key = object.getString("school");list.clear();pageIndex = 1;getData(false);}} catch (Exception e) {}}

?

個(gè)人覺得這樣寫比較煩，個(gè)人覺得這個(gè)Observeable應(yīng)該封裝在BaseActivity或者BaseFragment中

比如

1 public abstract class AsukaActivity extends AppCompatActivity implements Observer { 2 @Override 3 protected void onCreate(Bundle savedInstanceState) { 4 super.onCreate(savedInstanceState); 5 RefreshSender.getInstances().addObserver(this); 6 initView()； 7 initEvent(); 8 } 9 /** 10 * 發(fā)消息 11 * @param type 12 * @param object 13 */ 14 public void sendObseverMsg(String type,JSONObject object){ 15 object.put("type",type); 16 RefreshSender.getInstances().sendMessage(object.toJSONString()); 17 } 18 19 protected abstract void initView(); 20 protected abstract void initEvent(); 21 protected abstract void oberserMsg(String type, JSONObject object); 22 23 @Override 24 public void update(Observable observable, Object data) { 25 try { 26 JSONObject object= JSON.parseObject(data.toString()); 27 String type=object.getString("type"); 28 oberserMsg(type,object); 29 }catch (Exception e){ 30 31 } 32 } 33 34 @Override 35 protected void onDestroy() { 36 super.onDestroy(); 37 RefreshSender.getInstances().deleteObserver(this); 38 AsukaAndroid.app().getAppManager().finishActivity(this); 39 } 40 ?protected? abstract void initView();
??? protected? abstract void initEvent();
??? protected? abstract void oberserMsg(String type, JSONObject object); 41 }

那么怎么使用呢

使用就很簡(jiǎn)單了，只要繼承AsukaActivity ，發(fā)送接收就可以了

繼承會(huì)有oberserMsg這個(gè)方法進(jìn)行接收

1 @Override 2 protected void oberserMsg(String type, JSONObject object) { 3 if ("workFlow".equals(type)) { 4 wfid = object.getString("wfid"); 5 arr.clear(); 6 pageIndex = 1; 7 isUpdate = false; 8 getData(); 9 }

發(fā)送

?1 sendObseverMsg("workFlow", object);?

?

希望大家可以使用

轉(zhuǎn)載于:https://www.cnblogs.com/wangying222/p/7485093.html

總結(jié)

以上是生活随笔為你收集整理的Observable观察者模式的使用的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。