一，RabbitMQ六种工作模式

​ RabbitMQ 是一个消息中间件：它接受并转发消息。你可以把它当做一个快递站点，当你要发送一个包裹时，你把你的包裹放到快递站，快递员最终会把你的快递送到收件人那里，按照这种逻辑 RabbitMQ 是一个快递站，一个快递员帮你传递快件。RabbitMQ 与快递站的主要区别在于，它不处理快件而是接收，存储和转发消息数据。

核心概念：

• Broker：接收和分发消息的应用，RabbitMQ Server 就是 Message Broker
• Virtual host：出于多租户和安全因素设计的，把 AMQP 的基本组件划分到一个虚拟的分组中，类似 于网络中的 namespace 概念。当多个不同的用户使用同一个RabbitMQ server提供的服务时可以划分出多个vhost，每个用户在自己的vhost创建 exchange／queue等
• Connection：publisher／consumer 和 broker 之间的 TCP 连接
• Channel：如果每一次访问 RabbitMQ 都建立一个 Connection，在消息量大的时候建立 TCP Connection 的开销将是巨大的，效率也较低。Channel 是在 connection 内部建立的逻辑连接，如果应用程 序支持多线程，通常每个 thread 创建单独的 channel 进行通讯，AMQP method 包含了 channel id 帮助客 户端和 message broker 识别 channel，所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销
• Exchange：message 到达 broker 的第一站，根据分发规则，匹配查询表中的 routing key，分发消息到 queue 中去。常用的类型有：direct (point-to-point), topic (publish-subscribe) and fanout (multicast)
• Queue：消息最终被送到这里等待 consumer 取走
• Binding：exchange 和 queue 之间的虚拟连接，binding 中可以包含 routing key，Binding 信息被保 存到 exchange 中的查询表中，用于 message 的分发依据.

一，RabbitMQ整合Spring

1.1 引入基础配置

第一步：引入Spring整合RabbitMQ的jar包：

<dependency>
	<groupId>org.springframework.amqp</groupId>
	<artifactId>spring-rabbit</artifactId>
	<version>2.1.8.RELEASE</version>
</dependency>

一，整合SpringBoot

创建SpringBoot项目，引入jar包

<dependency>
	<groupId>org.apache.rocketmq</groupId>
	<artifactId>rocketmq-spring-boot-starter</artifactId>
	<version>2.1.1</version>
</dependency>

消息的可靠传递

RocketMQ消息的延迟消息实现原理

• 存储阶段的“偷梁换柱”: 消息的主题和队列ID替换为系统内部主题 SCHEDULE_TOPIC_XXXX
• 调度与转发阶段: Broker内部有一个后台线程池（ScheduleMessageService），专门负责处理延迟消息,它会每隔1秒（或配置间隔）去对应的队列（SCHEDULE_TOPIC_XXXX 的特定队列）拉取消息,
  • 拉取到消息后，会检查消息的“预定投递时间”（存储时计算出的 当前时间 + 延迟时长）是否小于当前系统时间
  • 如果未到期：则重新挂起定时任务，等待下一轮（1秒后）检查。**
  • 如果已到期：Broker会利用原消息体，重新构建一条新消息。将新消息的主题（Topic）改回之前保存的 REAL_TOPIC（OrderTopic），队列改回 REAL_QID。**

一，基础安装

1.1 安装ErLang

由于RabbitMQ是基于Erlang语言开发的，所以在安装RabbitMQ之前需要先安装Erlang的运行环境。

erlang与RabbitMQ版本的对应关系:https://www.rabbitmq.com/which-erlang.html

如：RabbitMQ3.6.10，建议的erlang最小版本是R16Bo3，最大版本19.3.x

一，消息的可靠投递

1.1 消息的发布和确认

消息的发布和确认目的是为了让生产者确认消息已经投递成功了。

消息的投递流程如下：

根据消息的投递流程RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式。

• confirm 确认模式：消息从 producer 到 exchange投递结果，设置ConnectionFactory的publisher-confirm-type="true" 开启确认模式，使用rabbitTemplate.setConfirmCallback设置回调函数，在方法中判断ack，如果为true，则发送成功，如果为false，则发送失败。
• return 退回模式：消息从 exchange 到 queue 投递结果，设置ConnectionFactory的publisher-returns="true" 开启退回模式,使用rabbitTemplate.setReturnCallback设置退回函数，如果同时设置了rabbitTemplate.setMandatory(true)参数，则会将消息退回给producer。

一，RabbitMQ的各种队列

1.1 死信队列

由于特定的原因导致 queue 中的某些消息无法被消费，就变成了死信，死信队列是为了优雅的处理着这些无法被消费者正常消费的信息，消息变成死信有如下三种情况：

• 消息 TTL 过期
• 队列达到最大长度(队列满了，无法再添加数据到 mq 中)
• 消息被拒绝(basic.reject 或 basic.nack)并且 requeue=false.

架构图：

一，Docker安装RocketMQ

1.1 创建namesrv服务

拉取镜像

docker pull rocketmqinc/rocketmq

一，基础API操作

新建mavn项目导入jar包：

<dependency>
	<groupId>org.apache.rocketmq</groupId>
	<artifactId>rocketmq-client</artifactId>
	<version>4.7.1</version>
</dependency>