1. 为什么要用消息队列
- 消息队列是啥&＃xff1a;消息队列&＃xff08;Message Queue&＃xff09;&＃xff0c;一种先进先出的队列结构&＃xff0c;用于处理Message。
- 消息队列解决的问题&＃xff1a;在处理大量并发请求时&＃xff0c;同步处理往往会发生阻塞&＃xff0c;特别是在更新数据库或者调用其他组件时。消息队列能够实现请求的异步处理、应用解耦、流量削锋和消息通讯&＃xff0c;同时能够有效防止阻塞导致的消息丢失。
- 消息队列系统&＃xff0c;一般都包含3个角色&＃xff1a;队列服务端&＃xff0c;队列的生产者&＃xff0c;队列的消费者。这种架构与当下流行的分布式架构极为契合。
2. RabbitMQ是啥
- RabbitMQ是使用Erlang编写的一个开源的消息队列&＃xff0c;本身支持很多的协议&＃xff1a;AMQP&＃xff0c;XMPP, SMTP, STOMP&＃xff0c;也正因如此&＃xff0c;它非常重量级&＃xff0c;更适合于企业级的开发。同时实现了Broker构架&＃xff0c;这意味着消息在发送给客户端时先在中心队列排队。对路由&＃xff0c;负载均衡或者数据持久化都有很好的支持。
- 它支持开放的高级消息队列协议 (AMQP&＃xff0c;Advanced Message Queuing Protocol)&＃xff0c;从根本上避免了生产厂商的封闭&＃xff0c;使用任何语言的各种客户都可以从中受益。这种协议提供了相当复杂的消息传输模式&＃xff0c;所以基本上不需要MassTransit或NServiceBus的配合。它还具有“企业级”的适应性和稳定性。这些东西对我的客户来说十分的有吸引力。
RabbitMQ的整体架构3. 如何安装RabbitMQ
- 安装RabbitMQ(下载地址&＃xff1a;https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.7.26)&＃xff08;安装之前先安装 Erlang&＃xff09;
将sbin添加到环境目录中的Path中在Powershell中执行&＃xff1a;rabbitmq-plugins list安装RabbitMQ可视化管理端&＃xff1a;rabbitmq-plugins enable rabbitmq_management默认的账户密码都是guest
登录之后的页面修改或者删除该用户&＃xff08;建议先修改密码&＃xff0c;然后添加用户&＃xff0c;添加之后再删除guest用户&＃xff0c;或者直接改一个密码吗保留guest用户&＃xff09;添加一个Admin用户&＃xff0c;名称随便&＃xff0c;密码随便&＃xff0c;角色选择Admin添加完之后刷新Users列表会看到该用户&＃xff0c;接下来配置hosts新建一个testhost&＃xff0c;然后点击testhost&＃xff0c;进入host配置页面&＃xff0c;在Permissions选项中添加admin 的访问权限回到Users页面可以看到如上的列表&＃xff0c;至此RabbitMQ配置完成TIPS&＃xff1a;上述操作也可以通过命令行来完成
查看所有用户
添加一个用户
rabbitmqctl add_user admin 123456
配置权限
rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"
查看用户权限
rabbitmqctl list_user_permissions admin
设置tag
rabbitmqctl set_user_tags admin administrator
删除用户&＃xff08;安全起见&＃xff0c;删除默认用户&＃xff09;
rabbitmqctl delete_user guest
4. 先了解一下RabbitMQ的队列形式
在使用RabbitMQ之前&＃xff0c;咱们先捋一捋RabbitMQ一共有几种使用方式&＃xff0c;常用的5中队列
- 第一种&＃xff1a;简单队列&＃xff08;一对一模式&＃xff09;耦合性高&＃xff0c;生产消费一一对应。
- 第二种&＃xff1a;WorkQueues&＃xff08;工作队列&＃xff09;&＃xff0c;一个生产&＃xff0c;多个消费者共同处理消息。
- 第三种&＃xff1a;订阅模式&＃xff0c;1一个生产者多个消费者&＃xff0c;每一个消费者有自己的一个队列&＃xff0c;生产者直接将消息发送给交换机&＃xff0c;交换机将消息发送给队列&＃xff0c;每一个队列都需要绑定到交换机。这种模式可以满足消费者发布一个消息&＃xff0c;多个消费者消费同一信息的需求&＃xff0c;但C1、C2消费的都是相同的数据&＃xff0c;有时我们需要C1和C2消费的信息只有部分差异&＃xff0c;比如我们需求&＃xff1a;C1消费增加的数据&＃xff0c;C2消费编辑、增加和删除的数据。
- 第四种&＃xff1a;路由模式&＃xff0c;路由模式是在订阅模式基础上的完善&＃xff0c;可以在生产消息的时候&＃xff0c;加入Key值&＃xff0c;与key值匹配的消费者消费信息。但路由模式中&＃xff0c;就如三中提到的C1、C2、如果C2对应的类型更多&＃xff0c;就需要写很多key值。但其实它只与C1有一点差别。
- 第五种&＃xff1a;通配符模式是在路由模式的升级&＃xff0c;他允许key模糊匹配。*代表一个词&＃xff0c;#代表一个或多个词。通过通配符模式我们就可以将C1对应的一个key准确定为item.add。而C2我们就不需要一一写出key值&＃xff0c;而是用item.#代替即可。
5. .net Core3.1如何优雅的使用RabbitMQ
新建控制台应用程序&＃xff0c;引入RabbitMQ.Client包创建生产者
using RabbitMQ.Client;
using System;
using System.Text;namespace RabbitMQTest
{/// /// 生产者/// class Program{static void Main(string[] args){//创建连接工厂ConnectionFactory factory &＃61; new ConnectionFactory{UserName &＃61; "admin",//用户名Password &＃61; "lmt456123",//密码HostName &＃61; "localhost"//rabbitmq ip};//创建连接var connection &＃61; factory.CreateConnection();//创建通道var channel &＃61; connection.CreateModel();//声明一个队列channel.QueueDeclare("hello", false, false, false, null);Console.WriteLine("nRabbitMQ连接成功&＃xff0c;请输入消息&＃xff0c;输入exit退出&＃xff01;");string input;do{input &＃61; Console.ReadLine();var sendBytes &＃61; Encoding.UTF8.GetBytes(input);//发布消息channel.BasicPublish("", "hello", null, sendBytes);}while (input.Trim().ToLower() !&＃61; "exit");channel.Close();connection.Close();}}
}
创建一对一消费者
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;namespace RabbitMQConsumer
{/// /// 消费者/// class Program{static void Main(string[] args){//创建连接工厂ConnectionFactory factory &＃61; new ConnectionFactory{UserName &＃61; "admin",//用户名Password &＃61; "lmt456123",//密码HostName &＃61; "localhost"//rabbitmq ip};//创建连接var connection &＃61; factory.CreateConnection();//创建通道var channel &＃61; connection.CreateModel();//事件基本消费者EventingBasicConsumer consumer &＃61; new EventingBasicConsumer(channel);//接收到消息事件consumer.Received &＃43;&＃61; (ch, ea) &＃61;>{string message &＃61; Encoding.Default.GetString(ea.Body.ToArray());Console.WriteLine($"收到消息&＃xff1a; {message}");// Console.WriteLine($"收到该消息[{ea.DeliveryTag}] 延迟10s发送回执");// Thread.Sleep(10000);//确认该消息已被消费channel.BasicAck(ea.DeliveryTag, false);// Console.WriteLine($"已发送回执[{ea.DeliveryTag}]");};//启动消费者 设置为手动应答消息channel.BasicConsume("hello", false, consumer);Console.WriteLine("消费者已启动");Console.ReadKey();channel.Dispose();connection.Close();}}
}
启动程序并测试
一对一的消费队列咱们就此创建完成&＃xff0c;下一节开始RabbitMQ的高级用法
京公网安备 11010802041100号