首页
视频
资源
登录
原
.netcore3.1 RabbitMq Fanout交换机
3790
人阅读
2021/1/25 14:07
总访问:
2594331
评论:
0
收藏:
0
手机
分类:
RabbitMq
![](https://img.tnblog.net/arcimg/hb/585b0f1ffa7f4c2095baa20c175b32a0.png) >#.netcore3.1 RabbitMq Fanout交换机 [TOC] tn>在前面我们有提到交换机但都是用的普通的交换机(`direct`),交换机在`Rabbitmq`中有`4`种可用类型:`direct`,`topic`,`headers` 和`fanout`。而今天我要讲的是最后一个`fanout`交换机,它的作用可以用下面的一张图来说明。 ![](https://img.tnblog.net/arcimg/hb/653022dffd264288990130bac911f31f.png) tn>如果你们公司要发新年的祝福语,一般会通过手机发短信给你发一条,然后邮件给你发一条,系统里面也可能会给你发一条。所以这就是`fanout`交换机的好处,都是同一条消息不同的队列处理相同的消息。 创建相关队列(手机与邮箱) ------------ >### 代码 ```csharp var factory = new ConnectionFactory() { HostName = "47.98.187.188", UserName = "bob", Password = "bob" }; // 创建一个链接 using (var connection = factory.CreateConnection()) { // 创建一个通道 using (var channel = connection.CreateModel()) { // 创建交换机 普通类型 channel.ExchangeDeclare("MyFanoutExchangeName", ExchangeType.Fanout,true,false); // 声明一个队列 channel.QueueDeclare( queue: "MyFanoutPhone", durable: true, exclusive: false, autoDelete: false, arguments: null); // 声明一个队列 channel.QueueDeclare( queue: "MyFanoutEmail", durable: true, exclusive: false, autoDelete: false, arguments: null); // 将队列与交换机绑定在一起 channel.QueueBind("MyFanoutPhone", "MyFanoutExchangeName", string.Empty, null); channel.QueueBind("MyFanoutEmail", "MyFanoutExchangeName", string.Empty, null); Console.WriteLine("Finish"); Console.ReadLine(); } } ``` >### 运行图片 ![](https://img.tnblog.net/arcimg/hb/4cd9374eb82a4f9985f52cd9e160ea56.png) ![](https://img.tnblog.net/arcimg/hb/62fedabc083b4dcc97b4e772bf7f9888.png) ![](https://img.tnblog.net/arcimg/hb/2fa73f514bbe4f55b32909a36ef23990.png) ![](https://img.tnblog.net/arcimg/hb/81e804e40b2e49ef8ad9fe06e9f75f5e.png) 创建2种消费端(手机和邮箱) ------------ >### 创建消费端 ```csharp var factory = new ConnectionFactory() { HostName = "47.98.187.188", UserName = "bob", Password = "bob", VirtualHost = "/" }; // 获取要取消息的队列的名称 var QueueName = args[0]; Console.WriteLine($"Queue Name: {QueueName}"); // 创建一个链接 using (var connection = factory.CreateConnection()) { // 创建一个通道 using (var channel = connection.CreateModel()) { // one by one 处理 channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false); // 创建消费实例 var consumer = new EventingBasicConsumer(channel); // 事件在交付到使用者时触发。(消费处理事件) consumer.Received += (model, ea) => { try { string _QueueName = QueueName; var body = ea.Body.ToArray(); var message = Encoding.UTF8.GetString(body); Thread.Sleep(1000); if (QueueName == "MyFanoutPhone") { Console.BackgroundColor = ConsoleColor.Blue; //设置背景色 Console.ForegroundColor = ConsoleColor.White; //设置前景色,即字体颜色 Console.WriteLine("From MyFanoutPhone Message: {0}", message); // 否定确认,减少网络请求,提高性能 channel.BasicAck(ea.DeliveryTag,multiple: true); } else { Console.BackgroundColor = ConsoleColor.Green; Console.ForegroundColor = ConsoleColor.DarkGreen; Console.WriteLine("From MyFanoutEmail Message: {0}", message); // 重新排队,减少网络请求,提高性能 channel.BasicAck(ea.DeliveryTag, multiple: true); } } catch (Exception ex) { Console.WriteLine("【Error】:", ex.Message); channel.BasicNack(ea.DeliveryTag, multiple: true, requeue: true); } }; // 绑定到队列中去 channel.BasicConsume(queue: QueueName, autoAck: false, consumer: consumer); Console.ReadLine(); } } ``` >### 运行消费端 tn>我们这里通过输入不同的参数去不同的队列中处理相同的消息。(开启两个窗体分别处理手机与邮箱) ```csharp ./Worker.exe MyFanoutPhone ./Worker.exe MyFanoutEmail ``` >### 添加消息 tn>在创建队列的时候添加相关消息。 ```csharp var factory = new ConnectionFactory() { HostName = "47.98.187.188", UserName = "bob", Password = "bob" }; // 创建一个链接 using (var connection = factory.CreateConnection()) { // 创建一个通道 using (var channel = connection.CreateModel()) { // 创建交换机 普通类型 channel.ExchangeDeclare("MyFanoutExchangeName", ExchangeType.Fanout,true,false); // 声明一个队列 channel.QueueDeclare( queue: "MyFanoutPhone", durable: true, exclusive: false, autoDelete: false, arguments: null); // 声明一个队列 channel.QueueDeclare( queue: "MyFanoutEmail", durable: true, exclusive: false, autoDelete: false, arguments: null); // 将队列与交换机绑定在一起 channel.QueueBind("MyFanoutPhone", "MyFanoutExchangeName", string.Empty, null); channel.QueueBind("MyFanoutEmail", "MyFanoutExchangeName", string.Empty, null); var properties = channel.CreateBasicProperties(); properties.Persistent = true; channel.BasicPublish( exchange: "MyFanoutExchangeName", routingKey: string.Empty, basicProperties: properties, body: Encoding.UTF8.GetBytes("Happy New Year") ); Console.WriteLine("Finish"); Console.ReadLine(); } } ``` >### 运行发布端 ![](https://img.tnblog.net/arcimg/hb/e262253602d24151ac28d46211406ab7.png) ![](https://img.tnblog.net/arcimg/hb/1a42d93cf8e34f07a69fd276b332174a.png)
欢迎加群讨论技术,1群:677373950(满了,可以加,但通过不了),2群:656732739
👈{{preArticle.title}}
👉{{nextArticle.title}}
评价
{{titleitem}}
{{titleitem}}
{{item.content}}
{{titleitem}}
{{titleitem}}
{{item.content}}
尘叶心繁
这一世以无限游戏为使命!
博主信息
排名
6
文章
6
粉丝
16
评论
8
文章类别
.net后台框架
168篇
linux
17篇
linux中cve
1篇
windows中cve
0篇
资源分享
10篇
Win32
3篇
前端
28篇
传说中的c
4篇
Xamarin
9篇
docker
15篇
容器编排
101篇
grpc
4篇
Go
15篇
yaml模板
1篇
理论
2篇
更多
Sqlserver
4篇
云产品
39篇
git
3篇
Unity
1篇
考证
2篇
RabbitMq
23篇
Harbor
1篇
Ansible
8篇
Jenkins
17篇
Vue
1篇
Ids4
18篇
istio
1篇
架构
2篇
网络
7篇
windbg
4篇
AI
18篇
threejs
2篇
人物
1篇
嵌入式
2篇
python
13篇
HuggingFace
8篇
pytorch
9篇
opencv
6篇
最新文章
最新评价
{{item.articleTitle}}
{{item.blogName}}
:
{{item.content}}
关于我们
ICP备案 :
渝ICP备18016597号-1
网站信息:
2018-2024
TNBLOG.NET
技术交流:
群号656732739
联系我们:
contact@tnblog.net
欢迎加群
欢迎加群交流技术