什么是rabbitMQ？
RabbitMQ是用Erlang语言开发的AMQP（高级消息队列协议）的开源实现。
RabbitMQ轻量级且易于部署，并且可以支持多种消息协议。
RabbitMQ可以部署在分布式和联合配置中，以满足大规模的高可用性需求。
具体功能包括：
可靠性：RabbitMQ使用了一些机制来保证可靠性，比如持久化、传输确认、发布确认等。
灵活的路由：消息在进入队列之前通过Exchange进行路由。对于典型的路由功能，RabbitMQ提供了几个内置的交换来实现。对于更复杂的路由功能，可以连接多个exchange，也可以通过插件机制实现自己的exchange。
集群：多个RabbitMQ服务器可以组成一个集群，形成一个逻辑代理。
高可用队列：队列可以在集群中的计算机上进行镜像，因此即使某些节点发生故障，队列仍然可用。
多协议：RabbitMQ支持STOMP、MQTT等多种消息队列协议。
Multilingualclient（多客户端）：RabbitMQ支持几乎所有常见的语言，如Java、.NET、Ruby等。
管理UI：RabbitMQ提供了一个易于使用的用户界面，允许用户监控和管理消息代理的许多方面。
Tracing：如果消息异常，RabbitMQ提供了消息追踪机制，让用户可以及时发现发生了什么。
插件机制（plug-insystem）：RabbitMQ提供了多种插件进行多种方式的扩展，你也可以编写自己的插件。
展开全文
RabbitMQ管理模型
为什么要使用rabbitMQ？
下面我将以商人（花店）的角色给大家举个例子：
异步地
在顾客来店里下单之前，我会先让顾客等一会，同时让店员准备好订单，等到可以送货到店时，顾客才能离开。顾客现在客户给我打电话：“我要买xxx，地址是：xxx，发给我，我拿个小本子，记下：客户a，电话：xxx，地址：xxx
当员工有空时准备好订单并发货
解耦
以前有新订单时，我亲自去找每个文员（负责准备花束、会计、送花等），告诉他们有新订单，我有空就去处理.
有官员参加工作，我再通知一个人；当我下班时，我通知的人少了（我保留了一份需要通知的人的名单）
现在，当有新订单时，我只是把它记在一个小本子上，店员有空的时候就会看一下。
剪裁
去年七夕节我接到了很多电话。我把每一个订单都告诉了店员，但是店员太忙了，顾客不停地打电话提醒我。
最后，这位官员受够了，罢工了
今年七夕我学会了做人。当电话打进来时，我告诉客户，“我知道了，我会尽快安排修好”，然后我把它记在一本小本子上。当店员有空时，他会按顺序完成订单。
另一个思路是引导客户不要在七夕节开始下单，而是提前购买（淘宝双十一预售就是基于这个topidea）
以上就是rabbitMQ解决的主要问题。
如何使用rabbitMQ？
基本安装方法
MAC页面
酿造安装rabbitmq
复制代码
窗边
安装Erlang，下载地址：erlang.org/download/ot...
安装RabbitMQ，下载地址：dl.bintray.com/rabbitmq/al...
安装完成后，进入RabbitMQ安装目录下的sbin目录
在地址栏中输入cmd并回车启动命令提示符，然后输入以下命令启动管理功能：
Králikmq-plugins启用králikmq_management
复制代码
CentOS页面
安装二郎
#rabbitmq依赖erlang，需要自己下载
cd/path/to/erlang-sound-code&&./configure--prefix=/usr/local/erlang
做&&安装
vim/etc/配置文件
＃添加
导出PATH=$PATH:/usr/local/erlang/bin资源/etc/profile
#输入erl，会显示版本信息，表示安装成功
复制代码
安装rabbitmq
#下载abbitmq_server-3.8.16并移动到/usr/local/
vim/etc/配置文件
＃添加
导出PATH=$PATH:/usr/local/rabbitmq_server-3.8.16/sbin
资源/etc/profile
cd/usr/local/rabbitmq_server-3.8.16/sbin
#开始
./rabbitmq-server启动
复制代码
函数的实现
RabbitMQ有两种实现延迟消息的方式，一种是使用死叶队列，另一种是使用延迟插件。
网上有很多死信队列的实现。本文介绍使用延迟插件（mac环境，java版本）的更简单实现。
其他安装方式（推荐使用这一种）
首先准备好需要用到的安装文件和插件（rabbitmq_delayed_message_exchange）。
版本必须匹配。不一致的版本可能无法安装或可能导致兼容性问题。
我用的是erl_25.0和rabbitMQ-3.10.0（可以去官网下载或者私信作者）。使用这种安装方式的好处是本地安装和服务器安装过程完全一样，但是服务器需要根据情况开启安全端口5672和15672，一般建议测试环境开启，关闭生产环境。
安装erl和rabbitMQ，具体步骤省略（这个应该不行，逃~）。
将插件文件复制到RabbitMQ安装目录的plugins目录下，执行如下命令重启rabbitMQ：
Králikmq-plugins启用králikmq_delayed_message_exchange
复制代码
实施延迟消息
以一个真实的业务场景为例：当客服状态为在线，且客户留言3分钟内未得到回复时，即时聊天机器人会自动重启接管会话。这是使用延迟消息的常见场景。
首先在pom.xml文件中添加AMQP相关依赖
♬org.springframework.boot
spring-boot-starter-amqp
复制代码在application.yml文件中添加RabbitMQ相关配置
春天：
兔子：
host:localhost#Rabbitmq连接地址
port:5672#Rabbitmq连接端口号
virtual-host:/mall#rabbitmq的虚拟主机
用户名：im#用户名rabbitmq
密码：xxxxxx#密码rabbitmq
publisher-confirms:true#如果需要异步消息的回调，必须设置为true
复制代码
接下来创建RabbitMQjava配置，主要用于配置交换机、队列、绑定
*消息队列的配置
@配置
公共类RabbitMqConfig{
*Bot管理重启插件消息队列绑定的开关
@豆
CustomExchangechatPluginDirect(){
//创建一个可以发送延迟消息的自定义开关
Mapargs=newHashMap<>();
参数。
put("x-delayed-type","direct");
returnnewCustomExchange(QueueEnum.QUEUE_RESET_MESSAGE_CANCEL.getExchange(),"x-delayed-message",true,false,args);
*机器人管理重启插件队列
@豆
公共队列chatPluginQueue(){
返回新队列（QueueEnum.QUEUE_RESET_MESSAGE_CANCEL.getName（））;
*绑定bot重启插件队列替换*/
@豆
publicBindingchatPluginBinding(CustomExchangechatPluginDirect,QueuechatPluginQueue){
返回绑定生成器
.bind（聊天插件队列）
.
