一、Observer模式定义对象间的一对多的依赖关系,当一个对象的状态发生改变时, 所有依赖于它的对象都得到通知并被自动更新。JDK里提供的observer设计模式的实现由java.util.Observable类和 java.util.Observer接口组成。从名字上可以清楚的看出两者在Observer 设计模式中分别扮演的角色：Observer是观察者角色，Observable是被观察目标(subject)角色。
二、观察者模式的优点：
1、 Subject和Observer之间是松耦合的，分别可以各自独立改变。
2、 Subject在发送广播通知的时候，无须指定具体的Observer，Observer可以自己决定是否要订阅Subject的通知。
3、 遵守大部分GRASP原则和常用设计原则，高内聚、低耦合。
三、观察者模式的缺陷：
1、 松耦合导致代码关系不明显，有时可能难以理解。(废话)
2、 如果一个Subject被大量Observer订阅的话，在广播通知的时候可能会有效率问题。（毕竟只是简单的遍历）
四、结构图
1）注册时：
2）Subject触发时：
五、这里写了一个实际开发中很有用的观察者模式的架构
1）观察者实现，抽象类的目的在于开发者只需要处理onMessage中的数据即可，不需要处理更多数据
package com.pinnet.observer; import com.pinnet.observable.MessageObservable; import javax.jms.ObjectMessage; import java.util.Observable; import java.util.Observer; /** * 观察者 * 抽象类的目的是更好的简化开发，实际开发中很有必要 */ public abstract class MessageObserver implements Observer { /** * 目的是在操作观察者的时候就加入到对应的被观察者中 * @param messageObservable */ public MessageObserver(MessageObservable messageObservable) { if (messageObservable == null) { return; } messageObservable.addObserver(this); } /** * 数据存在改变时触发，也是消息接收者 * @param observable * @param object */ public void update(Observable observable, Object object) { //这里采用ObjectMessage的数据形式，为了更好的传输对象数据 ObjectMessage objectMessage = (ObjectMessage) object; onMessage(objectMessage); } /** * 消息处理，需要具体实现 * @param objectMessage */ public abstract void onMessage(ObjectMessage objectMessage);
}
2）被观察者的继承，被观察者的方法基本都完善了，我们这里继承的目的是为了更好的理解
package com.pinnet.observable; import javax.jms.ObjectMessage; import java.util.Observable; /** * 被观察者 * 用来发送消息，这里不直接应用，采用消息中心模式在处理 */ public class MessageObservable extends Observable { /** * 发送消息在center中使用 * @param objectMessage */ public void sendMessage(ObjectMessage objectMessage) { //设置改变点 setChanged(); //发给观察者 notifyObservers(objectMessage); } }
3）消息处理中心，目的是为了提供更有用的工具
package com.pinnet.center; import com.pinnet.observable.MessageObservable; import org.apache.activemq.command.ActiveMQObjectMessage; import javax.jms.JMSException; import javax.jms.ObjectMessage; import java.io.Serializable; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * 消息处理中心，所有操作全部在这里 */ public class MessageCenter { //用于保存具体被观察者，发送数据，注册等 public static Map<MessageType, MessageObservable> messageMap = new ConcurrentHashMap<MessageType, MessageObservable>(); /** * 获取被观察者，添加观察者 * @param messageType * @return */ public MessageObservable getMessageObservable(MessageType messageType) { if (messageMap.containsKey(messageType)) { return messageMap.get(messageType); } else { MessageObservable messageObservable = new MessageObservable(); messageMap.put(messageType, messageObservable); return messageObservable; } } /** * 发送消息，统一入口 * @param messageType * @param serializable */ public void sendMessage(MessageType messageType, Serializable serializable) { if (messageMap.containsKey(messageType)) { try { MessageObservable messageObservable = messageMap.get(messageType); //这里采用的是ActiveMQ中实现类，当然可以自己实现ObjectMessage也可以 ObjectMessage objectMessage = new ActiveMQObjectMessage(); objectMessage.setObject(serializable); //被观察者发送给每个观察者 messageObservable.sendMessage(objectMessage); } catch (JMSException e) { e.printStackTrace(); } } } /** * 枚举类的目的是更好的控制数据发送 */ public enum MessageType { PUB,SUB } }
4）测试：简单实现一下即可，当然需要注册（注册部分可以写成xml，也可以自己写启动类）
a、写了两个观察者的实现类
package com.pinnet.observer.impl; import com.pinnet.observable.MessageObservable; import com.pinnet.observer.MessageObserver; import javax.jms.JMSException; import javax.jms.ObjectMessage; /** * 消息监听 */ public class PUBMessageListener extends MessageObserver { /** * 目的是在操作观察者的时候就加入到对应的被观察者中 * * @param messageObservable */ public PUBMessageListener(MessageObservable messageObservable) { super(messageObservable); } /** * 消息处理 * @param objectMessage */ public void onMessage(ObjectMessage objectMessage) { try { System.out.println(objectMessage.getObject()); } catch (JMSException e) { e.printStackTrace(); } } }
package com.pinnet.observer.impl; import com.pinnet.observable.MessageObservable; import com.pinnet.observer.MessageObserver; import javax.jms.JMSException; import javax.jms.ObjectMessage; public class SUBMessageListener extends MessageObserver { /** * 目的是在操作观察者的时候就加入到对应的被观察者中 * * @param messageObservable */ public SUBMessageListener(MessageObservable messageObservable) { super(messageObservable); } /** * 消息处理 * @param objectMessage */ public void onMessage(ObjectMessage objectMessage) { try { System.out.println(objectMessage.getObject()); } catch (JMSException e) { e.printStackTrace(); } } }
b、注册：统一写在了MessageCenter中
/** * 注册 */ public static void init() { new PUBMessageListener(MessageCenter.getMessageObservable(MessageType.PUB)); new PUBMessageListener(MessageCenter.getMessageObservable(MessageType.PUB)); new SUBMessageListener(MessageCenter.getMessageObservable(MessageType.SUB)); }
c、测试：
package com.pinnet; import com.pinnet.center.MessageCenter; public class Test { public static void main(String[] args) { MessageCenter.init(); MessageCenter.sendMessage(MessageCenter.MessageType.PUB, "pub"); MessageCenter.sendMessage(MessageCenter.MessageType.SUB, "sub"); } }
d、结果
六、观察者模式应用还是很不错的，特别是在分发数据，socket推送过后的数据分发处理等。当然不会离开消息队列，下一个博客将写到jms的用法。
