rocketmq由生产者与消费者构成,将发送消息端,与消费端解偶,以达到业务切割与高峰消峰的目的,以双11为例,一大波消费打过来,分批消费,防止服务器卡死。
中间为消息队列,用于存储消息,由broke自动分配,当然自己也能指定,分配好后,由消息模式分发到每个q当消费时,再由q转发给消费者。
消费方式主要有顺序消费,部分顺序消费,延迟消费,过滤消息(tag过滤与sql过滤)
rocketmq由生产者与消费者构成,将发送消息端,与消费端解偶,以达到业务切割与高峰消峰的目的,以双11为例,一大波消费打过来,分批消费,防止服务器卡死。
中间为消息队列,用于存储消息,由broke自动分配,当然自己也能指定,分配好后,由消息模式分发到每个q当消费时,再由q转发给消费者。
消费方式主要有顺序消费,部分顺序消费,延迟消费,过滤消息(tag过滤与sql过滤)
本文标题:mq消费方式
本文链接:https://www.haomeiwen.com/subject/azchndtx.html
网友评论