rocketmq分布式事务中,从生产者到发送消息到MQ,消费者接收都是正常。那么如果消费者接收消息,然后进行处理出现了异常,那么消费者进行回滚。那么生产者呢?以及MQ这条消息他们两是如何处理的?生产者出现回滚吗?
1是重试,失败他会重新发送,重试的次数自己定义
2是一个消费失败会尝试寻找另一个消费者,保证队列运行
3舍弃
生产者和消费者之间的消息传递是通过消息队列来实现的。当生产者发送消息时,它将消息放入消息队列中。当消费者消费消息时,它从消息队列中获取消息并进行处理。如果消费者在处理消息时出现异常,消息会从消息队列中丢失。在这种情况下,生产者可以通过回滚事务来回滚之前的消息,并重新发送最新的消息。