Java中的观察者模式实例讲解(2)

时间:2014-12-02 11:03来源:网络整理作者:网络点击: 次

分享到：

//method to post message to the topic public void postMessage(String msg){ System.out.println("Message Posted to Topic:"+msg); this.message=msg; this.changed=true; notifyObservers(); } } 注册与注销

//method to post message to the topic
public void postMessage(String msg){
  System.out.println("Message Posted to Topic:"+msg);
  this.message=msg;
  this.changed=true;
  notifyObservers();
}

}

注册与注销观察者方法的实现非常简单，额外的方法postMessage()将被客户端应用来提交一个字符串消息给此主题。注意，布尔变量用于追踪主题状态的变化并且通知观察者此种变化。这个变量是必须的，因为如果没有更新，但是有人调用notifyObservers()方法，他就不能发送错误的通知信息给观察者。

此外需要注意的是，notifyObservers()中使用synchronization同步的方式来确保在消息被发布给主题之前，通知只能被发送到注册的观察者处。

此处是观察者的实现。他们将一直关注subject对象。

复制代码代码如下:

package com.journaldev.design.observer;

public class MyTopicSubscriber implements Observer {

private String name;
private Subject topic;

public MyTopicSubscriber(String nm){
  this.name=nm;
}
@Override
public void update() {
  String msg = (String) topic.getUpdate(this);
  if(msg == null){
   System.out.println(name+":: No new message");
  }else
  System.out.println(name+":: Consuming message::"+msg);
}

@Override
public void setSubject(Subject sub) {
this.topic=sub;
}

}

注意，update()方法的实现使用了被观察者的getUpdate()来处理更新的消息。此处应该避免把消息作为参数传递给update()方法。

一下为简单地测试程序来验证话题类的实现。

复制代码代码如下:

package com.journaldev.design.observer;

public class ObserverPatternTest {

public static void main(String[] args) {
//create subject
MyTopic topic = new MyTopic();

  //create observers
  Observer obj1 = new MyTopicSubscriber("Obj1");
  Observer obj2 = new MyTopicSubscriber("Obj2");
  Observer obj3 = new MyTopicSubscriber("Obj3");

  //register observers to the subject
  topic.register(obj1);
  topic.register(obj2);
  topic.register(obj3);

  //attach observer to subject
  obj1.setSubject(topic);
  obj2.setSubject(topic);
  obj3.setSubject(topic);

//check if any update is available
obj1.update();

//now send message to subject
topic.postMessage("New Message");
}

}

此处为上述输出内容：

复制代码代码如下:

Obj1:: No new message

Message Posted to Topic:New Message

Obj1:: Consuming message::New Message

Obj2:: Consuming message::New Message

Obj3:: Consuming message::New Message</pre>

观察者模式的UML图