标签：交换器 AMQP 队列 RabbitMQ 概念 死信 交换机 消息 使用
1.1 AMQP
1.1.1 AMQP是什么?
RabbitMQ就是 AMQP 协议的 Erlang 的实现(当然 RabbitMQ 还支持 STOMP2、 MQTT3 等协议 ) AMQP 的模型架构 和 RabbitMQ 的模型架构是一样的，生产者将消息发送给交换器，交换器和队列绑定 。
RabbitMQ 中的交换器、交换器类型、队列、绑定、路由键等都是遵循的 AMQP 协议中相 应的概念。目前 RabbitMQ 最新版本默认支持的是 AMQP 0-9-1。
1.1.2 AMQP协议3层？
i. Module Layer:协议最高层，主要定义了一些客户端调用的命令，客户端可以用这些命令实现自己的业务逻辑。
ii. Session Layer:中间层，主要负责客户端命令发送给服务器，再将服务端应答返回客户端，提供可靠性同步机制和错误处理。
iii. TransportLayer:最底层，主要传输二进制数据流，提供帧的处理、信道服用、错误检测和数据表示等。
1.1.3 AMQP模型的几大组件？
交换器 (Exchange)：消息代理服务器中用于把消息路由到队列的组件。
队列 (Queue)：用来存储消息的数据结构，位于硬盘或内存中。
绑定 (Binding)：一套规则，告知交换器消息应该将消息投递给哪个队列。
1.1.4 Spring AMQP
在本项目中，使用的是spring AMQP，使用方法是：
1、 导入依赖
2、 配置RabbitMQ的地址
3、 生产者：可直接通过@Autowired注入AmqpTemplate，直接调用方法，用来发送消息，当然，同时要指定交换机的名字，和routing key
4、 创建消费者：直接在封装处理消息的逻辑上，使用注解指定绑定的消息队列和交换机的名字，指定是否可持久化，交换机的类型，routing key
可以在这个类中创建多个方法，添加注解后，表示多个消费者
1.2 队列
1.2.1 队列结构？
通常由以下两部分组成？
\1) rabbit_amqqueue_process:负责协议相关的消息处理，即接收生产者发布的消息、向消费者交付消息、处理消息的确认(包括生产端的 confirm 和消费端的 ack) 等。
\2) backing_queue:是消息存储的具体形式和引擎，并向 rabbit amqqueue process提供相关的接口以供调用。
1.2.2 死信队列？
DLX，全称为 Dead-Letter-Exchange，死信交换器，死信邮箱。当消息在一个队列中变成死信 (dead message) 之后，它能被重新被发送到另一个交换器中，这个交换器就是 DLX，绑定 DLX 的队列就称之为死信队列。
1.2.2.1 导致的死信的几种原因？
\1) 消息被拒（Basic.Reject /Basic.Nack) 且 requeue = false。
\2) 消息TTL过期。
\3) 队列满了，无法再添加。
1.2.3 优先级队列？
优先级高的队列会先被消费。
可以通过x-max-priority参数来实现。
当消费速度大于生产速度，且Broker没有堆积的情况下，优先级显得没有意义。
1.2.4 延迟队列？
存储对应的延迟消息，指当消息被发送以后，并不想让消费者立刻拿到消息，而是等待特定时间后，消费者才能拿到这个消息进行消费。
1.2.4.1 实现延时队列的两种方式
Rabbitmq本身是没有延迟队列的，要实现延迟消息，一般有两种方式：
1、 通过Rabbitmq本身队列的特性来实现，需要使用Rabbitmq的死信交换机（Exchange）和消息的存活时间TTL（Time To Live）
若想不借助插件实现rabbitMQ的延迟消息，实际就是利用一个没有消费者的Queue1，等待消息过期后，通过交换机转发到Queue2来进行消费，消息的延迟时间就是消息在Queue1中的存活时间
这里相当于利用了死信队列，即当消息在一个队列中变成死信 (dead message) 之后，它能被重新被发送到另一个交换器中，这个交换器就是 DLX，绑定 DLX 的队列就称之为死信队列
2、 在rabbitmq 3.5.7及以上的版本提供了一个插件（rabbitmq-delayed-message-exchange）来实现延迟队列功能。同时插件依赖Erlang/OPT 18.0及以上
1.2.4.2 完成半小时再支付的设计
利用死信队列
导致的死信的几种原因？
\1) 消息被拒（Basic.Reject /Basic.Nack) 且 requeue = false。
\2) 消息TTL过期。
\3) 队列满了，无法再添加。
理解：
代码编写流程是：
有一个(n个)正常业务的Exchange，比如为user-exchange。
有一个(n个)正常业务的Queue，比如为user-queue。（因为该队列需要绑定死信交换机，所以需要加俩参数：死信交换机:x-dead-letter-exchange，死信消息路由键:x-dead-letter-routing-key）
进行正常业务的交换机和队列绑定。
定义一个死信交换机，比如为common-dead-letter-exchange。
将正常业务的队列绑定到死信交换机(队列设置了x-dead-letter-exchange即会自动绑定)。
定义死信队列user-dead-letter-queue用于接收死信消息，绑定死信交换机。
消息会变成死信消息的场景：
\1. 消息被(basic.reject() or basic.nack()) and requeue = false，即消息被消费者拒绝签收，并且重新入队为false。
有一种场景需要注意下：消费者设置了自动ACK，当重复投递次数达到了设置的最大retry次数之后，消息也会投递到死信队列，但是内部的原理还是调用了nack/reject。
\2. 消息过期，过了TTL存活时间。
\3. 队列设置了x-max-length最大消息数量且当前队列中的消息已经达到了这个数量，再次投递，消息将被挤掉，被挤掉的是最靠近被消费那一端的消息。
标签：交换器,AMQP,队列,RabbitMQ,概念,死信,交换机,消息,使用 来源： https://www.cnblogs.com/askfb/p/15474738.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。