.netcore3.1 RabbitMq MessageTTL，AutoExpire，MaxLength与MaxLengthBytes

• .netcore3.1 RabbitMq MessageTTL，AutoExpire，MaxLength与MaxLengthBytes
  • Message TTL
    • Queue TTL
    • Queue TTL Demo
    • Message TTL
    • Message Demo
  • Auto Expire(队列存活时间)
    • Auto Expire Demo
    • 命令
  • MaxLength
    • MaxLength Demo
    • MaxLengthBytes

Message TTL

Queue TTL

使用策略为队列定义消息TTL

Queue TTL Demo

var factory = new ConnectionFactory()
{
    HostName = "127.0.0.1",
    UserName = "bob",
    Password = "bob"
};
// 创建一个链接
using (var connection = factory.CreateConnection())
{
    // 创建一个通道
    using (var channel = connection.CreateModel())
    {
        // 创建x-message-ttl为6秒的参数
        var arguments = new Dictionary<string,object>();
        arguments.Add("x-message-ttl",12000);
        // 创建一个消息只可以存活6秒的队列
        channel.QueueDeclare(
            queue: "MyTTLQueue",
            durable: true,
            exclusive: false,
            autoDelete: false,
            arguments: arguments);
        // 发布一个新消息
        channel.BasicPublish(
            exchange: string.Empty,
            routingKey: "MyTTLQueue",
            basicProperties: null,
            body: Encoding.UTF8.GetBytes("新消息")
            );
        Console.WriteLine("Finish");
        Console.ReadLine();
    }
}

Message TTL

Message Demo

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: "MyMessageQueue",
            durable: true,
            exclusive: false,
            autoDelete: false,
            arguments: null);
        // 发布一个只能存活12秒的新消息
        var props = channel.CreateBasicProperties();
        props.Expiration = "12000";
        channel.BasicPublish(
            exchange: string.Empty,
            routingKey: "MyMessageQueue",
            basicProperties: props,
            body: Encoding.UTF8.GetBytes("新消息")
            );
        Console.WriteLine("Finish");
        Console.ReadLine();
    }
}

Auto Expire(队列存活时间)

Auto Expire Demo

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: "MyExpireQueue",
            durable: false,
            exclusive: false,
            autoDelete: false,
            arguments: new Dictionary<string,object>(){
                {"x-expires",1000*12}
            });
        channel.BasicPublish(
            exchange: string.Empty,
            routingKey: "MyExpireQueue",
            basicProperties: null,
            body: Encoding.UTF8.GetBytes("新消息")
            );
        Console.WriteLine("Finish");
        Console.ReadLine();
    }
}

命令

MaxLength

MaxLength Demo

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: "MyMaxLengthQueue",
            durable: false,
            exclusive: false,
            autoDelete: false,
            arguments: new Dictionary<string,object>(){
                {"x-max-length",10}
            });
            // 我们创建15条消息
            for (var i = 0; i < 15; i++)
            {
                channel.BasicPublish(
                    exchange: string.Empty,
                    routingKey: "MyMaxLengthQueue",
                    basicProperties: null,
                    body: Encoding.UTF8.GetBytes($"新消息{i}")
                    );
            }
        Console.WriteLine("Finish");
        Console.ReadLine();
    }
}

MaxLengthBytes