更新MassTransit至8.1.3版本后全局设置Message TTL失效问题

核心原因 #

MassTransit 8.1.x版本调整了MessageDataDefaults.TimeToLive的作用范围：该配置仅针对MessageData（大消息分片存储）的TTL生效，不再像8.0.x版本那样隐式同步设置常规RabbitMQ消息的过期时间。之前版本的隐式关联在8.1.x中被移除，导致全局配置不再作用于普通消息。

解决方法 #

根据你的使用场景，选择对应方案：

1. 全局设置所有发送消息的TTL #

在Bus配置中，通过发送规则为所有消息统一设置TTL：

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.ConfigureEndpoints(context);
        
        // 为所有类型的消息设置全局TTL
        cfg.Send(s =>
        {
            s.TimeToLive = TimeSpan.FromSeconds(ttlInSeconds);
        });
    });
});

2. 为队列设置全局消息TTL（消费端生效） #

如果需要让进入队列的所有消息自动过期，可配置队列的x-message-ttl参数：

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.ReceiveEndpoint("your-target-queue", e =>
        {
            // 设置队列级别的消息TTL，单位毫秒
            e.SetQueueArgument("x-message-ttl", (int)TimeSpan.FromSeconds(ttlInSeconds).TotalMilliseconds);
        });
    });
});

3. 发送单个消息时显式指定TTL #

针对特定消息单独设置过期时间：

await _bus.Send(new YourBusinessMessage(), sendContext =>
{
    sendContext.TimeToLive = TimeSpan.FromSeconds(ttlInSeconds);
});

4. 若使用MessageData场景 #

如果你确实是在处理大消息（依赖MessageData存储），MessageDataDefaults.TimeToLive依然会作为默认TTL生效，只需确保发送时正确使用MessageData：

var largeData = await _messageDataRepo.CreateMessageData(new LargePayload(), TimeSpan.FromSeconds(ttlInSeconds));
await _bus.Send(new MessageWithData { Payload = largeData });

验证步骤 #

• 登录RabbitMQ管理后台，查看消息的expiration字段是否存在；
• 检查队列的参数列表，确认x-message-ttl是否配置正确；
• 调试发送逻辑，确认TimeToLive值是否传递到RabbitMQ的BasicPublish调用参数中。

内容的提问来源于stack exchange，提问作者Alexey Bychkov