RocketMQ基础

发布时间 2023-04-20 10:29:29作者: 李安歌

生产者

基本概念

发送消息(Message)主要包括topic、tag、properties和transactionId

普通消息发送

RocketMQ发送信息的方式有三种,同步、异步和单向传输。前两种方式是可靠性传输,单向传输是只负责发送,不管服务端是否接收和保存成功,该方式适合对消息可靠性要求不高的场景,如日志

顺序消息发送

延时消息发送

事务消息发送

消费者

基本概念

消息通过生产者发送到某一个Topic,如果需要订阅该Topic并消费里面的消息的话,就要创建对应的消费者进行消费。其中会涉及到消费组、消费位点、推和拉等概念

消费模式

RocketMQ消费模式有两种,分别是集群模式和广播模式

  • 集群模式:当使用集群消费模式时,RocketMQ 认为任意一条消息只需要被消费组内的任意一个消费者处理即可(有消息消费失败重试机制)
  • 广播模式:当使用广播消费模式时,RocketMQ 会将每条消息推送给消费组所有的消费者,保证消息至少被每个消费者消费一次
    消费方式
  • 并发消费:
  • 顺序消费: