RabbitMQ笔记(九)-死信队列

柔情只为你懂 2022-03-27 11:36 296阅读 0赞

死信交换机: DLX，dead-letter-exchange

当消息在一个队列中变成死信 (dead message) 之后，它能被重新 publish 到另一个 队列

消息变成死信的原因有:

1.消息被拒绝 (basic.reject / basic.nack) 并且 reQueue=false

2.消息 TTL 过期

3.队列达到最大长度了

死信队列的使用场景

可以用做定时任务，也可以是存储超时消息，比如付费超时之类的

私信队列的使用

1.  直接在管理页面上创建

首先创建私信交换机demo.dead

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70]

再创建私信队列demo.dead

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 1]

绑定队列和交换器

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 2]

创建业务交换器demo

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 3]

创建业务队列demo

x-message-ttl: 指定消息超时时间是10000ms

x-dead-letter-exchange: 指定死信交换器为demo.dead

x-dead-letter-routing-key: 指定死信的routingKey是demo.dead

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 4]

在绑定业务队列到业务交换器

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 5]

1.  springboot应用中创建

public void createQueue(String topic, String queryName) throws IOException {
    
            log.info("create queue : {}, {}, {}", topic, queryName);
            RabbitChannelManager.MyChannel channel = rabbitChannelManager.getChannel();
            /* 创建死信队列 */
            String deadQueueName = addDeadSuffix(queryName);
            String deadRouteKey = addDeadSuffix(topic);
            channel.getChannel().queueDeclare(deadQueueName, true, false, false, null);
            channel.getChannel().queueBind(addDeadSuffix(queryName), rabbitConfiguration.getDeadExchange(), deadRouteKey);
    
            /* 创建队列，加入死信转发参数 */
            Map<String, Object> deadArgs = new HashMap<>();
            deadArgs.put("x-message-ttl", rabbitConfiguration.getDeadMessageTtl());
            deadArgs.put("x-dead-letter-exchange", rabbitConfiguration.getDeadExchange());
            deadArgs.put("x-dead-letter-routing-key", deadRouteKey);
            channel.getChannel().queueDeclare(queryName, true, false, false, deadArgs);
            channel.getChannel().queueBind(queryName, rabbitConfiguration.getDefaultExchange(), topic);
    
            rabbitChannelManager.returnChannel(channel);
    
        }

创建好的队列列表

![在这里插入图片描述][20190113143957883.jpg]

测试一下

发送一条消息到demo队列，查看队列情况

![在这里插入图片描述][20190113144007125.jpg]

可以看到demo队列有一条消息

等待一会后再看队列情况

![在这里插入图片描述][20190113144015863.jpg]

可以看到该消息已经因为超时而转发到了demo.dead死信队列

另外两种情况也是同样的结果就不多写了

欢迎关注微信交流  
![在这里插入图片描述][70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70]: /images/20220327/04ab1dbeb0fb47acb7f1bab112e44f80.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 1]: /images/20220327/8b10a28246744e2eade11e5bcd45a0bb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 2]: /images/20220327/1757227c30ae4b56b1ce114831873465.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 3]: /images/20220327/a1417ec4b70648c5a947abca6c508334.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 4]: /images/20220327/634635fcc6224cc28ba54cee729f2304.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpbmd6aWlzbWU_size_16_color_FFFFFF_t_70 5]: /images/20220327/a4a2272db37246ce83b5a27fbf0945d8.png
[20190113143957883.jpg]: /images/20220327/5f027de3d9e54260ad3034b5229c992c.png
[20190113144007125.jpg]: /images/20220327/cb52efd360034407be51e8f1347634a2.png
[20190113144015863.jpg]: /images/20220327/ed176f5d086d4125beee94122b60df41.png
[70]: /images/20220327/2ea77d985a554f628acd86b6ad08fe9f.png