RabbitMQ多線程消費消息

背景 最近在改造一個IM系統後臺,用到RabbitMQ。在處理消費線程的時候遇到點小麻煩,網上彷佛也不多有提到如何多線程處理消息,因此記錄一下。java 業務場景 模塊A向消息隊列發送消息,模塊B消費其中的消息,由於處理每條消息耗時略有不一樣,因此但願B能多線程處理。其中模塊B創建20個Connection到MQ Broker,而且每一個Connection建立一個Channel,用於消費消息。多
相關文章
相關標籤/搜索