一个完善的消息中间件,监控是必不可少的功能。通过监控我们可以查看系统的运行情况,是否出现异常,是系统稳定性和运维的...[作者空间]
我们都知道RocketMQ的消息是持久化到文件的,具体的消息的刷盘策略是什么,是发送一条消息就直接持久化到文件中吗...[作者空间]
RocketMQ为了保证消息被消费采用ACK确认机制,消费者消费消息时需要给Broker反馈消息消费的情况,成功或...[作者空间]
前面几节我们讲解的都是RocketMQ应用层面也有一些关于源码的分析讲解,消息的存储只是简单的分析没有深入的探讨其...[作者空间]
RocketMQ作为一款优秀的中间件,应用领域非常广泛,金融、电商、电信、医疗、社科、安保等不同的领域都有其大规模...[作者空间]
RocketMQ作为一款优秀的分布式消息中间件,分布式系统的一个很重要的特点就是要保证系统的高可用(HA),Roc...[作者空间]
在微服务架构中,随着服务的逐步拆分,数据库私有已经成为共识,这也导致所面临的分布式事务问题成为微服务落地过程中一个...[作者空间]
消息过滤包括基于表达式过滤与基于类模式两种过滤模式。其中表达式过滤又分为TAG和SQL92模式,分别介绍各自的过滤...[作者空间]
RocketMQ存储路径默认是${ROCKRTMQ_HOME}/store,主要存储消息、主题对应的消息队列的索引...[作者空间]
延时消息即消息发送后并不立即对消费者可见,而是在用户指定的时间投递给消费者。比如我们现在发送一条延时30秒的消息,...[作者空间]
消费者客户端有两种方式从消息中间件获取消息并消费。严格意义上来讲,RocketMQ并没有实现PUSH模式,而是对拉...[作者空间]
RocketMQ创建消费者的时指定了Topic主题及Tag,我们发现新创建的消费者消费不了历史的数据,只能消费掉创...[作者空间]
RocketMQ提供两种消费策略CLUSTERING集群消费(默认)和BROADCASTING广播消费,在创建Co...[作者空间]
我们知道消息队列的特性导致其消息不是顺序进行消费的,RocketMQ没有提供所谓的顺序消息来供我们使用,但是有时候...[作者空间]
准备 操作系统:CentOS-6.9-x86_64-bin-DVD1.iso 依赖环境:gcc 4.4.7.rar...[作者空间]
本章简单讲讲RocketMQ的入门操作,消息发送和消息接收。 引入 rocketmq-client 编写Produ...[作者空间]
一、简介 RocketMQ是阿里开源的一款分布式消息中间件,满足线上海量消息堆积的需求, 在2016年底捐赠给Ap...[作者空间]