是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间共享数据，RabbitMQ是使用Erlang(高并发语言)语言来编写的，并且RabbitMQ是基于AMQP协议的。
(1) AMQP协议Advanced Message Queuing Protocol(高级消息队列协议)
(2)AMQP专业术语（多路复用->在同一个线程中开启多个通道进行操作）
Server：又称broker，接受客户端的链接，实现AMQP实体服务
Connection:连接，应用程序与broker的网络连接
Channel:网络信道，几乎所有的操作都在channel中进行，Channel是进行消息读写的通道。客户端可以建立多个channel，每个channel代表一个会话任务。
Message:消息，服务器与应用程序之间传送的数据，由Properties和Body组成.Properties可以对消息进行修饰，必须消息的优先级、延迟等高级特性；Body则是消息体内容。
virtualhost: 虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个virtual host里面可以有若干个Exchange和Queue，同一个Virtual Host 里面不能有相同名称的Exchange 或 Queue。
Exchange：交换机，接收消息，根据路由键转单消息到绑定队列
Binding: Exchange和Queue之间的虚拟链接，binding中可以包换routing key
Routing key: 一个路由规则，虚拟机可用它来确定如何路由一个特定消息。（如负载均衡）
(3)RabbitMQ整体架构
ClientA(生产者)发送消息到Exchange1(交换机)，同时带上RouteKey(路由Key)，Exchange1找到绑定交换机为它和绑定传入的RouteKey的队列，把消息转发到对应的队列，消费者Client1，Client2,Client3只需要指定对应的队列名即可以消费队列数据。
交换机和队列多对多关系，实际开发中一般是一个交换机对多个队列，防止设计复杂化。
二、安装RabbitMQ安装方式不影响下面的使用，这里用Docker安装
#15672端口为web管理端的端口，5672为RabbitMQ服务的端口
docker run -d --name rabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 -p 15672:15672 -p 5672:5672 rabbitmq:3-management
输入：ip:5672访问验证。
建一个名为develop的Virtual host(虚拟主机)使用，项目中一般是一个项目建一个Virtual host用，能够隔离队列。
切换Virtual host
最简单的工作队列，其中一个消息生产者，一个消息消费者，一个队列。也称为点对点模式
描述：一个生产者 P 发送消息到队列 Q，一个消费者 C 接收
建一个RabbitMQHelper.cs类
/// <summary> /// RabbitMQ帮助类 /// </summary> public class RabbitMQHelper { private static ConnectionFactory factory; private static object lockObj = new object(); /// <summary> /// 获取单个RabbitMQ连接 /// </summary> /// <returns></returns> public static IConnection GetConnection() { if (factory == null) { lock (lockObj) { if (factory == null) { factory = new ConnectionFactory { HostName = "172.16.2.84",//ip Port = 5672,//端口 UserName = "admin",//账号 Password = "123456",//密码 VirtualHost = "develop" //虚拟主机 }; } } } return factory.CreateConnection(); } }
生产者代码：
新建发送类Send.cs
public static void SimpleSendMsg() { string queueName = "simple_order";//队列名 //创建连接 using (var connection = RabbitMQHelper.GetConnection()) { //创建信道 using (var channel = connection.CreateModel()) {//创建队列 channel.QueueDeclare(queueName, durable: false, exclusive: false, autoDelete: false, arguments: null); for (var i = 0; i < 10; i++) { string message = $"Hello RabbitMQ MessageHello,{i + 1}"; var body = Encoding.UTF8.GetBytes(message);//发送消息 channel.BasicPublish(exchange: "", routingKey: queueName, mandatory: false, basicProperties: null, body); Console.WriteLine($"发送消息到队列:{queueName},内容:{message}"); } } } }
创建队列参数解析：
durable：是否持久化。
exclusive：排他队列，只有创建它的连接(connection)能连，创建它的连接关闭，会自动删除队列。
autoDelete：被消费后，消费者数量都断开时自动删除队列。
arguments：创建队列的参数。
发送消息参数解析：
exchange：交换机，为什么能传空呢，因为RabbitMQ内置有一个默认的交换机，如果传空时，就会用默认交换机。
routingKey：路由名称，这里用队列名称做路由key。
mandatory：true告诉服务器至少将消息route到一个队列种，否则就将消息return给发送者；false：没有找到路由则消息丢弃。
执行效果：
队列产生10条消息。
消费者代码：
新建Recevie.cs类