Producer与Consumer之间解耦的分布式事务解决方案

Producer去查询Consumer消息时从RPC调用换为消息发布订阅。
1）producer中的scheduler每隔一分钟会发送check消息至同一个事务消息topic
2）consumer收到消息时使用keys来区分check消息或者事务消息，如果是check消息，那么查询数据库后将check-reply消息发送给另一个topic（比如叫 事务消息topic+"check"）
3）producer订阅了这个topic，然后在接收到check-reply消息时去更新消息状态，然后重发确认消息发送失败的消息。

Producer与Consumer之间存在耦合的分布式事务解决方案

Producer获取Consumer的新的消息状态是使用RPC调用的方式，这就要求Producer必须知道它的Consumer是谁，也势必要引入Consumer的API包，这不是一种好的设计。