使用RabbitMQ+C#+MassTransit+Autofac遇内存溢出异常求助

看起来你遇到的是典型的资源未正确释放导致的内存堆积问题，结合异常信息和你的场景（每5秒执行一次的定时任务，运行2小时后OOM），核心问题大概率出在总线实例的生命周期管理或者Autofac Scope的不当使用上，下面给你一步步的排查和解决思路：

1. 先排查总线实例的创建逻辑 #

最常见的坑就是每次定时任务都创建新的MassTransit总线实例——每5秒就新建一个总线，2小时下来就是1440个总线实例，每个总线都持有RabbitMQ连接、通道、消费者等大量资源，没释放的话必然会撑爆内存。

你需要确保：

• 总线是单例注册的，只在应用启动时创建并启动一次，后续所有定时任务都复用这个实例。
• 检查你的Autofac配置，是否把IBusControl注册为单例：

// 正确的单例注册方式
builder.Register(c => Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    // 你的RabbitMQ配置代码
    var host = cfg.Host("rabbitmq://localhost", h =>
    {
        h.Username("guest");
        h.Password("guest");
    });

    // 注册消费者时复用Autofac的Scope
    cfg.ReceiveEndpoint(host, "your_queue_name", e =>
    {
        e.Consumer<YourConsumer>(c.Resolve<ILifetimeScope>());
    });
})).As<IBusControl>().As<IBus>().SingleInstance();

• 应用启动时一次性启动总线，不要在定时任务里重复创建/启动：

var container = builder.Build();
var bus = container.Resolve<IBusControl>();
bus.Start(); // 只在启动时执行一次

2. 检查Autofac Scope的管理 #

异常里提到Scope ---> 创建总线时发生异常，说明你的定时任务可能在每次执行时都创建了新的Autofac Scope，并且在Scope内部创建了总线——这会导致Scope和总线实例不断堆积。

解决要点：

• 定时任务执行时，若需要创建Scope，必须用using语句确保Scope被正确释放：

// 定时任务内的Scope使用方式
using(var scope = container.BeginLifetimeScope())
{
    var bus = scope.Resolve<IBus>(); // 复用单例总线，不是创建新的
    // 执行你的消费/消息发布逻辑
}

• 消费者的生命周期要和Scope绑定，确保每次消费完成后，消费者的依赖资源（比如数据库上下文、网络连接）能被及时释放。

3. 用工具定位内存泄漏点 #

如果上面的调整后问题还存在，建议用内存分析工具精准定位：

• 使用Visual Studio自带的内存诊断工具（Memory Diagnostic Tool），或者JetBrains的dotMemory，捕获OOM前的内存快照。
• 重点查看是否有大量的RabbitMqBus、ConnectionFactory、IModel（RabbitMQ通道）对象存在——这些都是总线相关的资源，如果没被GC回收，说明总线实例没被正确释放。
• 同时检查是否有大量未释放的Autofac Scope实例，或者消费者依赖的对象（比如DbContext）堆积。

4. 正确实现MassTransit定时任务 #

如果你是自己手动实现的5秒定时任务，建议改用MassTransit官方推荐的定时任务集成方案（比如和Quartz/Hangfire配合），避免手动管理总线生命周期：

• 用Quartz的话，Job里直接从Autofac容器获取已注册的单例IBus，而不是创建新的总线：

public class MyScheduledJob : IJob
{
    private readonly IBus _bus;

    // 构造函数注入单例总线
    public MyScheduledJob(IBus bus)
    {
        _bus = bus;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        // 执行你的消息发布/消费逻辑，复用已有的总线
        await _bus.Publish(new YourMessage());
    }
}

最后总结 #

你的问题本质是资源重复创建+未释放导致的内存溢出，优先排查总线是否单例、Scope是否正确释放，再用内存工具确认泄漏点，基本上就能解决问题。

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