MQ底層類MQClientInstance和ProcessQueue分析

本篇內容介紹了“MQ底層類MQClientInstance和ProcessQueue分析”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

基石MQClientInstance

DefaultMQProducerImpl 、DefaultMQPullConsumerImpl、DefaultMQPushConsumerImpl  三個對象的成員變量都包含 同一個成員對象：

private MQClientInstance mQClientFactory;

this.mQClientFactory = MQClientManager.getInstance().getAndCreateMQClientInstance(this.defaultMQPushConsumer, this.rpcHook);

MQClientInstance功能如下：

• MQClientInstance 負責與NameServer 通信進行心跳維持、根據Topic獲取Broker地址；

• MQClientInstance負責與Broker通信進行收發消息、ReBalance；

普通情況下，一個用到RocketMQ的生產端或者消費端，或者說一個JVM進程只要有一個MQClientInstance實例就夠了.如果不手動通過setInstanceName設置，這個時候創建的一個或者多個Consumer或者Producer底層使用的都是同一個MQClientInstance實例(默認名字是"DEFAULT").

但是有些情況下只有一個MQClientInstance對象是不夠的,比如一個Java程序需要連接兩個MQ集群的，從一個集群消費，發送到另外一個集群，一個MQClientInstance對象則無法支持這種場景,此時一定要手動指定不同的InstanceName,底層就會創建兩個MQClientInstance對象。

public class MQClientManager {
  
    private static MQClientManager instance = new MQClientManager();
    private AtomicInteger factoryIndexGenerator = new AtomicInteger();
    private ConcurrentMap<String/* clientId */, MQClientInstance> factoryTable =
        new ConcurrentHashMap<String, MQClientInstance>();

ClientId的生成規則：

如果同一臺機器上有多個服務集成了MQ的客戶端，進程ID

MessageQueue在client端的快照類ProcessQueue

路徑：org.apache.rocketmq.client.impl.consumer

“MQ底層類MQClientInstance和ProcessQueue分析”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！