1、消息压缩:能将较大的消息进行压缩后发送到服务端,有效利用带宽,可通过设置CompressMsgBodyOverHowMuch,超过该值会对消息体进行压缩。
2、消息过滤:一个应用入奚戢瘟尽可能用一个 Topic,消息子类型用 tags 来标识,tags 可以由应用自由设置。只有収送消息设置了tags,消费方在订阅消息时,才可以利用 tags 在 brok髫潋啜缅er 做消息过滤。
3、延迟消息:设计消费时延,消息发送到服务端后,过了预设的时间后才可以被消费者消费。消费位置设置:能设置消费者首次启动的消费位置:1. 队列头;2.队列尾;3.由客户端指定。
4、事务消息:消息发送后,根据预设的事务进行判断,满足事务的消息将会被确认,不满足的事务的消息不会被服务端接收。
5、消息回溯:能够回溯消费进度,将订阅组在某topic上的消费进度重置到过去或者未来,重置的时间点为目标消息的落盘时间。
6、大包体消息:能在服务端配置和调整接收消息的最大包体大小,能在生产者客户端配置发送消息的最大包体大小。
7、消息标签:每个消息在业务局面的唯一标识码,要设置到 keys字段,方便将来定位消息丢失问题。服务器会为每个消息创建索引(哈希索引),应用可以通过 topic key来查询返回消息内容,以及消息被谁消费。