我正在编写一个简单的类，我的应用程序将使用RabbitMQ发送和接收消息 . 我已经阅读了尽可能多的How-Tos，博客文章，白皮书以及关于RabbitMQ的喜欢 . 大多数示例显示使用包含在using块中的连接和通道，并且通过说您应该将它们实现为单例来抵销它 . 特别是关于 Channels ，我看到评论说你不应该同时使用单个 Channels 的多个线程 .
我正在用c＃编写我的库 . 它是在第一次实例化时连接静态连接的单例 .
我想为 Channels 做同样的事情，但我打算使用相同的库来允许发布/订阅多个交换/队列 . 发布和订阅都可以从多个线程完成 .
最后我的问题是：我应该如何实现 Channels 创作？每条消息？让每个消费者拥有一个独特的私人 Channels ，发布商同步访问一个独特的 Channels 吗？你 grab 了我的漂移 . 请记住，我打算使用单个服务器，有几十个消费者/发布者，而不是更多 .
谢谢！
4 回答
编辑（2016-1-26）： Channels are NOT thread safe . 关于它的文档在April和May 2015之间发生了变化 . 新文本：
从您的问题来看，听起来您没有预定义的，固定数量的线程，主要发布/订阅RabbitMQ（在这种情况下，您可以考虑创建一个通道作为线程初始化的一部分，或使用
ThreadLocal<IModel>） .如果并发RabbitMQ操作很少或消息大小总是很小，那么您可能只需在所有RabbitMQ发布/子操作周围放置一个
lock(channel)即可 . 如果你需要以交错的方式传输多个请求 - 这就是首先使用的通道 - 使用任意线程，你可能想要创建一个 channel pool ，例如aConcurrentQueue<IModel>您将未使用的 Channels 排队并在您需要的时间内出列队列 . Channel creation is very low-overhead ，我从性能测试中感觉到，通道创建过程不涉及任何网络io，即似乎在客户端首次使用时，RabbitMQ服务器中会自动创建一个通道 .OLD （2016-1-26之前）：Java和.net实现现在几乎已经过时的细节：
Re：通道和多个线程，由于它依赖于实现，这有点令人困惑 .
Java implementation ：Channels are thread safe：
But：
在多个线程之间共享通道时，无法正确处理确认
.net implementation ：Channels are not thread safe：
所以除了Robin 's useful answer, which applies regardless of whether it' s线程安全与否， in the .net implementation, you can't just share a connection .
它阐明了aqmp的内部结构 . 目前，我的理解是：A . 我可以从每个应用程序（作为静态共享资源）保持与服务器的单个共享tcp连接B.我应该为每个“任务”创建一个通道（一个用于侦听队列X和一个用于发布以交换Y等，假设这些“任务”可以并行执行）C . 或者我可以在单个应用程序中使用一个通道用于所有内容，同时确保对它的访问是同步的 - 使用一些锁定机制，假设使用（锁定）通道的实际时间 Span 相对非常短 .
谢谢 .
我无法评论C＃实现的细节，但可能有助于知道Amqp通道旨在共享单个TCP连接，即启用多路复用 . 单个通道一次只能发送一个或接收一个消息，但是连接可以同时在不同的通道上接收消息 . 图片你有2个大的1GB文件，你发送对于单个消费者来说，消息可能会被分成10K块并以交错方式发送 . 您可以在设置连接时操纵默认的Amqp消息大小，这与您是否以及何时可能会遇到交错有关; AFAIK此功能旨在帮助防止多个消费者共享连接且一个消费者收到大量消息时的饥饿 .
HTH .
你是正确的，Channel不是线程安全的，不应该由多个线程访问 .
如果您计划使用不同的队列，则可以使用单个通道拥有多个队列 . 但是如果您计划进行多个交换（不确定为什么在这里需要更多的交换），您将被迫跟踪单个中的多个交换和通道，或将该责任转移给调用者 .
我会构建你的单例，例如它有一个观察者模式，并在那里保存所有RabbitMQ的东西，并引用你的调用者 . 然后，您还需要对单个线程的调用进行编组处理，否则您可能会冒险使用通道对象 .