首页 > 代码库 > RabbitMQ Exchange中的fanout类型
RabbitMQ Exchange中的fanout类型
fanout 多播
在之前都是使用direct直连类型的交换机，通过routingkey来决定把消息推到哪个queue中。
而fanout则是把拿到消息推到与之绑定的所有queue中。
分析业务，怎样的场景需要它呢？某个用户注册了网站的用户，一般我们需要发送短信和邮件通知，莫非要在同一个consumer中把这两件事都做了？这不符合单一职责，可是发送的消息是一样的，只是方式不一样。要使用两种routingkey都发送一次？这显然也不是我们想要的。所以fanout出现了
fanout类型的exchange会把消息推到所有的queue中，所以不需要指定routingkey，指定了也没用！
下面通过代码来看
这里有两种需求，发短信与发邮件
//创建返回一个新的频道 using (var channel = RabbitMqHelper.GetConnection().CreateModel()){ //发布一个消息 var msg = Encoding.UTF8.GetBytes($"二狗子"); //不需要指定routingkey,指定了也没用.因为交换机是fanout类型 channel.BasicPublish("fanoutExchange", routingKey: string.Empty, basicProperties: null, body: msg); Console.Write("发布成功！");} Console.ReadKey();
这里是consumer部分的代码
bool flag = true; string pattern = ""; while (flag) { Console.WriteLine("请选择Ccnsumer模式 1(发短信)/2(发邮件)"); pattern = Console.ReadLine(); if (pattern == "1" || pattern == "2") flag = false; else Console.Write("请做出正确的选择"); } using (var channel = RabbitMqHelper.GetConnection().CreateModel()) { //声明交换机 Fanout模式 channel.ExchangeDeclare("fanoutExchange", ExchangeType.Fanout, true, false, null); //根据声明使用的队列 var queueName = pattern == "1" ? "sms" : "emai"; channel.QueueDeclare(queueName, true, false, false, null); //进行绑定 channel.QueueBind(queueName, "fanoutExchange", string.Empty, null); //创建consumbers var consumer = new EventingBasicConsumer(channel); consumer.Received += (sender, e) => { var msg = Encoding.UTF8.GetString(e.Body); var action = (pattern == "1" ? "发短信" : "发邮件"); Console.WriteLine($"给{msg}{action}"); }; //进行消费 channel.BasicConsume(queueName, true, consumer); Console.ReadKey(); }
下面把程序运行起来,不同的consumer进行了不同的消费
RabbitMQ Exchange中的fanout类型
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。