天翼云分布式消息服务RocketMQ消费者实例的创建和销毁

分布式消息服务RocketMQ

简介/价格/文档

天翼云分布式消息服务RocketMQ消费者实例的创建和销毁

文档简介：

使用CTGFactory进行创建实例【强制规范】； Consumer是重量级的实例，每次创建、销毁都会消耗系统资源，建议系统启动的时候创建，系统退出的时候关闭，禁止每次消费消息都创建新的实例【强制规范】。

*产品来源：中国电信天翼云。免费试用咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！微信咨询

免费试用、价格特惠

文档详情

使用CTGFactory进行创建实例【强制规范】；
Consumer是重量级的实例，每次创建、销毁都会消耗系统资源，建议系统启动的时候创建，系统退出的时候关闭，禁止每次消费消息都创建新的实例【强制规范】。

相似文档

天翼云分布式消息服务RocketMQ消费者多消费组消费
一个Topic，可以使用多个消费组消费消息，每个消费组将在服务端独立保存进度。集群消费意味着多个消费者均衡消费Topic的消息，由于经常不同的程序由多个开发者进行研发和调试，如果使用同一个消费组，在调试过程中存在被其他程序消费者消费的可能，因此应该尽量避免多种类型的应用程序使用同一个消费组。
天翼云分布式消息服务RocketMQ消费者消费位置设置
管理员可以通过《运维管理命令手册.docx》，重置消费进度，使用注意事项如下：消费重置时间是指：消息的生产时间，而不是消息的消费时间。 resetOffsetByTimeOffline 客户端必须离线，重置后启动。 resetOffsetToLatest 客户端必须离线，重置后启动,重置到最新。
天翼云分布式消息服务RocketMQ消费者堆积量
不建议高堆积量的消费，为了预防出现高堆积的情况，建议：边生产边消费，如果消费速度跟不上，增加消费者。消费者一直在线，不要等生产了一段时间再开启消费者，这样会造成消费的堆积。
天翼云分布式消息服务RocketMQ topic、queue的规划
在RocketMQ中，队列数直接影响到消费者实例数的上限，同一消费组消费者实例数的上限=队列数，需要集群消费的情况，需考虑队列数的设置。在RocketMQ中，队列能分布到不同的Broker上，是RocketMQ分布式的基础。
天翼云分布式消息服务RocketMQ Java客户端Pull和Push的选择
Java客户端必须使用Push Consumer （1）使用Pull可以实现的所有场景，均可使用Push实现，并且更简单。（2）Push其实是长轮询的Pull（依然是由客户端发起），在客户端通过配置参数是可以实现流控的，并不会出现服务端的流量压垮客户端的情况。

文档中心

全民上云·上云补贴申领

免费试用（限企业）