RabbitMQ连接阻塞时资源无法正常释放的问题咨询

环境与重现步骤 #

• 版本信息：RabbitMQ 3.10.6，.NET Framework 4.8 + RabbitMQ.Client 6.2.4
• 连接配置：通过ConnectionFactory.CreateConnection()创建连接，启用AutomaticRecoveryEnabled = true
• 发送端代码：

IModel sendChannel = Connection.CreateModel();
sendChannel.ConfirmSelect();
sendChannel.QueueDeclare("sendQueueName", true, false, false);

• 接收端代码：

IModel receiveChannel = Connection.CreateModel();
receiveChannel.ConfirmSelect();
receiveChannel.QueueDeclare("receiveQueueName", true, false, false);
var receiveQueueConsumer = new QueueConsumer(receiveChannel); // 自定义类继承自DefaultBasicConsumer
receiveChannel.BasicConsume("receiveQueueName", false, receiveQueueConsumer);

异常现象 #

1. 填满磁盘达到RabbitMQ配置的阈值后，ConnectionBlocked事件触发，连接进入阻塞状态
2. 发送持久化消息：设置AMQP属性Persistent = true，执行sendChannel.BasicPublish("", "sendQueueName", amqpProperties, someBytes)后调用sendChannel.WaitForConfirms(TimeSpan.FromSeconds(5))，5秒后返回true，符合预期
3. 关闭应用时资源释放出现异常：
   • sendChannel.Close()阻塞10秒
   • receiveChannel.BasicCancel(ConsumerTags.First())抛出TimeoutException
   • Connection.Close()冻结至少1分钟
4. 替换为Dispose()或Abort()方法，行为完全一致；强制关闭应用后，底层连接和通道仍处于阻塞状态，只有当磁盘空间恢复充足，Broker才会自动移除这些阻塞的连接与通道，无需重启Broker

官方相关说明 #

超时可能有多种原因，从真正的连接中断到生效的资源警报，除非警报解除，否则目标节点无法读取来自客户端的任何数据。

节点会通过暂停读取客户端连接来临时阻塞发布连接。

疑问求助 #

1. 是否意味着除非重启Broker或解除资源警报，否则客户端无法正常释放资源？是否有官方的明确确认？
2. 如何调整客户端的资源释放机制，使其在Broker处于阻塞状态时也能正常完成资源清理？

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