container.setConcurrent Consumers

一、什么是RabbitMQ？ MQ全称为Message Queue，即消息队列。消息队列是在消息的传输过程中保存消息的容器。它是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦 二、RabbitMQ与Kafka的全面对比 对比项KafkaRabbitMQ 开发语言 scala、Java erlang 是否支持多租户 2.x.x支持 支持 是否支持topic优先级 不支持 支持 是否支持消息全局有序 不支持 支持 是否支持消息分区有序 支持 支持 是否有内置监控 无 有 是否支持多个生产者 支持 支持 是否支持多个消费者 支持 支持 是否支持一个分区多个消费者 不支持 不支持 是否支持JMX 支持 不支持 是否支持加密 支持 支持 消息队列协议支持 仅支持自定义协议 支持AMQP、MQTT、STOMP协议 客户端语言支持 支持 支持 是否支持消息追踪 不支持 支持 是否支持消费者推模式 不支持 支持 否支持消费者拉模式 支持 支持...

一、简介 幂等性是分布式中比较重要的一个概念，是指在多作业操作时候避免造成重复影响，其实就是保证同一个消息不被消费者重复消费两次，但是可能存在网络波动等问题，生产者无法接受消费者发送的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...