玉环网站建设,视频网站怎么做排名,唐山seo网站建设,nginx 做网站本文介绍 Apache RocketMQ 中消费者#xff08;Consumer#xff09;的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。
定义
消费者是 Apache RocketMQ 中用来接收并处理消息的运行实体。 消费者通常被集成在业务系统中#xff0c;从 Apache RocketMQ 服务…本文介绍 Apache RocketMQ 中消费者Consumer的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。
定义
消费者是 Apache RocketMQ 中用来接收并处理消息的运行实体。 消费者通常被集成在业务系统中从 Apache RocketMQ 服务端获取消息并将消息转化成业务可理解的信息供业务逻辑处理。
在消息消费端可以定义如下传输行为 消费者身份消费者必须关联一个指定的消费者分组以获取分组内统一定义的行为配置和消费状态。 消费者类型Apache RocketMQ 面向不同的开发场景提供了多样的消费者类型包括PushConsumer类型、SimpleConsumer类型、PullConsumer类型仅推荐流处理场景使用等。具体信息请参见消费者分类。 消费者本地运行配置消费者根据不同的消费者类型控制消费者客户端本地的运行配置。例如消费者客户端的线程数消费并发度等实现不同的传输效果。
模型关系
在 Apache RocketMQ 的领域模型中消费者的位置和流程如下 消息由生产者初始化并发送到Apache RocketMQ 服务端。 消息按照到达Apache RocketMQ 服务端的顺序存储到主题的指定队列中。 消费者按照指定的订阅关系从Apache RocketMQ 服务端中获取消息并消费。
内部属性
消费者分组名称 定义当前消费者关联的消费者分组名称消费者必须关联到指定的消费者分组通过消费者分组获取消费行为。更多信息请参见消费者分组ConsumerGroup。 取值消费者分组为Apache RocketMQ 的逻辑资源需要您提前通过控制台或OpenAPI创建。具体命名格式请参见使用限制。
客户端ID 定义消费者客户端的标识用于区分不同的消费者。集群内全局唯一。 取值客户端ID由Apache RocketMQ 的SDK自动生成主要用于日志查看、问题定位等运维场景不支持修改。
通信参数
接入点信息 必选 连接服务端的接入地址用于识别服务端集群。 接入点必须按格式配置建议使用域名避免使用IP地址防止节点变更无法进行热点迁移。身份认证信息 可选 客户端用于身份验证的凭证信息。 仅在服务端开启身份识别和认证时需要传输。请求超时时间 可选 客户端网络请求调用的超时时间。取值范围和默认值请参见参数限制。
预绑定订阅关系列表
定义指定消费者的订阅关系列表。 Apache RocketMQ 服务端可在消费者初始化阶段根据预绑定的订阅关系列表对目标主题进行权限及合法性校验无需等到应用启动后才能校验。
取值建议在消费者初始化阶段明确订阅关系即要订阅的主题列表若未设置或订阅的主题动态变更Apache RocketMQ 会对目标主题进行动态补充校验。
消费监听器 定义Apache RocketMQ 服务端将消息推送给消费者后消费者调用消息消费逻辑的监听器。 取值由消费者客户端本地配置。 约束使用PushConsumer类型的消费者消费消息时消费者客户端必须设置消费监听器。消费者类型的具体信息请参见消费者分类。
行为约束
在 Apache RocketMQ 领域模型中消费者的管理通过消费者分组实现同一分组内的消费者共同分摊消息进行消费。因此为了保证分组内消息的正常负载和消费
Apache RocketMQ 要求同一分组下的所有消费者以下消费行为保持一致 投递顺序 消费重试策略
版本兼容性
如行为约束中所述同一分组内所有消费者的投递顺序和消费重试策略需要保持一致。 Apache RocketMQ 服务端5.x版本上述消费者的消费行为从关联的消费者分组中统一获取因此同一分组内所有消费者的消费行为必然是一致的客户端无需关注。 Apache RocketMQ 服务端3.x/4.x历史版本上述消费逻辑由消费者客户端接口定义因此您需要自己在消费者客户端设置时保证同一分组下的消费者的消费行为一致。
若您使用 Apache RocketMQ 服务端5.x版本客户端使用历史版本SDK则消费者的消费逻辑以消费者客户端接口的设置为准。
使用建议
不建议在单一进程内创建大量消费者
Apache RocketMQ 的消费者在通信协议层面支持非阻塞传输模式网络通信效率较高并且支持多线程并发访问。因此大部分场景下单一进程内同一个消费分组只需要初始化唯一的一个消费者即可开发过程中应避免以相同的配置初始化多个消费者。
