.Net使用RabbitMQ即时发消息Demo

以下是使用RabbitMQ在.NET中实现即时消息发送的完整攻略，包含两个示例说明。

示例1：发送消息到RabbitMQ

步骤1：安装RabbitMQ.Client

使用NuGet包管理器安装RabbitMQ.Client。

步骤2：创建消息发送者

创建一个消息发送者类，用于发送消息到RabbitMQ：

using RabbitMQ.Client;
using System.Text;

public class MessageSender
{
    private readonly ConnectionFactory _factory;
    private readonly IConnection _connection;
    private readonly IModel _channel;

    public MessageSender()
    {
        _factory = new ConnectionFactory() { HostName = "localhost" };
        _connection = _factory.CreateConnection();
        _channel = _connection.CreateModel();
        _channel.QueueDeclare(queue: "hello",
                              durable: false,
                              exclusive: false,
                              autoDelete: false,
                              arguments: null);
    }

    public void SendMessage(string message)
    {
        var body = Encoding.UTF8.GetBytes(message);

        _channel.BasicPublish(exchange: "",
                              routingKey: "hello",
                              basicProperties: null,
                              body: body);
    }

    public void Close()
    {
        _channel.Close();
        _connection.Close();
    }
}

步骤3：发送消息

在需要发送消息的地方，实例化消息发送者并调用SendMessage方法：

var messageSender = new MessageSender();
messageSender.SendMessage("Hello, RabbitMQ!");
messageSender.Close();

示例2：从RabbitMQ接收消息

步骤1：安装RabbitMQ.Client

同示例1。

步骤2：创建消息接收者

创建一个消息接收者类，用于接收消息：

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

public class MessageReceiver
{
    private readonly ConnectionFactory _factory;
    private readonly IConnection _connection;
    private readonly IModel _channel;

    public MessageReceiver()
    {
        _factory = new ConnectionFactory() { HostName = "localhost" };
        _connection = _factory.CreateConnection();
        _channel = _connection.CreateModel();
        _channel.QueueDeclare(queue: "hello",
                              durable: false,
                              exclusive: false,
                              autoDelete: false,
                              arguments: null);
    }

    public void ReceiveMessage()
    {
        var consumer = new EventingBasicConsumer(_channel);
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body.ToArray();
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine("Received message: {0}", message);
        };
        _channel.BasicConsume(queue: "hello",
                              autoAck: true,
                              consumer: consumer);
    }

    public void Close()
    {
        _channel.Close();
        _connection.Close();
    }
}

步骤3：启动消息接收者

在需要接收消息的地方，实例化消息接收者并调用ReceiveMessage方法：

var messageReceiver = new MessageReceiver();
messageReceiver.ReceiveMessage();

以上就是使用RabbitMQ在.NET中实现即时消息发送的完整攻略，包含两个示例说明。