.netcore3.1 RabbitMq 讲讲相关方法 - 尘叶心繁的专栏

.netcore3.1 RabbitMq 讲讲相关方法
.netcore3.1 RabbitMq 讲讲相关方法
QueueDeclare方法
durable持久化
exclusive 排外
autoDelete 自动删除
QueueDeclarePassive方法
QueueDeclareNoWait方法

QueueDeclare方法

这是一个创建队列的方法，参数以及参数描述由下图所示：

参数名	参数描述
durable	持久化操作。【mnesiz:数据库中会有专门的表去保存我们的队列申明】
exclusive	排外。当前定义的队列是`connection`共享的，其他的`connection`是访问不到的…
autoDelete	自动删除
passive	消极
arguments	传入一些相关参数

durable持久化

我们先来创建一个非持久化队列来进行一个演示

channel.QueueDeclare("NoDurable", false, false, false, null);

之后我们进行重启rabbitmq，然后我们就发现队列已经被删除了

exclusive 排外

一般connection是高成本的，因为TCP需要经过三次握手才可以连接得上，而在一个connection中是可以创建无数多个channel的。而exclusive为true也是随着connection的释放而释放，并且其他connection是不可以访问这个队列的。举个例子：

var factory = new ConnectionFactory()
{
    HostName = "47.98.187.188",
    UserName = "bob",
    Password = "bob"
};
// 创建一个链接
using (var connection = factory.CreateConnection())
{
    // 创建一个通道
    using (var channel = connection.CreateModel())
    {
        // 创建持久化队列
        channel.QueueDeclare("NoExclusive", false, true, false, null);
        // 这里我们先看完UI后再回车，让连接失效
        Console.ReadLine();
    }
}

然后回车

autoDelete 自动删除

channel.QueueDeclare("AutoDelete", false, false, true, null);

接着我们用一个消费端去消费该队列，并迅速的将消费端关闭，代码与UI过程如下：

var factory = new ConnectionFactory()
{
    HostName = "47.98.187.188",
    UserName = "bob",
    Password = "bob"
};
// 创建一个链接
using (var connection = factory.CreateConnection())
{
    // 创建一个通道
    using (var channel = connection.CreateModel())
    {
        var consumer = new EventingBasicConsumer(channel);
        // 事件在交付到使用者时触发。（消费处理事件）
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body.ToArray();
            var message = Encoding.UTF8.GetString(body);
            Thread.Sleep(1000);
            channel.BasicAck(ea.DeliveryTag, multiple: false);
        };
        // 绑定到队列中去
        channel.BasicConsume(queue: "AutoDelete", autoAck: false, consumer: consumer);                   Console.ReadLine();
    }
}
// 消费端结束

QueueDeclarePassive方法

检测队列是否存在。如果不存在就报错，就拿刚刚的AutoDelete来举个例子。

channel.QueueDeclarePassive("AutoDelete");

QueueDeclareNoWait方法

与QueueDeclare方法是差不多的，区别在于一个同步获取创建的结果，一个异步不返回结果，从底层源代码来说，这个方法所执行的步骤比QueueDeclare少

最后有一些Exchange与Queue的一些方法的意思类似，只不过一个是交换机，一个是队列的区别。