利用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负责派发和捕获。

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