一段时间后在 RabbitMQ 中获取 OutOfMemory

Question

我将 RabbitMQ 与 C#、MassTransit、Autofac 结合使用。

我有一个预定的（5 秒）作业来使用队列。

这项工作大约工作了 2 个小时，然后突然停止了。当我搜索日志时，我发现了这个：

Scope ---> An exception occurred during bus creation (See inner exception for det ails.) ---> MassTransit.ConfigurationException: An exception occurred during bus creation ---> System.OutOfMemoryException: Exception of type 'System.OutOfMemoryException' was thrown.

这些是我在 MassTransit 中配置 Autofac 的代码块：

builder.Register(context =>
{
    var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
    {
        cfg.Host(new Uri(Globals.QueueUrl), h =>
        {
            h.Username(Globals.QueueUserName);
            h.Password(Globals.QueuePassword);
        });

        cfg.ReceiveEndpoint("create_sales_queue",
            ec =>
            {
                ec.Consumer<CreateSalesConsumer>(context);
                ec.UseRetry(p => p.Incremental(10, TimeSpan.FromMilliseconds(200), TimeSpan.FromMilliseconds(200)));
            });

    });
    return busControl;
})
    .InstancePerDependency()
    .As<IBusControl>()
    .Named<IBusControl>(GenericIntegrationTask.CreateSalesTask.ToString());

这些是预定作业的代码：

try
{

    var bus = container.ResolveNamed<IBusControl>(GenericIntegrationTask.CreateSalesTask.ToString());
    bus.Start();
    Thread.Sleep(2000);
    bus.Stop();        
}
catch (Exception e)
{
    Console.WriteLine(e);
}

提前致谢。

Answer 1

问题是，每次您解析 IBusControl 实例时，您都会创建一个新实例。但是您不使用生命周期范围 - 此实例未被 GC 收集。

我看到两个解决方案：

列表项在生命周期范围内解析IBusControl。 See here
将 IBusControl 注册为 SingleInstance

Answer 2

你应该永远不要注册你的IBus每个依赖项或每个请求。它必须是单个实例。

您还需要在应用启动时启动总线，在应用停止时停止总线。

一段时间后在 RabbitMQ 中获取 OutOfMemory

Getting OutOfMemory in RabbitMQ after a while

c#

masstransit

out-of-memory

autofac