.setMessage Listener

一、简介 幂等性是分布式中比较重要的一个概念，是指在多作业操作时候避免造成重复影响，其实就是保证同一个消息不被消费者重复消费两次，但是可能存在网络波动等问题，生产者无法接受消费者发送的ack信息，因此这条消息将会被重复发送给其他消费者进行消费，实际上这条消息已经被消费过了，这就是重复消费的问题。 如何避免重复消费的问题 1.消息全局唯一ID 2.通过redis中的setnx命令，给消息分配一个全局ID，当消费了这个消息的时候写入redis ----下面通过第一种方式示例来避免重复消费 二、消息全局ID 【1】 将队列和交换机绑定 @Configuration public class DirectRabbitConfig { @Bean public Queue TestDirectQueue() { return new Queue("TestDirectQueue",true); } @Bean DirectExchange TestDirectExchange() { return new...