Rabbitmq死信队列

写一点笔记

发布于 2022-08-11 15:55:13

2060

发布于 2022-08-11 15:55:13

文章被收录于专栏：程序员备忘录程序员备忘录

在上一节中我们说不会被消费的消息都被称为死信。那么死信队列就是存储死消息的队列，也就是存储不会被消费者消费的队列，显然死信队列就是一个排查问题的队列。我们可以认为其就是一个日志队列。

死信队列DLX，全称Dead-letter-exchange，可以称为死信交换器，也可以叫做死信邮箱。当消息在一个队列中变为死信之后，它能被重新发送到另一个交换器中，这个交换器就是dlx，绑定到dlx的队列就被称为死信队列。

消息变成死信一般有以下几种情况：

1.消息被拒绝，并设置requeue参数为false

2.消息过期

3.队列达到最大长度

dlx但是其最大的功能就是将死信消息发送到死信队列中。

通过在channel.queueDeclare方法中设置x-dead-letter-exchange参数来位这个队列添加dlx。但是要注意的是DLX队列的使用不能和AE混合使用。否则会将消息发送到AE交换器上。

    @Bean
    public Queue AAQueue() {
        Map map=new HashMap<>();
        map.put("x-message-ttl",2000);
        map.put("x-dead-letter-exchange","C");
        map.put("x-dead-letter-routing-key","");
//        map.put("x-expires",2000);
        return new Queue("AA",true,false,false,map);
    }

    @Bean
    public Queue CCQueue() {
        return new Queue("CC");
    }

    @Bean
    public DirectExchange exchangeA() {
        Map map=new HashMap<>();
        return new DirectExchange("A",true,false,map);
    }

    @Bean
    public DirectExchange exchangeC() {
        return new DirectExchange("C");
    }


    @Bean
    public Binding delayBindingA(Queue AAQueue, DirectExchange exchangeA) {
        return BindingBuilder.bind(AAQueue).to(exchangeA).with("aaa");
    }

    @Bean
    public Binding exchangeCinding(DirectExchange exchangeC, Queue CCQueue) {
        return BindingBuilder.bind(CCQueue).to(exchangeC).with("");
    }