RabbitMQ.Client 中序列化大小异常的分析与解决

问题背景

在使用RabbitMQ.Client库进行消息发布时，从5.1.1版本升级到6.8.1后，部分用户遇到了"Serialized to wrong size"的异常。这个异常表现为在调用BasicPublish方法时，实际序列化大小与预期大小不匹配，导致消息发布失败。

异常现象

异常信息显示："Serialized to wrong size, expect 14068, offset 14056"，这表明在序列化过程中，实际生成的字节数与预期值存在偏差。这种错误通常发生在网络传输层，当框架尝试将消息序列化并发送到RabbitMQ服务器时。

根本原因分析

经过深入调查，发现这个问题与IModel实例的线程安全性有关。在RabbitMQ.Client库中：

1. IConnection是线程安全的，可以在多个线程间共享
2. IModel/IChannel不是线程安全的，应该每个线程使用独立实例

在5.1.1版本中，虽然IModel也不是线程安全的，但由于内部实现的原因，可能在多线程环境下"偶然"工作正常。而在6.8.1版本中，内部序列化机制更加严格，当多个线程同时使用同一个IModel实例时，就可能出现序列化大小不匹配的问题。

解决方案

正确的做法是在每次发布消息时创建新的IModel实例，或者在每个线程中使用独立的IModel实例。以下是改进后的代码示例：

private Task<PublishResult> PublishAsync(byte[] messageBody, string routingKey, CancellationToken cancellation)
{
    return Task.Run(() =>
    {
        try
        {
            // 每个任务创建新的IModel实例
            using var model = Connection.CreateModel();
            var properties = model.CreateBasicProperties();
            properties.DeliveryMode = PersistentDeliveryMode;

            cancellation.ThrowIfCancellationRequested();

            model.BasicPublish(Configuration.Exchange, routingKey, mandatory: false, properties, messageBody);

            return PublishResult.Published;
        }
        catch (Exception ex)
        {
            logger.LogError(ex, nameof(PublishAsync));
            return PublishResult.Unpublished(messageBody, Configuration.Exchange, routingKey);
        }
    });
}

最佳实践建议

1. IModel生命周期管理：IModel实例应该保持短生命周期，使用后及时释放
2. 线程隔离：确保每个线程使用独立的IModel实例
3. 资源复用：虽然需要创建新实例，但可以复用IConnection对象
4. 新版考虑：考虑升级到7.0.0及以上版本，它提供了原生异步API支持

版本兼容性说明

这个问题在5.x版本中不明显，但在6.x版本中会显现，主要是因为：

1. 6.x版本改进了序列化机制，增加了更严格的校验
2. 内部缓冲区管理更加精确，能更早发现线程安全问题
3. 错误报告机制更加完善，以前可能被忽略的问题现在会被明确报告

结论

RabbitMQ.Client库的线程安全模型要求开发者明确区分IConnection和IModel的使用方式。通过遵循每个线程使用独立IModel实例的原则，可以避免"Serialized to wrong size"这类序列化异常。对于高性能场景，可以考虑使用连接池和模型池来平衡资源创建开销和线程安全性。