如何将消息发布到具有高tps的rabbitmq,多线程

Question

由于channel不是线程安全的，所以我可以在发布之前同步channel实例，或者每次需要时创建一个channel并关闭它。

但在我看来，由于锁定或创建和破坏通道的代价，这两种方法都没有很好的性能。

Answer 1

所以，第一件事。通道不是连接。在RabbitMQ中，通道与应用程序会话是一样的，而连接表示与服务器的底层TCP会话。这个答案很好地解释了其中的一些问题。

TCP会话的创建成本很高，因此它们的生存期往往在任何特定工作线程的生存期之外。创建通道非常便宜--服务器所做的只是为您的通道标识符分配一个整数，您就有了一个新的通道。

RabbitMQ上的大多数操作在失败时会关闭通道。这样做是因为这样做没有实际后果。如果他们关闭了底层连接，那会给应用程序带来很多问题。

消费者的寿命与渠道有关。当通道关闭时，连接的使用者也会关闭。将您的使用者对象（工作线程）设计成能够在发生这种情况时获得连接并创建新通道，然后重新订阅它们自己。

避免跨线程共享通道。一个线程=一个通道。

虽然我对Java客户机没有任何特别的经验，但我不认为锁应该是必要的，而且我当然希望实现不会做一些使通道不是轻量级的事情。

关于Java客户机，我认为您可以假设通道操作（读和写等）不是线程安全的，这就是为什么您希望坚持一个线程/一个通道范例的原因。我认为您可以假设创建通道（一个连接操作）是线程安全的。