基于SQL Server CLR调用RabbitMQ报错：通道池阻塞问题求助

刚碰到过一模一样的问题，这个错误本质是RabbitMQ的通道池里拿不到可用的通道了，导致请求直接卡住。我整理了几个排查和修复的方向，你可以一步步试：

先搞懂错误根源 #

Channel pool blocked说白了就是你的CLR代码里维护的RabbitMQ通道池已经被占满，新的请求过来没通道可用了。常见的原因要么是通道用完没还回去，要么是池本身太小，要么是底层连接出问题导致池里的通道都失效了。

具体修复步骤 #

1. 检查通道是否正确回收 #

那篇文章里的RabbitPublisher应该用了通道池模式，你得确保每次用通道的时候都用using语句包裹——这能保证通道用完自动回池，不会被一直占用：

using (var channel = _channelPool.GetChannel())
{
    // 这里写发送消息的逻辑
    channel.BasicPublish(exchange, topic, null, msg);
}

如果你的代码里没这么写，或者手动获取通道后忘了调用释放方法，那通道就会一直占着，直到池被耗尽。

2. 调大通道池的最大容量 #

默认的通道池大小可能设置得太小，比如只有10个，但你的SQL Server并发请求超过这个数就会堵。找到CLR项目里初始化通道池的代码，把最大通道数调高一点：

// 举个例子，把最大通道数改成50，根据你的并发情况调整
var channelPool = new ChannelPool(connection, maxChannels: 50);

注意别调得太夸张，RabbitMQ每个连接的通道数默认上限是2047，还要考虑SQL Server CLR的资源承受能力。

3. 检查RabbitMQ连接的稳定性 #

如果底层的RabbitMQ连接断了或者出了异常，池里的通道可能就变成无效的了，拿过来用不了也回不去。你可以在代码里加个检查，连接断开时自动重建连接和通道池：

if (!_connection.IsOpen)
{
    _connection.Dispose();
    _connection = CreateNewRabbitConnection(); // 换成你创建连接的方法
    _channelPool = new ChannelPool(_connection, maxChannels: 50);
}

另外去看看RabbitMQ服务器的日志，有没有连接中断、限流或者资源不足的提示，这些也会影响通道的可用性。

4. 确认SQL Server CLR的权限配置 #

RabbitMQ需要网络连接，所以你的CLR程序集必须有EXTERNAL_ACCESS或者UNSAFE权限。用这条SQL查一下：

SELECT name, permission_set_desc FROM sys.assemblies WHERE name = 'RabbitMQSqlClr';

如果权限不对，得重新部署程序集并设置正确的权限，不然可能会间接导致通道创建失败，池里可用通道越来越少。

5. 从小规模测试开始验证 #

先测单条消息能不能正常发送，确认基础功能没问题。然后慢慢增加并发请求，看什么时候会出现阻塞——这样能快速定位是池大小不够还是通道泄漏的问题。

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