RabbitMQ-死信队列_amqp死信队列

概述

DLX，全称为Dead-Letter-Exchange , 可以称之为死信交换机，也有人称之为死信邮箱。当消息在一个队列中变成死信(dead message)之后，它能被重新发送到另一个交换机中，这个交换机就是DLX ，绑定DLX的队列就称之为死信队列。
消息变成死信，可能是由于以下的原因：

• 消息被拒绝
• 消息过期
• 队列达到最大长度

DLX也是一个正常的交换机，和一般的交换机没有区别，它能在任何的队列上被指定，实际上就是设置某一个队列的属性。当这个队列中存在死信时，Rabbitmq就会自动地将这个消息重新发布到设置的DLX上去，进而被路由到另一个队列，即死信队列。
要想使用死信队列，只需要在定义队列的时候设置队列参数 x-dead-letter-exchange 指定交换机即可。

案例

声明一个死信队列(和声明一个普通队列方式一样)

package com.chif.rabbitmq.springbootorderrabbitmqproducer.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;

@Configuration
public class DeadRabbitMqConfiguration {

    //1.声明注册direct模式的dead交换机
    @Bean
    public DirectExchange DeadExchange() {
        return new DirectExchange("dead_direct_exchange", true, false);
    }

    //2.声明队列 sms.direct.queue,email.direct.queue,duanxin.direct.queue
    @Bean
    public Queue deadQueue() {
        return new Queue("dead.direct.queue", true);
    }


    //3.完成绑定关系
    @Bean
    public Binding deadBinding() {
        return BindingBuilder.bind(deadQueue()).to(DeadExchange()).with("dead");
    }



}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

在之前设置过队列TTL的队列中绑定死信队列

package com.chif.rabbitmq.springbootorderrabbitmqproducer.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;

@Configuration
public class TTLRabbitMqConfiguration {

    //1.声明注册fanout模式的交换机
    @Bean
    public DirectExchange ttlDirectExchange() {
        return new DirectExchange("ttl_order_exchange", true, false);
    }

    //2.声明队列 sms.direct.queue,email.direct.queue,duanxin.direct.queue
    @Bean
    public Queue ttlDirectQueue() {
        //设置ttl过期时间
        HashMap<String, Object> args = new HashMap();
        args.put("x-message-ttl",5000);

        //设置死信队列的交换机和队列routingKey
        args.put("x-dead-letter-exchange","dead_direct_exchange");
        args.put("x-dead-letter-routing-key","dead");
        //设置队列的最大长度
        args.put("x-max-length",5);

        return new Queue("ttl.direct.queue", true,false,false,args);
    }

    @Bean
    public Queue ttlDirectMessageQueue() {
        //从MessagePostProcessor设置ttl过期时间
        return new Queue("ttlMsg.direct.queue", true);
    }

    //3.完成绑定关系
    @Bean
    public Binding ttlDirectBinding() {
        return BindingBuilder.bind(ttlDirectQueue()).to(ttlDirectExchange()).with("ttl");
    }

    @Bean
    public Binding ttlDirectMsgBinding() {
        return BindingBuilder.bind(ttlDirectMessageQueue()).to(ttlDirectExchange()).with("TTLMsg");
    }

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

测试发送数据就会发现，消息过期之后就会到死信队列中去