300字范文,内容丰富有趣,生活中的好帮手!
300字范文 > rocketMQ的消息介绍 发送方式和消费方式

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

时间:2023-07-31 21:10:21

相关推荐

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

rocketMQ中消息有以下几种

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

一、消息发送方式

小修发送方式有三种

同步发送异步发送单向发送

1.1 同步发送

原理:同步发送是指消息发送方发出一条消息后,会在收到服务端同步响应之后才发下一条消息的通讯方式。

应用场景:此种方式应用场景非常广泛,例如重要通知邮件、报名短信通知、营销短信系统等。

1.2 异步发送

原理

异步发送是指发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。发送消息时需要实现异步发送回调接口(SendCallback)。消息发送方在发送了一条消息后,不需要等待服务端响应即可发送第二条消息。发送方通过回调接口接收服务端响应,并处理响应结果。

应用场景

异步发送一般用于链路耗时较长,对响应时间较为敏感的业务场景,例如,您视频上传后通知启动转码服务,转码完成后通知推送转码结果等。

1.3 单向发送

原理

发送方只负责发送消息,不等待服务端返回响应且没有回调函数触发,即只发送请求不等待应答。此方式发送消息的过程耗时非常短,一般在微秒级别。

应用场景

适用于某些耗时非常短,但对可靠性要求并不高的场景,例如日志收集。

1.4 三种发送方式对比

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

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

二、消息对比

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

三、消费模式

集群消费:任何一条消息只需要被消费者集群中任意一个消费者处理广播消费:每条消息被推送给消费者集群中的所有注册消费者,保证消息被每个消费者至少消费一次

以上

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。