亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

C#用RabbitMQ實現消息訂閱與發(fā)布

 更新時間:2021年05月17日 09:04:55   作者:Alan.hsiang  
在消息隊列模型中,如何將消息廣播到所有的消費者,這種模式成為“發(fā)布/訂閱”。本文主要以一個簡單的小例子,簡述通過fanout交換機,實現消息的發(fā)布與訂閱,僅供學習分享使用,如有不足之處,還請指正。

Fanout交換機模型

扇形交換機,采用廣播模式,根據綁定的交換機,路由到與之對應的所有隊列。一個發(fā)送到交換機的消息都會被轉發(fā)到與該交換機綁定的所有隊列上。很像子網廣播,每臺子網內的主機都獲得了一份復制的消息。Fanout交換機轉發(fā)消息是最快的。

RabbitMQ控制臺操作

新增兩個隊列

在同一個Virtual host下新增兩個隊列Q1,Q2,如下圖所示:

綁定fanout交換機

將兩個隊列綁定到系統(tǒng)默認的fanout交換機,如下所示:

示例效果圖

生產者,采用Fanout類型交換機發(fā)布消息,如下圖所示:

 當生產者發(fā)布 一條消息時,Q1,Q2兩個隊列均會收到,如下圖所示:

當啟動消費者后,兩個消費者,均會訂閱到相關消息,如下圖所示:

核心代碼

消息發(fā)布

建立連接后,將通道聲明類型為Fanout的交換機,如下所示:

/// <summary>
    /// fanout類型交換機,發(fā)送消息
    /// </summary>
    public class RabbitMqFanoutSendHelper : RabbitMqHelper {
        /// <summary>
        /// 發(fā)送消息
        /// </summary>
        /// <param name="msg"></param>
        /// <returns></returns>
        public bool SendMsg(string msg)
        {
            try
            {
                using (var conn = GetConnection("/Alan.hsiang"))
                {
                    using (var channel = conn.CreateModel())
                    {
                        channel.ExchangeDeclare(exchange: "amq.fanout", type: ExchangeType.Fanout,durable:true);

                        var body = Encoding.UTF8.GetBytes(msg);

                        channel.BasicPublish(exchange: "amq.fanout",
                                             routingKey: "",
                                             basicProperties: null,
                                             body: body);

                        //Console.WriteLine(" [x] Sent {0}", message);
                    };
                };
                return true;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }

消息訂閱

建立連接后,通道聲明類型為Fanout的交換機,并綁定隊列進行訂閱,如下所示:

/// <summary>
    /// 扇形交換機接收消息
    /// </summary>
    public class RabbitMqFanoutReceiveHelper : RabbitMqHelper
    {
        public RabbitMqReceiveEventHandler OnReceiveEvent;

        private IConnection conn;

        private IModel channel;

        private EventingBasicConsumer consumer;

        public bool StartReceiveMsg(string queueName)
        {
            try
            {
                conn = GetConnection("/Alan.hsiang");

                channel = conn.CreateModel();
                channel.ExchangeDeclare(exchange: "amq.fanout", type: ExchangeType.Fanout,durable:true);
                //此處隨機取出交換機下的隊列
                //var queueName = channel.QueueDeclare().QueueName;
                channel.QueueBind(queue: queueName, exchange: "amq.fanout", routingKey: "");
                consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body.ToArray();
                    var message = Encoding.UTF8.GetString(body);
                    //Console.WriteLine(" [x] Received {0}", message);
                    if (OnReceiveEvent != null)
                    {
                        OnReceiveEvent(queueName+"::"+message);
                    }
                };
                channel.BasicConsume(queue: queueName,
                                        autoAck: true,
                                        consumer: consumer);
                return true;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }

作者:Alan.hsiang
出處:http://www.cnblogs.com/hsiang/

以上就是C#用RabbitMQ實現消息訂閱與發(fā)布的詳細內容,更多關于C#用RabbitMQ實現消息訂閱與發(fā)布的資料請關注腳本之家其它相關文章!

相關文章

  • C#實現的文件壓縮和解壓縮類

    C#實現的文件壓縮和解壓縮類

    這篇文章主要介紹了C#實現的文件壓縮和解壓縮類,實例分析了C#針對文件壓縮與解壓縮的常用技巧,非常具有實用價值,需要的朋友可以參考下
    2015-03-03
  • Unity?UGUI的Text文本組件使用示例

    Unity?UGUI的Text文本組件使用示例

    這篇文章主要為大家介紹了Unity?UGUI的Text文本組件使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-07-07
  • C#實現Json文件讀寫的方法代碼

    C#實現Json文件讀寫的方法代碼

    這篇文章主要給大家介紹了關于C#實現Json文件讀寫的相關資料,C# 讀取JSON文件并讀取某一個關鍵字的值可以使用Newtonsoft.Json庫,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2023-11-11
  • C#使用XSLT實現xsl、xml與html相互轉換

    C#使用XSLT實現xsl、xml與html相互轉換

    這篇文章介紹了C#使用XSLT實現xsl、xml與html相互轉換的方法,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-06-06
  • C#實現變量交換、斐波那契數列、質數、回文方法合集

    C#實現變量交換、斐波那契數列、質數、回文方法合集

    這篇文章介紹了C#實現變量交換、斐波那契數列、質數、回文的方法合集,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-02-02
  • Unity?UGUI的Canvas畫布組件使用示例詳解

    Unity?UGUI的Canvas畫布組件使用示例詳解

    這篇文章主要介紹了Unity?UGUI的Canvas畫布組件使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-07-07
  • C#常用目錄文件操作類實例

    C#常用目錄文件操作類實例

    這篇文章主要介紹了C#常用目錄文件操作類,實例分析了C#針對目錄的讀取、檢測及查找等相關操作技巧,非常具有實用價值,需要的朋友可以參考下
    2015-03-03
  • WinForm之BindingSource基礎操作實例教程

    WinForm之BindingSource基礎操作實例教程

    這篇文章主要介紹了WinForm之BindingSource基礎操作,對BindingSource組建的用法進行較為深入的實例分析,需要的朋友可以參考下
    2014-08-08
  • C#無損轉換Image為Icon的方法

    C#無損轉換Image為Icon的方法

    這篇文章主要為大家詳細介紹了C#無損轉換Image為Icon的方法,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-04-04
  • C#多線程系列之任務基礎(一)

    C#多線程系列之任務基礎(一)

    本文詳細講解了C#多線程的任務基礎,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-02-02

最新評論