消息中间件—RocketMQ消息消费(二)(push模式实现)

摘要:在RocketMQ中,消息消费都是基于Pull消息方式,那么Push模式中又是如何实现Consumer端准实时消费的呢? 在上一篇—“消息中间件—RocketMQ消息消费(一)”中,已经简要地介绍了下Roc...

癫狂侠
2018/08/16
0
0
RocketMQ源码之Message的生命周期

RocketMQ作为一个消息中间件,大部分业务逻辑都在对Message进行传递和处理,我们以Message的生命周期为切入点,来探一探它的运行原理,从RocketMQ的架构图我们可以大致分析出Message的运动轨...

激情的狼王
2018/05/04
0
0
使用 RocketMQ 实现延时消息

一. 延时消息 延时消息是指消息被发送以后,并不想让消费者立即拿到消息,而是等待指定时间后,消费者才拿到这个消息进行消费。 使用延时消息的典型场景,例如: 在电商系统中,用户下完订单...

fengzhizi715
07/01
0
0
消息中间件 RocketMQ源码解析:Message拉取&消费(上)

摘要: 原创出处 http://www.iocoder.cn/RocketMQ/message-pull-and-consume-first/ 「芋道源码」欢迎转载,保留摘要,谢谢! 本文主要基于 RocketMQ 4.0.x 正式版 1、概述 2、ConsumeQueue ...

芋道源码
2017/05/09
0
0
[RocketMQ]消息中间件—RocketMQ消息消费(三)(消息消费重试)

摘要:如果Consumer端消费消息失败,那么RocketMQ是如何对失败的异常情况进行处理? 前面两篇RocketMQ消息消费(一)/(二)篇,主要从Push/Pull两种消费模式的简要流程、长轮询机制和Consu...

morpheusWB
2018/09/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多