小编Ank*_*och的帖子

我正在使用 RabbitMQ .net 客户端库以下列方式将消息发布到 RabbitMQ 节点。

var factory = new ConnectionFactory
                {
                    HostName = "localhost",
                    Port = 5672,
                    UserName = "guest",
                    Password = "guest",
                    VirtualHost = @"/"
                };
_conn = factory.CreateConnection();

_channel = _conn.CreateModel();

_properties = _channel.CreateBasicProperties();

然后在循环中调用下面的

using (var memStream = new MemoryStream())
{
    var formatter = new BinaryFormatter();

    formatter.Serialize(memStream, message);

    var properties = _channel.CreateBasicProperties();
    properties.Priority = Convert.ToByte((int) priority);

   _channel.BasicPublish(String.Empty, _routeKey, properties, memStream.ToArray());
 }

上面的代码在中等负载下运行良好，每秒大约有 50-100 条消息。但是当我增加每秒大约 500 条消息要发布的消息数量时，RabbitMQ 节点开始出现以下错误并断开通道连接。

Already closed: The AMQP operation was interrupted: AMQP close-reason, …