rocketMQ的消息介绍、发送方式和消费方式

时间:2025-03-12 08:59:17

rocketMQ中消息有以下几种

  • 普通消息:消息队列中没有特性的消息
  • 顺序消息:严格按照顺序发布和消费的消息,先发布的消息一定会先被消费,可以分为
    • 全局顺序消息:所有消息严格按照先入先出的顺序来发布和消费
    • 分区顺序消息:消息根据sharding key进行区块分区,同一分区的消息严格按照先入先出的顺序进行发布和消费
  • 定时消息:发送消息时可以不立即投递,而是指定一个将来的时间点进行投递
  • 延时消息:发送消息时可以不立即投递,而是指定一个延迟时间段后才进行投递
  • 事务消息:提供分布式事务功能、达到分布式事务的最终一致性
    • 半事务消息:已发送到消息服务端,但是未收到发送方提交或回滚确认的消息,状态是“暂不能投递”,不会被投递给消费者。
    • 消息回查:消息服务端扫描发现某消息长时间处于“半事务消息”状态时,主动向消息发送者查询消息最终状态的过程

一、消息发送方式

小修发送方式有三种

  1. 同步发送
  2. 异步发送
  3. 单向发送

1.1 同步发送

原理:同步发送是指消息发送方发出一条消息后,会在收到服务端同步响应之后才发下一条消息的通讯方式。
应用场景:此种方式应用场景非常广泛,例如重要通知邮件、报名短信通知、营销短信系统等。

1.2 异步发送

原理
异步发送是指发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。发送消息时需要实现异步发送回调接口(SendCallback)。消息发送方在发送了一条消息后,不需要等待服务端响应即可发送第二条消息。发送方通过回调接口接收服务端响应,并处理响应结果。
应用场景
异步发送一般用于链路耗时较长,对响应时间较为敏感的业务场景,例如,您视频上传后通知启动转码服务,转码完成后通知推送转码结果等。

1.3 单向发送

原理
发送方只负责发送消息,不等待服务端返回响应且没有回调函数触发,即只发送请求不等待应答。此方式发送消息的过程耗时非常短,一般在微秒级别。
应用场景
适用于某些耗时非常短,但对可靠性要求并不高的场景,例如日志收集。

1.4 三种发送方式对比

发送方式 发送TPS 发送结果反馈 可靠性
同步发送 不丢失
异步发送 不丢失
单向发送 最快 可能丢失

1.5 不同消息适用的发送方式

顺序消息必须保证按照顺序发送,所以只能使用同步发送。

消息类型 是否支持可靠的同步发送 是否支持可靠的异步发送 是否支持单向发送
无序消息(普通、事务、定时、延时)
分区顺序消息
全局顺序消息

二、消息对比

顺序消息必须保证按照顺序发送和消费,所以不支持定时、延时、事务。

消息类型 是否支持事务消息 是否支持定时和延时消息 性能
无序消息(普通、事务、定时、延时) 最高
分区顺序消息
全局顺序消息 一般

三、消费模式

  • 集群消费:任何一条消息只需要被消费者集群中任意一个消费者处理
  • 广播消费:每条消息被推送给消费者集群中的所有注册消费者,保证消息被每个消费者至少消费一次
消息类型 是否支持顺序消息 消费进度维护处
集群消费 服务端维护
广播消费 客户端维护

以上

相关文章