# 使用NuGet安裝RabbitMQ.Client（官方客戶端）
Install-Package RabbitMQ.Client
 
# 如果喜歡更簡(jiǎn)單的封裝，可以安裝EasyNetQ（基于RabbitMQ.Client）
Install-Package EasyNetQ

using RabbitMQ.Client;
using System.Text;

class Program
{
    static void Main(string[] args)
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            // 聲明交換機(jī)（使用fanout類型，適合廣播）
            channel.ExchangeDeclare(exchange: "logs", type: "fanout");
            
            // 發(fā)送消息
            string message = "Hello RabbitMQ from C#!";
            var body = Encoding.UTF8.GetBytes(message);
            
            channel.BasicPublish(exchange: "logs", 
                                routingKey: "", 
                                basicProperties: null, 
                                body: body);
            
            Console.WriteLine($" [x] Sent '{message}'");
        }
    }
}

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

class Program
{
    static void Main(string[] args)
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            // 聲明相同交換機(jī)
            channel.ExchangeDeclare(exchange: "logs", type: "fanout");
            
            // 創(chuàng)建臨時(shí)隊(duì)列（會(huì)自動(dòng)刪除）
            var queueName = channel.QueueDeclare().QueueName;
            
            // 綁定隊(duì)列到交換機(jī)
            channel.QueueBind(queue: queueName,
                             exchange: "logs",
                             routingKey: "");
            
            // 創(chuàng)建消費(fèi)者
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine($" [x] Received '{message}'");
            };
            
            channel.BasicConsume(queue: queueName,
                                autoAck: true,
                                consumer: consumer);
            
            Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C");
            Console.ReadLine();
        }
    }
}

// 發(fā)布者
channel.ExchangeDeclare(exchange: "persistent", type: "direct", durable: true);
channel.QueueDeclare(queue: "persistent_queue", durable: true);
channel.QueueBind(queue: "persistent_queue", exchange: "persistent", routingKey: "key");

var message = "Persistent message";
var body = Encoding.UTF8.GetBytes(message);
var properties = channel.CreateBasicProperties();
properties.Persistent = true; // 關(guān)鍵！設(shè)置為持久化

channel.BasicPublish(exchange: "persistent", 
                    routingKey: "key",
                    basicProperties: properties,
                    body: body);

// 安裝EasyNetQ
// Install-Package EasyNetQ

using EasyNetQ;
using System;

class Program
{
    static void Main()
    {
        // 創(chuàng)建連接
        var bus = RabbitHutch.CreateBus("host=localhost");
        
        // 發(fā)布消息
        bus.Publish(new Message { Text = "Hello EasyNetQ!" });
        
        // 訂閱消息
        bus.Subscribe<Message>("my-queue", message => 
        {
            Console.WriteLine($"Received: {message.Text}");
        });
        
        Console.WriteLine("Waiting for messages...");
        Console.ReadLine();
    }
}

// 訂單服務(wù)（生產(chǎn)者）
public void CreateOrder(Order order)
{
    // 處理訂單邏輯...
    
    // 發(fā)布訂單消息到RabbitMQ
    var bus = RabbitHutch.CreateBus("host=localhost");
    bus.Publish(new OrderCreatedEvent { OrderId = order.Id });
}

// 郵件服務(wù)（消費(fèi)者）
bus.Subscribe<OrderCreatedEvent>("order-events", order => 
{
    // 發(fā)送確認(rèn)郵件
    EmailService.SendOrderConfirmation(order.OrderId);
});

// 日志服務(wù)（生產(chǎn)者）
public void Log(string message)
{
    var bus = RabbitHutch.CreateBus("host=localhost");
    bus.Publish(new LogMessage { Message = message, Timestamp = DateTime.UtcNow });
}

// 日志處理服務(wù)（消費(fèi)者）
bus.Subscribe<LogMessage>("log-queue", log => 
{
    // 保存到數(shù)據(jù)庫或文件
    LogRepository.Save(log);
});

// 使用連接工廠創(chuàng)建連接
var factory = new ConnectionFactory { HostName = "localhost" };
using (var connection = factory.CreateConnection())
{
    // 用同一個(gè)連接創(chuàng)建多個(gè)channel
    using (var channel = connection.CreateModel())
    {
        // ...
    }
}

try
{
    // 消息處理邏輯
}
catch (Exception ex)
{
    // 記錄錯(cuò)誤并重試
    Console.WriteLine($"處理消息失敗: {ex.Message}");
}

channel.QueueDeclare(queue: "my-queue", 
                   durable: true, 
                   exclusive: false, 
                   autoDelete: false);

channel.BasicConsume(queue: "my-queue",
                   autoAck: false, // 關(guān)鍵！設(shè)置為false
                   consumer: consumer);