.netcore3.1 RabbitMq 讲讲相关方法

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

QueueDeclare方法

durable持久化

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

exclusive 排外

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);

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方法

channel.QueueDeclarePassive("AutoDelete");

QueueDeclareNoWait方法