MQ底层类MQClientInstance和ProcessQueue分析


本篇内容介绍了“MQ底层类MQClientInstance和ProcessQueue分析”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!DefaultMQProducerImpl 、DefaultMQPul 香港云主机lConsumerImpl、DefaultMQPushConsumerImpl 三个对象的成员变量都包含 同一个成员对象:MQClientInstance功能如下:MQClientInstance 负责与NameServer 通信进行心跳维持、根据Topic获取Broker地址;MQClientInstance负责与Broker通信进行收发消息、ReBalance;普通情况下,一个用到RocketMQ的生产端或者消费端,或者说一个JVM进程只要有一个MQClientInstance实例就够了.如果不手动通过setInstanceName设置,这个时候创建的一个或者多个Consumer或者Producer底层使用的都是同一个MQClientInstance实例(默认名字是”DEFAULT”).但是有些情况下只有一个MQClientInstance对象是不够的,比如一个Java程序需要连接两个MQ集群的,从一个集群消费,发送到另外一个集群,一个MQClientInstance对象则无法支持这种场景,此时一定要手动指定不同的InstanceName,底层就会创建两个MQClientInstance对象。ClientId的生成规则:如果同一台机器上有多个服务集成了MQ的客户端,进程ID路径:org.apache.rocketmq.client.impl.consumer“MQ底层类MQClientInstance和ProcessQueue分析”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注开发云网站,小编将为大家输出更多高质量的实用文章!

相关推荐: es在数据量很大的情况下如何提高查询效率

本篇内容主要讲解“es在数据量很大的情况下如何提高查询效率”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“es在数据量很大的情况下如何提高查询效率”吧!es 在数据量很大的情况下(数十亿级别)如何提高查询效率这个问题…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 08/14 19:48
下一篇 08/14 19:48

相关推荐