RocketMQ核心概念(翻译)
根据上面的模型,我们可以深挖关于消息系统设计的一些主题: 消费组并发性 消费者热点问题 消费者负载均衡 消息路由 连接多路复用 金丝雀部署 生产者 生产者将业务应用产生的消息发送到broker。生产者提供多种发送模式:同步,异步和单向。 生产者群组 相同角色的多个生产者组合在一起。如果原始生产者事物之后崩溃,broker联系同一生产者组内的不同生产者实例提交或回滚事务。 注意 考虑到提供的生产者在发送消息方面足够强大,每个生产者组只允许一个生产者实例,以避免多余的生产者实例初始化。 消费者 消费者从brokers拉去消息和将它们给应用。从用户应用角度,提供了两种消费者: pull消费者 pull消费者主动从broker获取消息。一旦批量的消息被取回,用户应用开始消费处理。 push消费者 另一方面,push消费组封装消息拉取,消费进度和维护其他内部工作,为最终用户留下回调接口,实现在消息到达时执行。 消费者群组 类似前面提到的生产者群组,同样角色的消费者组合在一起称为消费者群组。 消费者群组是一个很好的概念,在消息消费方面,达到负载均衡和容错是很容易的。 注意 消费者群组的消费者必须拥...