消息队列

##  消息队列

- 消息队列：

-- 就是一种订阅发布模式的实现

- 主要的角色

1. 消息的生产者

2. 消息的消费者

3. 消息队列

- 作用：

 1. 异步调用，延迟处理

 2. 应用解耦

 3. 处理高并发

 - 常用的消息队列：

 msmq:微软自带的，不开源，使用的人不多

rabbitmq:开源的，使用较多，支持多语言，社区支持强

rocketmq:阿里巴巴的消息队列，数据万级，开源，商业收版，除了java语言支持

- 具体实操：

1. 创建#控制台应用

2. 工具中的Nuget包管理器中打开程序包管理控制台：输入

Install-Package RabbitMQ.Client -Version 3.6.5

- 先使用生产者创建消息

AMQP：高级消息队列协议

rabbitmq是基于AMQ的

- 创建交换机

chaneel.ExchangeDeclare("交换机名字","交换机类型");

- 创建消息队列

chaneel.QueueDeclare("队列的名字","是否持久性","排外","是否自动删除","参数");

- 把交换机和队列进行关联

关联时需要一个指定的key值

chaneel.QueueBind("队列名字","交换机的名字","路由key");

(路由key值需要自己定义)

- 具体实践源代码

- 获取消息