laomao , Life is like a play

RocketMQ中Topic、Tag使用及消息过滤(八)

概念1、Topic:消息主题,通过 Topic 对不同的业务消息进行分类。2、Tag:消息标签,二级分类,用来进一步区分某个 Topic 下的消息分类,RocketMQ 允许消费者按照 Tag 对消息进行过滤,确保消费者最终只消费到他关注的消息类型。Topic 与 Tag ...

默认分类 0 评

RocketMQ顺序、延迟、等消息发送样例(三)

如果要保证顺序消费,那么他的核心店就是 生产者有序存储、消费者有序消费顺序消息概念什么是无序消息无需消息也就是普通的消息,Producer只管发送消息,Consumer 只管接收消息,至于消息和消息之间的顺序并没有保证,也无所谓先后顺序什么是全局顺序对于指定的一个Topic...

默认分类 0 评

RocketMQ发送消息的三种方式(六)

多种消息发送模式对比SYNC:同步同步发送是指消息发送方发出数据后,会在收到接收方发回响应之后才发下一个数据包的通讯方式。应用场景:重要通知邮件、报名短信通知、营销短信系统等ASYNC:异步异步发送是指发送方发出数据后,不等接收方发回响应,接着发送下个数据包的通讯方式。 消...

默认分类 0 评

RocketMQ消息重试机制(五)

由于MQ经常处于复杂的分布式系统中,考虑网络波动、服务宕机、程序异常因素,很有可能出现消息发送或者消费失败的问题。因此,消息的重试就是所有MQ中间件必须考虑到的一个关键点。如果没有消息重试,就可能产生消息丢失的问题,可能对系统产生很大的影响。所以,秉承宁可多发消息,也不可丢...

默认分类 0 评