混合乱用模式之《观察者模式》AND《责任链模式》

有时候面对复杂的场景，就想着怎么解耦、怎么复用、怎么扩展，然后无意间各种设计模式就拧巴在一起了。

责任链和观察者的区别

责任链强调的是顺序，前后可能有逻辑关系。而观察者体现的是的独立性。虽然都有传递消息通知执行的功能，但是侧重点不同。

两个结合使用

我的这个业务场景正好符合混合使用。因为一个消息发布后，可能会通知多个observer，同时在一个observer上执行逻辑的时候，可能会有很长的链路要走，所以可能会有下一个处理的handler。

有各个observer需要实现的dealWithMessage方法，也有nextProcessor 处理器，整体属于一个observer

MessageObserver

package com.xxx.sales.saicorder.outerapp;import com.xxx.sales.saicorder.outerapp.tmall.dto.MessageDTO;
import com.xxx.sales.saicorder.outerapp.tmall.dto.MessageDealResultDTO;
import com.taobao.api.ApiException;/*** 消息处理方案*/
abstract public class MessageObserver {/*** 后面紧接着要处理的业务* 这里通常是将一个业务线上的很长的执行步骤，按照某一个维度进行垂直分割以后，形成的一个chain.* 执行的时候是按照业务线依次执行的。如果可以一步完成，就没有next processor*/private MessageObserver nextProcessor;public MessageObserver(MessageObserver nextProcessor) {this.nextProcessor = nextProcessor;}/*** 没有next processor的可以直接无参构造*/public MessageObserver() {}/*** 处理逻辑** @param messageData* @param contextObject* @return*/public abstract MessageDealResultDTO dealWithMessage(MessageDTO messageData, MessageDealResultDTO contextObject) throws ApiException;public MessageDealResultDTO doProcessor(MessageDTO messageData, MessageDealResultDTO contextObject) throws ApiException {dealWithMessage(messageData, contextObject);if (nextProcessor != null) {nextProcessor.doProcessor(messageData, contextObject);}return contextObject;}}

---

观察者使用

这些模式的用的算是比较多的。