码迷,mamicode.com
首页 > 其他好文 > 详细

RabbitMQ Exchange中的fanout类型

时间:2017-09-21 13:36:57      阅读:239      评论:0      收藏:0      [点我收藏+]

标签:成功   bsp   发送   coding   publish   ima   com   order   alt   

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类型

标签:成功   bsp   发送   coding   publish   ima   com   order   alt   

原文地址:http://www.cnblogs.com/zxtceq/p/7567365.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!