一个完善的消息中间件，监控是必不可少的功能。通过监控我们可以查看系统的运行情况，是否出现异常，是系统稳定性和运维的基础。 1、监控平台搭建 下载地址：https://gith...
发简信
IP属地：青海
一个完善的消息中间件，监控是必不可少的功能。通过监控我们可以查看系统的运行情况，是否出现异常，是系统稳定性和运维的基础。 1、监控平台搭建 下载地址：https://gith...
我们都知道RocketMQ的消息是持久化到文件的，具体的消息的刷盘策略是什么，是发送一条消息就直接持久化到文件中吗？作为一款高性能的消息中间件这样做肯定不行，至少性能上不允许...
RocketMQ为了保证消息被消费采用ACK确认机制，消费者消费消息时需要给Broker反馈消息消费的情况，成功或失败，对于失败的消息会根据内部算法一段时间后重新消费。会一直...
前面几节我们讲解的都是RocketMQ应用层面也有一些关于源码的分析讲解，消息的存储只是简单的分析没有深入的探讨其中的内部机制，我们都知道RocketMQ是基于文件存储的消息...
RocketMQ作为一款优秀的中间件，应用领域非常广泛，金融、电商、电信、医疗、社科、安保等不同的领域都有其大规模的应用，无疑安全性很受质疑，因为内部没有安全相关的业务模块，...
RocketMQ作为一款优秀的分布式消息中间件，分布式系统的一个很重要的特点就是要保证系统的高可用(HA)，RocketMQ则是通过主从同步机制保证系统的高可用。 1、概述 ...
在微服务架构中，随着服务的逐步拆分，数据库私有已经成为共识，这也导致所面临的分布式事务问题成为微服务落地过程中一个非常难以逾越的障碍，但是目前尚没有一个完整通用的解决方案。为...
消息过滤包括基于表达式过滤与基于类模式两种过滤模式。其中表达式过滤又分为TAG和SQL92模式，分别介绍各自的过滤机制，及代码示例内容，深入探消息过滤的原理。 1、TAG模式...
RocketMQ存储路径默认是${ROCKRTMQ_HOME}/store,主要存储消息、主题对应的消息队列的索引等。 1、概述 查看其目录文件 commitlog:消息的存...
延时消息即消息发送后并不立即对消费者可见，而是在用户指定的时间投递给消费者。比如我们现在发送一条延时30秒的消息，消息发送后立即发送给服务器，但是服务器在30秒后才将该消息交...
消费者客户端有两种方式从消息中间件获取消息并消费。严格意义上来讲，RocketMQ并没有实现PUSH模式，而是对拉模式进行一层包装，名字虽然是 Push 开头，实际在实现时，...
RocketMQ创建消费者的时指定了Topic主题及Tag,我们发现新创建的消费者消费不了历史的数据，只能消费掉创建以后消费者发送的数据。这是什么原因，我们能把所有的消息都消...
RocketMQ提供两种消费策略CLUSTERING集群消费(默认)和BROADCASTING广播消费，在创建Consumer消费者时可以指定消费策略，策略不同其内部机制也不...
我们知道消息队列的特性导致其消息不是顺序进行消费的，RocketMQ没有提供所谓的顺序消息来供我们使用，但是有时候一些场景需要需要顺序的去接收消息。今天我们重点讨论一下如何实...
准备 操作系统：CentOS-6.9-x86_64-bin-DVD1.iso 依赖环境：gcc 4.4.7.rar、jdk-8u121-linux-x64.tar.gz 安装...
本章简单讲讲RocketMQ的入门操作，消息发送和消息接收。 引入 rocketmq-client 编写Producer 查看结果 编写Consumer 查看结果 看到消费的...
一、简介 RocketMQ是阿里开源的一款分布式消息中间件，满足线上海量消息堆积的需求， 在2016年底捐赠给Apache开源基金会成为孵化项目，2017年正式成为了Apac...
以前养成的一个习惯，只要是喜欢的句子都会找一个特定的本子记下来，但觉得自己的字着实难看，无法写出那些句子的灵魂，渐渐的，也偷了个懒，存到了备忘录或者用说说记录。 以下是我无聊...
