SpringBootRabbitMQ

大家好，我是磊哥！死信：无法被消费的消息，称为死信。如果死信一直留在队列中，会导致一直被消费，却从不消费成功。所以我们专门开辟了一个来存放死信的队列，叫死信队列（DLX，dead-letter-exchange）。死信的几种来源：消息TTL过期（timetolive，存活时间，可以用在限时支付消息）队列达到最大长度（队列满了，无法路由到该队列）消息被拒绝（basic.reject/basic.nack），并且requeue=false环境准备配置准备MQ的队列和环境：正常交换机正常队列（最长队列5）----正常消费者，拒绝消息ttl队列（过期时间60秒）----没有消费者死信交换机死信队列主要配置文件如下：注意文末有：页互联网大厂面试题ConfigurationpublicclassDeadConfig{/*正常配置**********************************************************************************************************//***正常交换机，开启持久化*/

BeanDirectExchangenormalExchange(){returnnewDirectExchange("normalExchange",true,false);}

BeanpublicQueuenormalQueue(){//durable:是否持久化,默认是false,持久化队列：会被存储在磁盘上，当消息代理重启时仍然存在，暂存队列：当前连接有效//exclusive:默认也是false，只能被当前创建的连接使用，而且当连接关闭后队列即被删除。此参考优先级高于durable//autoDelete:是否自动删除，当没有生产者或者消费者使用此队列，该队列会自动删除。MapString,Objectargs=deadQueueArgs();//队列设置最大长度args.put("x-max-length",5);returnnewQueue("normalQueue",true,false,false,args);}

BeanpublicQueuettlQueue(){MapString,Objectargs=deadQueueArgs();//队列设置消息过期时间60秒args.put("x-message-ttl",60*);returnnewQueue("ttlQueue",true,false,false,args);}

BeanBindingnormalRouteBinding(){returnBindingBuilder.bind(normalQueue()).to(normalExchange()).with("normalRouting");}

BeanBindingttlRouteBinding(){returnBindingBuilder.bind(ttlQueue()).to(normalExchange()).with("ttlRouting");}/*死信配置**********************************************************************************************************//***死信交换机*/

BeanDirectExchangedeadExchange(){returnnewDirectExchange("deadExchange",true,false);}/***死信队列*/

BeanpublicQueuedeadQueue(){returnnewQueue("deadQueue",true,false,false);}

BeanBindingdeadRouteBinding(){returnBindingBuilder.bind(deadQueue()).to(deadExchange()).with("deadRouting");}/***转发到死信队列，配置参数*/privateMapString,ObjectdeadQueueArgs(){MapString,Objectmap=newHashMap();//绑定该队列到私信交换机map.put("x-dead-letter-exchange","deadExchange");map.put("x-dead-letter-routing-key","deadRouting");returnmap;}}arguments具体参数如下：队列达到最大长度首先测试最简单的，没有消费者。调用6次正常队列的生产方法。

/***正常消息队列，队列最大长度5*/

GetMapping("/normalQueue")publicStringnormalQueue(){MapString,Objectmap=newHashMap();map.put("messageId",String.valueOf(UUID.randomUUID()));map.put("data",System.currentTimeMillis()+",正常队列消息，最大长度5");rabbitTemplate.convertAndSend("normalExchange","normalRouting",map,newCorrelationData());returnJSONObject.toJSONString(map);}MQ结果如下：消息TTL过期消息的TTL指的是消息的存活时间，我们可以通过设置消息的TTL或者队列的TTL来实现。消息的TTL：对于设置了过期时间属性(expiration)的消息，消息如果在过期时间内没被消费，会过期队列的TTL：对于设置了过期时间属性(x-message-ttl)的队列，所有路由到这个队列的消息，都会设置上这个过期时间两种配置都行，一般都用在定时任务，限时支付这种地方。

/***消息TTL,timetolive*/

GetMapping("/ttlToDead")publicStringttlToDead(){MapString,Objectmap=newHashMap();map.put("messageId",String.valueOf(UUID.randomUUID()));map.put("data",System.currentTimeMillis()+",ttl队列消息");rabbitTemplate.convertAndSend("normalExchange","ttlRouting",map,newCorrelationData());returnJSONObject.toJSONString(map);}发送后：等待过期后：Demo中只是为了方便，代码中尽量使用消息TTL，不要用队列TTL拒绝消息正常队列消费后拒绝消息，并且不进行重新入队：Component

RabbitListener(queues="normalQueue")publicclassNormalConsumer{

RabbitHandlerpublicvoidprocess(MapString,Objectmessage,Channelchannel,MessagemqMsg)throwsIOException{System.out.println("收到消息，并拒绝重新入队:"+message.toString());channel.basicReject(mqMsg.getMessageProperties().getDeliveryTag(),false);}}MQ控制台：死信队列消费：Component

RabbitListener(queues="deadQueue")publicclassDeadConsumer{

RabbitHandlerpublicvoidprocess(MapString,Objectmessage,Channelchannel,MessagemqMsg)throwsIOException{System.out.println("死信队列收到消息:"+message.toString());channel.basicAck(mqMsg.getMessageProperties().getDeliveryTag(),false);}}消息顺序和实验一致：

死信队列收到消息:{data=5,正常队列消息，最大长度5,messageId=bceb-da38--ac88-d22cbe}死信队列收到消息:{data=5,ttl队列消息,messageId=a-5aab-4fac-aec7-ea}死信队列收到消息:{data=5,正常队列消息，最大长度5,messageId=b65ecaab-5ce7--a32c-c90b67ec46da}死信队列收到消息:{data=8,正常队列消息，最大长度5,messageId=d63d2a4c-e7d3-4f00-a6ca-78e2d62d1d92}死信队列收到消息:{data=7,正常队列消息，最大长度5,messageId=eed0c-b-43dc-aa79-ca}死信队列收到消息:{data=1,正常队列消息，最大长度5,messageId=7a7bd-f2fa-4a74-b9e6-ac7cbb3d4}死信队列收到消息:{data=4,正常队列消息，最大长度5,messageId=9dea1-4ca4---27aba01c}来源：

转载请注明：http://www.aierlanlan.com/rzdk/540.html