.netcore3.1 RabbitMq 简单运用与相关方法的介绍

• .netcore3.1 RabbitMq 简单运用与相关方法的介绍
  • 准备
  • 构建生产项目
    • 创建生产项目
    • 添加内容
    • 运行项目
  • 构建消费项目
    • 创建消费项目
    • 添加内容
    • 测试运行
  • 连接到RabbitMQ
  • 被动声明
  • 删除实体和清理消息
  • 发布消息

准备

构建生产项目

创建生产项目

dotnet new console --name Send
mv Send/Program.cs Send/Send.cs
cd Send
# 添加相关依赖包
dotnet add package RabbitMQ.Client
dotnet restore

添加内容

using System.Text;
using System;
using RabbitMQ.Client;
namespace Send
{
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory() { 
                HostName = "127.0.0.1",
                UserName = "bob",
                Password = "bob"
            };
            // 创建一个链接
            using (var connection = factory.CreateConnection())
            {
                // 创建一个通道
                using (var channel = connection.CreateModel())
                {
                    // 在这里还应该声明一个交换机
                    // 声明一个队列
                    channel.QueueDeclare(
                        queue:"mytestqueue",
                        durable: false,
                        exclusive: false,
                        autoDelete: false,
                        arguments: null);
                    // 创建一个消息
                    string message = "Hello World";
                    // 编码一个消息
                    var body = Encoding.UTF8.GetBytes(message);
                    // 发布一个消息
                    channel.BasicPublish(
                        exchange:string.Empty,
                        routingKey: "mytestqueue",
                        basicProperties: null,
                        body: body
                        );
                    System.Console.WriteLine("Sent Message:{0}",message);
                    Console.ReadLine();
                }
            }
        }
    }
}

运行项目

构建消费项目

创建消费项目

dotnet new console --name Receive
mv Receive/Program.cs Receive/Receive.cs
cd ../Receive
dotnet add package RabbitMQ.Client
dotnet restore

添加内容

using System.Text;
using System;
using RabbitMQ.Client;
using System.Buffers.Text;
namespace Receive
{
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory() { 
                HostName = "127.0.0.1",
                UserName = "bob",
                Password = "bob"
            };
            // 创建一个链接
            using (var connection = factory.CreateConnection())
            {
                // 创建一个通道
                using (var channel = connection.CreateModel())
                {
                    // 在这里还应该声明一个交换机
                    // 获取一个消息
                    var result = channel.BasicGet("mytestqueue",true);
                    var msg = Encoding.UTF8.GetString(result.Body.ToArray());
                    Console.WriteLine($"获取到一条消息：{msg}");
                }
            }
            Console.ReadLine();
        }
    }
}

测试运行

连接到RabbitMQ

channel.QueueDeclare(
    queue:"mytestqueue",
    durable: false,
    exclusive: false,
    autoDelete: false,
    arguments: null);

// 创建交换机
channel.ExchangeDeclare("MyExchangeName",ExchangeType.Direct);
channel.QueueDeclare(
    queue:"mytestqueue",
    durable: false,
    exclusive: false,
    autoDelete: false,
    arguments: null);
// 绑定在一起
channel.QueueBind("mytestqueue","MyExchangeName","routingKey",null);

被动声明

var response = channel.QueueDeclarePassive("queue-name");
// 获取消息数量
var GetMessageCount = response.MessageCount;
// 获取消费者数量
var GetConsumerCount = response.ConsumerCount;

删除实体和清理消息

// 可以显示删除队列和交换机
channel.QueueDelete("queue-name",false,false);
// 仅当队列为空时才可以删除它
channel.QueueDelete("queue-name",false,true);
// 如果不使用（没有任何使用者才删除）
channel.QueueDelete("queue-name",true,false);
// 可以清除队列（删除其所有消息）
channel.QueuePurge("queue-name");

发布消息

string message = "Hello World";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(
    exchange:string.Empty,
    routingKey: "mytestqueue",
    basicProperties: null,
    body: body
);