如果有大量请求尝试同时使用ipooledObject -policy，则createConnection（）失败

Question

我需要在.NET应用程序中使用RabbitMQ。我的策略是拥有一个iConnection和多个imodel由ipooledobjectPolicy处理。

问题是，如果有大量请求尝试同时使用sendMessage方法，我会在factory.createconnection（）;上获得此错误消息，我相信消息本身与实际问题无关：

rabbitmq.client.exceptions.brokerunreachableException
消息=指定的终点都不到达
ioException：Connection。从未收到启动，可能是由于网络超时

引起的

如果只有一个请求尝试使用sendmessage首次使用，那么在此之后一切正常，即使同时有大量请求触发。

这是实现ipooledObjectPolicy＆lt; imodel＆gt;：

private readonly RabbitMqConfigurations rabbitMqConfigurations;
private readonly IConnection _connection;

public RabbitModelPooledObjectPolicy(IOptions<RabbitMqConfigurations> RabbitMqConfigurations)
{
    rabbitMqConfigurations = RabbitMqConfigurations.Value;
    _connection = GetConnection();
}

private IConnection GetConnection()
{
    var factory = new ConnectionFactory
    {
        HostName = rabbitMqConfigurations.HostName
    };

    return factory.CreateConnection(); //<-- it fails
}

public IModel Create() => return _connection.CreateModel();

public bool Return(IModel obj)
{
    if (obj.IsOpen)
        return true;
    else
    {
        obj?.Dispose();
        return false;
    }
}

这就是我使用ipooledobjectpolicy＆lt; imodel＆gt;：

private readonly DefaultObjectPool<IModel> objectPool;

public RabbitMQProducer(IPooledObjectPolicy<IModel> objectPolicy)
{
    objectPool = new DefaultObjectPool<IModel>(objectPolicy, Environment.ProcessorCount * 2);
}

public void SendMessage<T>(T message, string queue) where T : class
{
    var channel = objectPool.Get();

    try
    {
        channel.QueueDeclare(queue: queue, durable: true, exclusive: false, autoDelete: false, arguments: null);

        var properties = channel.CreateBasicProperties();
        properties.Persistent = true;

        var json = JsonConvert.SerializeObject(message);
        var body = Encoding.UTF8.GetBytes(json);

        channel.BasicPublish(exchange: "", routingKey: queue, basicProperties: properties, body: body);
    }
    catch
    {
        throw;
    }
    finally
    {
        objectPool.Return(channel);
    }
}

我将这两个服务注册为Singleton：Singleton：

services.AddSingleton<IPooledObjectPolicy<IModel>, RabbitModelPooledObjectPolicy>();
services.AddSingleton<IMessageProducer, RabbitMQProducer>();

Answer 1

我可以设法解决这个问题。

说明问题：

rabbitmodelpooledobjectpolicy构造器首次访问课时。在执行构造函数的同时，应用程序也试图处理其他请求，并且请求很多，并且不断地像不间断的流一样出现。

因此，似乎某种程度上的应用程序正在放弃factory.createconnection（）临时处理其他即将到来的请求，以执行factory.createconnection（）稍后。但是，没有终点的请求，并且相同的情况会发生，直到factory.createconnection（）引发了超时的例外。

解决方案：

我热身ipooledobject -policy＆lt; imodel＆gt; in configure in startup.cs ececute eccodute rabbitMbitModelpoolpoolpoolpoolpoolpoolpoolpoolpoolpoolpoolpoolpolicy启动中的构造函数在应用程序准备就绪并收到请求之前。

public void Configure(IApplicationBuilder app, IWebHostEnvironment env){
    app.ApplicationServices.GetService<IPooledObjectPolicy<IModel>>();
}