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