C#在.NET Core中的消息隊列RabbitMQ支持

在.NET Core中，RabbitMQ是一個流行的消息隊列系統(tǒng)，用于在分布式系統(tǒng)中傳遞消息。為了在.NET Core應(yīng)用程序中使用RabbitMQ，你需要使用RabbitMQ .NET客戶端庫，如RabbitMQ.Client。

以下是在.NET Core中使用RabbitMQ的基本步驟：

1. 安裝RabbitMQ.Client NuGet包：

dotnet add package RabbitMQ.Client

2. 創(chuàng)建一個連接工廠（ConnectionFactory）并設(shè)置RabbitMQ服務(wù)器的連接信息：

using RabbitMQ.Client;

var factory = new ConnectionFactory()
{
    HostName = "localhost", // RabbitMQ服務(wù)器地址
    UserName = "guest",     // 用戶名
    Password = "guest"      // 密碼
};

3. 使用連接工廠創(chuàng)建一個連接（IConnection）和一個通道（IModel）：

using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    // 在這里編寫與RabbitMQ交互的代碼
}

4. 聲明一個隊列（Queue）：

string queueName = "my_queue";
channel.QueueDeclare(queue: queueName, durable: false, exclusive: false, autoDelete: false, arguments: null);

5. 發(fā)送消息到隊列：

string message = "Hello, RabbitMQ!";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "", routingKey: queueName, basicProperties: null, body: body);

6. 從隊列接收消息：

var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
    var receivedBody = ea.Body.ToArray();
    var receivedMessage = Encoding.UTF8.GetString(receivedBody);
    Console.WriteLine($"Received message: {receivedMessage}");
};
channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);

這些示例展示了如何在.NET Core應(yīng)用程序中使用RabbitMQ發(fā)送和接收消息。你可以根據(jù)自己的需求調(diào)整代碼，例如使用不同的交換器（Exchange）、路由鍵（RoutingKey）等。