利用Listener模式解决复杂业务逻辑

?

在传统的编程模型中，对数据更改是同步操作。

举一个常见的例子来说。小明在购物网站购物，进行支付并成功时。购物网站要做四件事： 1 、更新订单状态， 2 、插入支付记录 3 、编写订单日志。 4 、通知支付系统，回调成功。

在系统实现过程，我们通常采用如下代码完成这些任务

    public void successToPay(PurchaseOrder order){        //1、更改支付状态        order.setPayStatus(PayStatus.SUCCESS);        orderDao.save(order);        //2、插入支付记录        PayRecord record= RecordFactory.getSuccessRecord(order);        recordDao.insert(record);        //3、插入订单日志        OrderLog log = OrderFactory.getPaidLog(order);        logDao.insert(log);        //4、通知财务系统，支付成功        NotifyLog notifylog= NotifyFacotry.getSuccessNotify(order);        nofifyService.notify(notifylog);    }

????? 如果有购物网站需要再把支付结果通知相关系统，则我们需要修改这个方法。在业务逻辑简单的时候，我们可以直接修改此方法，但是逻辑越来越发杂时，修改此方法是一件风险很大事情。如果没有测试驱动保证，代码真的很难改

?

????? 如果使用领域模型来解决此问题，则采用事件监听模式。

????? 顾客成功支付是事件，而订单模块，财务模块，日志模块，支付模块则是监听器。

????? 具体实现方式如下：

public class PurchaseOrder {    public void notifyOrderPaid(List<OrderListener> listeners){        for(OrderListener listener:listeners){            listener.onOrderSuccessPaid(listener);        }    }}public  interface OrderListener{    public void onOrderSuccessPaid(PurchaseOrder order);}public class OrderDaoListener implements  OrderListener{    private OrderDao orderDao;    public void onOrderSuccessPaid(PurchaseOrder order){        order.setPayStatus(PayStatus.SUCCESS);        orderDao.save(order);    }}public class PayRecordDaoListener implements  OrderListener{    private PayRecordDao payRecordDao;    public void onOrderSuccessPaid(PurchaseOrder order){        PayRecord record= RecordFactory.getSuccessRecord();        payRecordDao.insert(record);    }}public class LogDaoListener implements OrderListener{    private  LogDao logDao;    public void onOrderSuccessPaid(PurchaseOrder order){        Log log = OrderFactory.getPaidLog(order);        logDao.insert(log);    }}public class FinanceListener  implements  OrderListener{    private FinanceService financeService;    public void onOrderSuccessPaid(PurchaseOrder order){        NotifyLog notifylog= NotifyFacotry.getSuccessNotify(order);        nofifyService.notify(notifylog);    }}public class OrderService{      public void successToPay(PurchaseOrder order){          List<OrderListener> listeners =new ArrayList<OrderListener>();          listeners.add(new PayRecordDaoListener());          listeners.add(new OrderDaoListener());          listeners.add(new FinanceListener());          listeners.add(new LogDaoListener());          order.onOrderSuccessPaid(listeners);      }}

????? 此方式的特点：purchaseOrder得到增强，不同于与贫血Entity，purchaseOrder需要告诉监听器其自身的状态变化；如果需要把支付状态通知给新的模块，只需要继承Listener接口，创建新的监听器即可。

?

???? 事实上还有第三种方式：event/eventListener。purchaseOrder负责发布事件，相关模块负责监听purchaseOrder发布的事件，然后又eventBus负责派发和捕获。

???? 但是限于自身能力，还没有完全领会，如果有更好的想法，咱们就一起讨论下：）

?

?

?

?