1.如何保证生产者发送的消息正确的送到了队列?
解决办法: 采用MQ消息确认机制。Confirm机制
2.生产者发送消息成功后,消费者消费失败了,该怎么做?
注意幂等性: 1个生产者,多个消费者,其中一个消费者出现,消息重新分发,避免重复消费问题。 采用消息重试机制,手动Ack,注意重试幂等性问题。
3.如何保证第一个事务先执行,采用补偿机制(补单机制),在创建一个补单消费者进行监听,如果订单没有创建成功,进行补单
生产者发送消息成功了,数据库里插入的记录,消费者收到消息,也消费成功了,生产者突然报错了,该怎么办?
解决办法:
生产者开启了事务,会进行回滚,但是消费者数据已经插入了。
生产者发送消息时,消息同时发送到2个队列里面,一个是消费队列,一个是消费的补偿队列。
消费队列正常消费。
消费补偿队列:用了确保生产者数据的一致性问题。补偿队列,根据唯一id查询数据库,如果没有查询到生产者 数据库创建的记录,则进行重新创建操作,如果查询到了,说明生产者是成功的,什么都不做。