消息中间件的最终一致性如何保证？架构上面，主要考虑以下几个方面：

       1。事务同步；

       2。消息缓存or持久化；

       3。定时钟轮询

       事务同步很好理解。我的消息总不能在事务提交前发出去吧？为此，架构设计中我们通常这么干：

    public boolean publish(AsyncEvent event) {
        boolean result = true;
        //1.delegate task to TransactionSynchronizationManager's afterCompletion method
        if (TransactionSynchronizationManager.isSynchronizationActive()) {
            TransactionSynchronizationManager
                    .registerSynchronization(new MQTransactionSynchronization(event, eventSender));
        } else {
            //2. just do it by manual processing
            logger.info("Publish event: {}", event);
            result = eventSender.send(event);
        }
        return result;
     }

        消息缓存or持久化，这里有两个进行实际处理的时机。其一，事务提交后，缓存或者数据库中持有一份事件，这个也比较契合EDA架构；第二个持久化的时机可以放到消息发送失败的时候。通常情况下，需要综合考虑DeliveryMode，AUTO_ACKNOWLEDGE等参数的设置。

        定时钟轮询，这一步也是MOM高可用性的一大保障。一旦我们缓存或者持久化消息后，当消息消费端出现问题，异或其它原因导致消费阻塞，我们就可以通过定时钟轮询+重推机制确保消息的最终一致性。