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

namespace RabbitMQTest.Producer
{
    /// <summary>
    /// RabbitMQ測(cè)試_Producer生產(chǎn)者
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            // 1、創(chuàng)建連接工廠
            IConnectionFactory factory = new ConnectionFactory()
            {
                UserName = "admin",
                Password = "admin",
                HostName = "192.168.1.101", //rabbitmq server ip
                Port = 5672,
                VirtualHost = "testhost" //在此連接期間要訪問(wèn)的虛擬主機(jī)。
            };
            // 2、創(chuàng)建連接
            IConnection connection = factory.CreateConnection();
            // 3、創(chuàng)建通道
            IModel channel = connection.CreateModel();
            string name = "testQueue";
            // 4、聲明一個(gè)隊(duì)列
            channel.QueueDeclare(
                queue: name, //消息隊(duì)列名稱
                durable: false, //是否持久化，true持久化，隊(duì)列會(huì)保存磁盤,服務(wù)器重啟時(shí)可以保證不丟失相關(guān)信息。
                exclusive: false, //是否排他，true排他的，如果一個(gè)隊(duì)列聲明為排他隊(duì)列,該隊(duì)列僅對(duì)首次聲明它的連接可見,并在連接斷開時(shí)自動(dòng)刪除。
                autoDelete: false, //是否自動(dòng)刪除，true是自動(dòng)刪除，自動(dòng)刪除的前提是：致少有一個(gè)消費(fèi)者連接到這個(gè)隊(duì)列，之后所有與這個(gè)隊(duì)列連接的消費(fèi)者都斷開時(shí)，才會(huì)自動(dòng)刪除。
                arguments: null); //設(shè)置隊(duì)列的一些其它參數(shù)。

            Console.WriteLine("\n RabbitMQ連接成功，請(qǐng)輸入消息，輸入exit退出！");
            string input;
            do
            {
                input = Console.ReadLine();
                byte[] sendBytes = Encoding.UTF8.GetBytes(input);
                //發(fā)布消息
                channel.BasicPublish("", name, null, sendBytes);
                Console.WriteLine("消息發(fā)布完畢");
            } while (input.Trim().ToLower() != "exit");
            Console.WriteLine("\n RabbitMQ測(cè)試完畢！");
            // 6、關(guān)閉通道
            channel.Close();
            // 7、關(guān)閉連接
            connection.Close();
        }
    }
}

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;
using System.Threading;

namespace RabbitMQTest.Consumer
{
    /// <summary>
    /// RabbitMQ測(cè)試_Consumer消費(fèi)者
    /// </summary>
    class Program
    {
        static void Main(string[] args)
        {
            // 1、創(chuàng)建連接工廠
            ConnectionFactory factory = new ConnectionFactory()
            { 
                UserName = "admin", //用戶名
                Password = "admin", //密碼
                HostName = "192.168.1.101", //rabbitmq server ip
                Port = 5672, //端口號(hào)
                VirtualHost = "testhost" //在此連接期間要訪問(wèn)的虛擬主機(jī)。

            };
            // 2、創(chuàng)建連接
            IConnection connection = factory.CreateConnection();
            // 3、創(chuàng)建通道
            IModel channel = connection.CreateModel();
            // 4、事件基本消費(fèi)者
            EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
            string name = "testQueue";
            // 5、接收到消息事件
            consumer.Received += (ch, ea) =>
              {
                  string message = Encoding.Default.GetString(ea.Body.ToArray());
                  Console.WriteLine($"接受到消息：{message}");
                  Console.WriteLine($"收到該消息[{ea.DeliveryTag}] 延遲1s發(fā)送回執(zhí)！");
                  Thread.Sleep(1000);
                  // 6、確認(rèn)該消費(fèi)已被消費(fèi)
                  channel.BasicAck(ea.DeliveryTag, false);
                  Console.WriteLine($"已發(fā)送回執(zhí){ea.DeliveryTag}");
              };
            // 7、啟動(dòng)消費(fèi)者 設(shè)置為手動(dòng)應(yīng)答消息
            channel.BasicConsume(name, false, consumer);

            Console.WriteLine("消費(fèi)者已啟動(dòng)");
            Console.ReadKey();
            channel.Close();
            connection.Close();
        }
    }
}