c# RabbitMQ 發送消息

參考地址：《C#使用RabbitMQ》

C#操作RabbitMQ需要引用RabbitMQ的DLL，地址是：http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/

下載最新版本即可，因為我使用的.Net Framework 4.5，所以選擇

下載后解壓

 

創建工程后，先引用RabbitMQ的庫RabbitMQ.Client.dll，即第一個dll文件

 

這里我使用了一個新通用Class，首先需要引用RabbitMQ的命令空間 using RabbitMQ.Client;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using RabbitMQ.Client;

namespace MES_MonitoringClient.Common
{
    /// <summary>
    /// RabbitMQ隊列上傳動作
    /// </summary>
    public class RabbitMQClientHandler
    {
        // 定義一個靜態變量來保存類的實例
        private static RabbitMQClientHandler uniqueInstance;
        //定義一個標識確保線程同步 
        private static readonly object locker = new object();


        /*-------------------------------------------------------------------------------------*/

        //ConnectionFactory
        private static ConnectionFactory mc_ConnectionFactory = null;
        //Connection
        public IConnection Connection;
        //Channel
        public IModel Channel;


        /*-------------------------------------------------------------------------------------*/

        /// <summary>
        /// 定義私有構造函數，使外界不能創建該類實例
        /// </summary>
        public RabbitMQClientHandler()
        {
            //連接工廠
            mc_ConnectionFactory = new ConnectionFactory();

            //連接工廠信息
            mc_ConnectionFactory.HostName = "localhost";
            mc_ConnectionFactory.UserName = "guest";
            mc_ConnectionFactory.Password = "guest";

            //創建連接
            Connection = mc_ConnectionFactory.CreateConnection();
            //創建頻道
            Channel = Connection.CreateModel();
        }

        /// <summary>
        /// 定義公有方法提供一個全局訪問點,同時你也可以定義公有屬性來提供全局訪問點
        /// </summary>
        /// <returns></returns>
        public static RabbitMQClientHandler GetInstance()
        {
            // 當第一個線程運行到這里時，此時會對locker對象 "加鎖"，
            // 當第二個線程運行該方法時，首先檢測到locker對象為"加鎖"狀態，該線程就會掛起等待第一個線程解鎖
            // lock語句運行完之后（即線程運行完之后）會對該對象"解鎖"
            // 雙重鎖定只需要一句判斷就可以了
            if (uniqueInstance == null)
            {
                lock (locker)
                {
                    // 如果類的實例不存在則創建，否則直接返回
                    if (uniqueInstance == null)
                    {
                        uniqueInstance = new RabbitMQClientHandler();
                    }
                }
            }
            return uniqueInstance;
        }


        /*-------------------------------------------------------------------------------------*/

        /// <summary>
        /// 發送消息至服務端
        /// </summary>
        /// <param name="queueName"></param>
        /// <param name="message"></param>
        /// <returns></returns>
        public bool publishMessageToServer(string queueName, string message)
        {
            try
            {
                //創建一個持久化的頻道
                bool durable = true;
                Channel.QueueDeclare(queueName, durable, false, false, null);

                //設置消息持久性
                //var properties = Channel.CreateBasicProperties();
                //properties.SetPersistent(true);

                //消息內容轉碼，並發送至服務器
                var messageBody = Encoding.UTF8.GetBytes(message);
                Channel.BasicPublish("", "test", null, messageBody);

                return true;
            }
            catch (Exception ex)
            {
                return false;
            }
        }

    }
}

 

然后在調用時，只需要使用

Common.RabbitMQClientHandler.GetInstance().publishMessageToServer("test", "test message");

 

這里需要比較的地方是，在測試過程中發現

• 1.同一個服務器中，不能有兩個一樣名字的Queue
• 2.針對同一個Queue，發送端與接收端的Channel.QueueDeclare時指定的durable（bool類型）指定的不同，也不能順利接收到
• 3.還有在發送時，Channel.BasicPublish("", "test", null, messageBody);  其中的routing參數也需要與Queue保持一致（后期可以通過設置Exchange和Routing對Queue進行分配）

 

---

 

2019-01-04 發現一個問題：問題表現為，RabbitMQ發送服務為后台服務，在開發環境中，RabbitMQ服務器有可能會隨時中斷，那么后台服務一直在運行，建立的連接則只存在於過去，RabbitMQ重新啟動后，之前創建的連接已經不存了，導致后台服務即使能讀到Mongodb中的數據，但是無法通過之前建立的連接將數據發送至RabbitMQ服務器，這時，只需要將后台服務重新啟動，重新創建新的連接即可正常服務，在代碼中需要增加一些判斷，如果發送RabbitMQ不能成功，則需要重新建立RabbitMQ連接，方便發送數據。