RabbitMQ安装及C#使用教程（.NET Core）

RabbitMQ安装

安装RabbitMQ需要以下文件：

- rabbitmq-server-3.6.12

- otp_win64_20.1（64位系统）/ otp_win32_20.1（32位系统）

重要提示：在安装server之前，请先安装OTP，否则可能出现错误。

Server配置

安装server后，配置其用户名和密码。

C#代码示例

以下代码示例演示了如何使用C#连接RabbitMQ并发送消息：

using RabbitMQ.Client;

// 创建连接工厂
var factory = new ConnectionFactory() { HostName = "localhost" };

// 创建连接
using (var connection = factory.CreateConnection())
{
    // 创建信道
    using (var channel = connection.CreateModel())
    {
        // 创建队列
        channel.QueueDeclare("my-queue", false, false, false, null);

        // 发送消息
        var message = Encoding.UTF8.GetBytes("Hello, world!");
        channel.BasicPublish("", "my-queue", null, message);
    }
}

CMD命令截图

1. 启用插件：rabbitmq-plugins enable rabbitmq_management
2. 添加用户：rabbitmqctl add_user username password
3. 给添加的用户赋权：rabbitmqctl set_permissions -p / username "['.']'.'"

标签： RabbitMQ、C#、消息队列、.NET Core、教程