生产者
基本概念
发送消息(Message)主要包括topic、tag、properties和transactionId
普通消息发送
RocketMQ发送信息的方式有三种,同步、异步和单向传输。前两种方式是可靠性传输,单向传输是只负责发送,不管服务端是否接收和保存成功,该方式适合对消息可靠性要求不高的场景,如日志
顺序消息发送
延时消息发送
事务消息发送
消费者
基本概念
消息通过生产者发送到某一个Topic,如果需要订阅该Topic并消费里面的消息的话,就要创建对应的消费者进行消费。其中会涉及到消费组、消费位点、推和拉等概念
消费模式
RocketMQ消费模式有两种,分别是集群模式和广播模式
- 集群模式:当使用集群消费模式时,RocketMQ 认为任意一条消息只需要被消费组内的任意一个消费者处理即可(有消息消费失败重试机制)
- 广播模式:当使用广播消费模式时,RocketMQ 会将每条消息推送给消费组所有的消费者,保证消息至少被每个消费者消费一次
消费方式 - 并发消费:
- 顺序消费: