RocketMQ

Posted 2020-11-20 lijinshan950823

Producer

• Producer：生产者，一个生产者发送业务应用系统生成的数据给Brokers（经纪人）。RocketMQ提供多范式发送：同步，异步，一站式。
• Producer Group:生产者组，是将同样角色生产者的分组在一起。同一生产组的不同生产者实例都会被Broker经纪人联络告知提交或者回滚事务，以避免事务后源生产者崩溃。
  注:考虑到提供的生产者在发送消息时足够给力时，一个生产者组仅允许一个生产者实例，以避免不必要的生产者实例初始化。

Consumer

• Consumer：消费者，从Brokers经纪人处拉取信息并填充到应用中。从用户应用的角度看，有两种类型的消费者：
  • PullConsumer：主动从brokers经纪人处拉取消息。一旦拉取到批量的数据，用户应用的消费进程初始化。
  • PushConsumer：封装消息拉取、消费进程和内部其他工作维护，留下一个回调接口让用户实现，当消息到达时即可执行用户实现逻辑。
• Consumer Group：消费组，同前面提到的生产者组类似，把同样角色的消费乾分组到一起即消费者组。消费者组是实现负载均衡目标和容错目标的一个重要概念。就信息消费而言，超级easy。
  注：一个消费组的所有消费者实例必须拥有相同的topic主题描述。