前面大致说明了一下如何接入EventBus 3.0及其简单的使用（链接），今天我们自己实现观察者模式来进行不同页面之间的消息传递 ~
场景
APP经过页面一和页面二到达页面三，页面三点击发消息按钮发送消息，页面一页面二接收到消息，更新UI，展示消息：
观察者模式
我们准备使用观察者模式来实现这个不同页面消息传递的功能，首先简单的介绍一下观察者模式。
（作者比较懒，以下介绍来自百度百科<a href="http://baike.baidu.com/link?url=MKDm0lcHVznikRyP1YOZsEOwJM4hdmThTd9Io-2beh4zhYV3jomNt6iT5_JMIxcl1bcCU2C5KxtachBEg8IIPi0XRPJwqnIoRXVabcvoWe-IngoJsTFBWQ2TmMcA1Rfjk96hJl3eFx2yFSloBVPbr_">观察者模式</a>）
观察者模式（Observer）完美的将观察者和被观察的对象分离开。举个例子，用户界面可以作为一个观察者，业务数据是被观察者，用户界面观察业务数据的变化，发现数据变化后，就显示在界面上。面向对象设计的一个原则是：系统中的每个类将重点放在某一个功能上，而不是其他方面。一个对象只做一件事情，并且将他做好。观察者模式在模块之间划定了清晰的界限，提高了应用程序的可维护性和重用性。
观察者设计模式定义了对象间的一种一对多的依赖关系，以便一个对象的状态发生变化时，所有依赖于它的对象都得到通知并自动刷新。
编写代码，实现观察者模式
定义观察者接口 Observer.java
public interface Observer {
void update(Object obj); //同notify()的意义，当观察者接收到消息时执行的更新方法
}
定义被观察者接口Observable.java
public interface Observable {
/**
* add a observer to the list
* @param observer
*/
void addObserver(Observer observer);
/**
* remove a observer from the list
* @param observer
*/
void removeObserver(Observer observer);
/**
* notify all observers in the list
* @param obj
*/
void notifyObservers(Object obj);
}
实现一个被观察者类ConcreteObservableA.java
public class ConcreteObservableA implements Observable {
private ArrayList<Observer> observers;
@Override
public void addObserver(Observer observer) {
if (observers == null) {
observers = new ArrayList<>();
}
observers.add(observer);
}
@Override
public void removeObserver(Observer observer) {
if (observers == null || observers.size() <= 0) {
return;
}
observers.remove(observer);
}
@Override
public void notifyObservers(Object obj) {
if (observers == null || observers.size() <= 0) {
return;
}
for (Observer observer : observers) {
observer.update(obj);
}
}
}
到现在为止，观察者模式的基本代码算是完成了，但是我们想一下：在业务代码的编写过程中，如何注册观察者（把观察者加入到被观察者的列表中）？被观察者显然应该是全局的或者是在单例类属性中，而EventBus是如何注册呢？
EventBus.getDefault().register(this);
那么我们可以参考这种做法，编写我们自己的单例类，我们叫它EventCar
public class EventCar {
private static EventCar instance;
private ConcreteObservableA observableA;
public static EventCar getDefault() {
if (instance == null) {
synchronized (EventCar.class) {
if (instance == null) {
instance = new EventCar();
}
}
}
return instance;
}
private EventCar() {
observableA = new ConcreteObservableA();
}
/**
* register a observer
* @param observer
*/
public void register(Observer observer) {
observableA.addObserver(observer);
}
/**
* unregister a observer
* @param observer
*/
public void unregister(Observer observer) {
observableA.removeObserver(observer);
}
/**
* post a objict message to all observer
* @param obj
*/
public void post(Object obj) {
observableA.notifyObservers(obj);
}
}
下面我们开始编写业务代码
页面一FirstActivity.java
public class FirstActivity extends Activity implements Observer{
private Button btnNextPage;
private TextView tvMsg;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_first);
initViews();
EventCar.getDefault().register(this);
}
private void initViews() {
btnNextPage = (Button) findViewById(R.id.btnNextPage);
tvMsg = (TextView) findViewById(R.id.tvMsg);
btnNextPage.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
Intent intent = new Intent(FirstActivity.this, SecondActivity.class);
startActivity(intent);
}
});
}
@Override
public void update(Object obj) {
if (!(obj instanceof EventMsg)){
return;
}
EventMsg eventMsg = (EventMsg) obj;
tvMsg.setText("message: " + eventMsg.getMsg() + "\nfrom :" + eventMsg.getFrom());
}
@Override
protected void onDestroy() {
super.onDestroy();
EventCar.getDefault().unregister(this);
}
}
FirstActivity实现了Observer接口，因为它是一个观察者，需要接收ThirdActivity发的消息。实现了接口的方法public void update(Object obj),接收到消息后刷新页面数据。
页面二 SecondActivity.java
与页面一FirstActivity.java代码差不多，这里省略。
页面三 ThirdActivity.java
public class ThirdActivity extends Activity {
private Button btnSendMsg;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_third);
btnSendMsg = (Button) findViewById(R.id.btnSendMsg);
btnSendMsg.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
//发送消息
EventCar.getDefault().post(new EventMsg("as long as you love me ~", String.valueOf(getClass().getName())));
}
});
}
}
页面里面有一个按钮，点击的时候会发送消息。可以看到，post方法的参数是Object类型
public void post(Object obj) {
observableA.notifyObservers(obj);
}
页面一、二接收并识别的类型应该跟这里的类型一样，才能接收到消息。为此我们定义一个消息类EventMsg .java
public class EventMsg {
private String msg; //事件发出的消息
private String from; //哪里发出的事件
public EventMsg(String msg, String from) {
this.msg = msg;
this.from = from;
}
public String getMsg() {
return msg;
}
public String getFrom() {
return from;
}
}
到这里，代码基本上都完成了，赶紧编译运行一下吧！
注意：
这里只是实现了同线程间不同页面传递消息，如果想了解更多，我也不会，靠您自己研究了~
写在最后
本人正在努力想脱离菜鸟群，很多东西理解的、写的可能不太正确，欢迎各位批评指正~
