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

創(chuàng)新互聯(lián)專注于網(wǎng)站建設，為客戶提供網(wǎng)站設計制作、做網(wǎng)站、網(wǎng)頁設計開發(fā)服務，多年建網(wǎng)站服務經(jīng)驗，各類網(wǎng)站都可以開發(fā)，高端網(wǎng)站設計，公司官網(wǎng)，公司展示網(wǎng)站，網(wǎng)站設計，建網(wǎng)站費用，建網(wǎng)站多少錢，價格優(yōu)惠，收費合理。

基石MQClientInstance

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

private MQClientInstance mQClientFactory;

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

MQClientInstance功能如下：

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

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

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

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

public class MQClientManager {
  
    private static MQClientManager instance = new MQClientManager();
    private AtomicInteger factoryIndexGenerator = new AtomicInteger();
    private ConcurrentMap factoryTable =
        new ConcurrentHashMap();

ClientId的生成規(guī)則：

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

MessageQueue在client端的快照類ProcessQueue

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

“MQ底層類MQClientInstance和ProcessQueue分析”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質量的實用文章！