.netcore3.1 RabbitMq Lazy Queue

• .netcore3.1 RabbitMq Lazy Queue
  • 没有Lazy的出现了什么问题
  • 使用Lazy Queue + inMemory的方式
  • 使用Default Queue + inMemory的方式
  • 其他

没有Lazy的出现了什么问题

• 消费者离线/崩溃/需要维护
• 突然出现消息入侵高峰，生产者的速度超过了消费者
• 消费者比正常人慢

使用Lazy Queue + inMemory的方式

var factory = new ConnectionFactory()
{
    HostName = "47.98.187.188",
    UserName = "bob",
    Password = "bob"
};
// 创建一个链接
using (var connection = factory.CreateConnection())
{
    // 创建一个通道
    using (var channel = connection.CreateModel())
    {
        // 声明一个Single_Active_Consumer_Queue队列
        channel.QueueDeclare(
            queue: "my_lazy_test",
            durable: true,
            exclusive: false,
            autoDelete: false,
            arguments: new Dictionary<string, object>() {
                { "x-queue-mode","lazy" }
            });
        for (int i = 0; i < int.MaxValue; i++)
        {
            var msg = Encoding.UTF8.GetBytes($"Publish Message {i}");
            channel.BasicPublish(string.Empty, "my_lazy_test", null, msg);
            Console.WriteLine($"Publish Message {i}");
        }
        Console.WriteLine(" Press [enter] to exit.");
        Console.ReadLine();
    }
}

使用Default Queue + inMemory的方式

var factory = new ConnectionFactory()
{
    HostName = "47.98.187.188",
    UserName = "bob",
    Password = "bob"
};
// 创建一个链接
using (var connection = factory.CreateConnection())
{
    // 创建一个通道
    using (var channel = connection.CreateModel())
    {
        // 声明一个Single_Active_Consumer_Queue队列
        channel.QueueDeclare(
            queue: "my_default_test",
            durable: true,
            exclusive: false,
            autoDelete: false,
            arguments: null);
        for (int i = 0; i < int.MaxValue; i++)
        {
            var msg = Encoding.UTF8.GetBytes($"Publish Message {i}");
            channel.BasicPublish(string.Empty, "my_default_test", null, msg);
            Console.WriteLine($"Publish Message {i}");
        }
        Console.WriteLine(" Press [enter] to exit.");
        Console.ReadLine();
    }
}

其他