使用 .NET client 連線至 RabbitMQ 收發訊息

繼之前使用 RabbitMQ.Client 連線至 RabbitMQ 出現 BrokerUnreachableException 問題解決後，終於又可以繼續測試 RabbitMQ 了，要比較的不僅僅是 mq 的能力，也要比較使用上的便利性及周邊管理功能或是其他套件的完整度，今天就先紀錄一下 RabbitMQ 的基本操作：收發訊息

安裝 RabbitMQ.Client

RabbitMQ 官方的介紹 .NET/C# RabbitMQ client library，說明很完整

1PLUGIN

接收訊息

如果有多個 consumer (接受端)，記得要先啟動 consumer，否則訊息將都會由第一啟動的 consumer 獨佔如果啟動接收訊息時出現錯誤，請先參考使用 RabbitMQ.Client 連線至 RabbitMQ 出現 BrokerUnreachableException

程式碼

void Main()
{
    //初始化連線資訊
    var factory = new ConnectionFactory();
    //設定 RabbitMQ 位置
    factory.HostName = "localhost";
    //設定 RabbitMQ port
    factory.Port = 5672;
    //設定連線 RabbitMQ username
    factory.UserName = "yowko";
    //設定 RabbitMQ password
    factory.Password = "pass.123";
    
    
    //開啟連線
    using (var connection = factory.CreateConnection())
    //開啟 channel
    using (var channel = connection.CreateModel())
    {
        //宣告 queues
        channel.QueueDeclare("yowkoTest", false, false, false, null);
        //建立 consumer
        var consumer = new QueueingBasicConsumer(channel);
        channel.BasicConsume("yowkoTest", true, consumer);
    
        Console.WriteLine(" waiting for message.");
        //持續等著接收訊息
        while (true)
        {
            //從 RabbitMQ 取得訊息
            var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
    
            var body = ea.Body;
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine("Received {0}", message);
            Thread.Sleep(5000);
        }
    }
}

發送訊息

如果啟動發送訊息時出現錯誤，請先參考使用 RabbitMQ.Client 連線至 RabbitMQ 出現 BrokerUnreachableException

程式碼

void Main()
{
    //初始化連線資訊
    var factory = new ConnectionFactory();
    //設定 RabbitMQ 位置
    factory.HostName = "localhost";
    //設定 RabbitMQ port
    factory.Port = 5672;
    //設定連線 RabbitMQ username
    factory.UserName = "yowko";
    //設定 RabbitMQ password
    factory.Password = "pass.123";


    //開啟連線
    using (var connection = factory.CreateConnection())
    //開啟 channel
    using (var channel = connection.CreateModel())
    {
        //宣告 exchanges，RabbitMQ提供了四種Exchange模式：fanout,direct,topic,header
        channel.ExchangeDeclare("yowko", ExchangeType.Fanout);
        //宣告 queues
        channel.QueueDeclare("yowkoTest", false, false, false, null);
        //將 exchnage、queue 依 route rule 綁定
        channel.QueueBind("yowkoTest", "yowko", "hello", null);
        //  channel.QueueDeclare("hello", false, false, false, null);
        string message = $"Hello World-{Guid.NewGuid()}";
        var body = Encoding.UTF8.GetBytes(message);
        channel.BasicPublish("yowko", "hello", null, body);
        Console.WriteLine(" set {0}", message);
    }
}

心得

使用上還算便利，但很多參數還不知道如何使用，有較深入研究使用會再另外紀錄介紹，敬請期待

文章目錄

使用 .NET client 連線至 RabbitMQ 收發訊息

安裝 RabbitMQ.Client

接收訊息

發送訊息

心得

參考資訊