1.首先要安裝 RabbitMQ Client

2.創建一個控制臺項目 取名 Publisher代碼如下:

using RabbitMQ.Client;
using System;
using System.Text;

namespace Publisher
{
    class Program
    {
        static void Main(string[] args)
        {
            ConnectionFactory factory = new ConnectionFactory()
            {
                HostName 
 
= "127.0.0.1",
                UserName = "mytest",
                Password="mytest"
            };
            //第一步：創建connection
            var connection = factory.CreateConnection();
            //第二步：創建channel
            var channel = connection.CreateModel();
            //第三步：申明交換機

            //第四步：聲明一個隊列
 

            channel.QueueDeclare("manQueue", true, false, false, null);
            var msg = Encoding.UTF8.GetBytes("希望！");
            //第五步：發布消息
            channel.BasicPublish(string.Empty, routingKey: "manQueue", basicProperties: null, body: msg);

            Console.WriteLine("完成");
        }
    }
}
 

3.創建一個控制臺項目 取名 Consumer代碼如下:

using RabbitMQ.Client;
using System;
using System.Text;

namespace Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            ConnectionFactory factory = new ConnectionFactory()
            {
                HostName = "127.0.0.1",
                UserName = "mytest",
                Password = "mytest"
            };
            //第一步：創建connection
            var connection = factory.CreateConnection();
            //第二步：創建channel
            var channel = connection.CreateModel();
            //第三步：申明交換機

            //第四步：獲取消息
            var result = channel.BasicGet("manQueue", true);
            var msg = Encoding.UTF8.GetString(result.Body);

            Console.WriteLine(msg);
        }
    }
}

2.RabbitMQ的quick start