private List subs= new ArrayList(); private String msg;
// this message is added so I can give // this class a reason to call notifyListener. public void setMessage(String message){ System.out.println("我是发布者,我说:" + message); this.messageText = message; this.notifyListeners(); }
public void addListener(Subscriber o) { this.subs.add(o); }
public void removeListener(Subscriber o) { if (this.subs.contains(o)){ this.subs.remove(o); } }
// call the update method on // each Subscriber
public void notifyListeners() { for (Iterator iter = subs.iterator(); iter.hasNext();) { Subscriber listener = (Subscriber ) iter.next(); listener.update(msg); } }
} 预定者类:Subsriber1.java
public class Subsriber1 implements Observer { public void update(String messageText) { System.out.println("我的名字是: " + this); System.out.println("我接收到消息: " + messageText); } 预定者类:Subsriber2.java
public class Subsriber2 implements Observer { public void update(String messageText) { System.out.println("我的名字是: " + this); System.out.println("我接收到消息: " + messageText); }