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

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

在介紹之前我們寫了一個方法

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 * 發送消息 16 * @param type 17 */ 18 public void sendMessage(String type){ 19 setChanged(); 20 this.notifyObservers(type); 21 } 22 23 24 }

這個方法可以注冊也可以取消注冊，還有一個發消息的方法

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

1.發消息

在發消息的界面調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 }

在對應的進程中注冊和取消注冊

然后發消息

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

好消息發好了，接下來接收消息了

2接收消息

同樣用到Observeable就要注冊和取消注冊然后調Observeable這個接口

調接口大家就會發現有update這個方法，在這個方法里就可以獲取到你傳遞的數據了

@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) {}}

?

個人覺得這樣寫比較煩，個人覺得這個Observeable應該封裝在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 * 發消息 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 }

那么怎么使用呢

使用就很簡單了，只要繼承AsukaActivity ，發送接收就可以了

繼承會有oberserMsg這個方法進行接收

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 }

發送

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

?

希望大家可以使用

轉載于:https://www.cnblogs.com/wangying222/p/7485093.html

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。