RocketMQ简介及配置
一、简介
二、安装配置
一、简介
RocketMQ为阿里的开源消息中间件，第一代的 Notify 主要使用了推模型，解决了事务消息；第二代的 MetaQ 主要使用了拉模型，解决了顺序消息和海量堆积的问题。 RocketMQ 基于长轮...
rocketmq流程
rocketmq特性(features)
# 特性(features)
1 订阅与发布
消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。
2 消息顺序
消息有序指的是一类消息消费时，...
RocketMQ普通消息实战演练详解
目录引言普通消息同步发送普通消息异步发送普通消息单向发送集群消费模式广播消费模式引言
之前研究了RocketMQ的源码，在这里将各种消息发送与消费的demo进行举例，方便以后使用的时候CV。
相关的配置，安装和启动在这篇文章有相关讲解ht...
RocketMQ详解（三）启动运行原理
专题目录
RocketMQ详解（一）原理概览
RocketMQ详解（二）安装使用详解
RocketMQ详解（三）启动运行原理
RocketMQ详解（四）核心设计原理
RocketMQ详解（五）总结提高
引子
明白一个项目启动时做了什么，...
RocketMQ(三) - RemotingServer服务端启动 源码分析
RocketMQ(三) - RemotingServer服务端启动 源码分析
接着 《 RocketMQ(一) - NameServer 启动源码分析 》 文章最后留下的 RemotingServer网络层服务端启动 来进行分析。...
RocketMQ 消费者(三) - Consumer端拉消息 (图解)
RocketMQ 消费者(三) - Consumer端拉消息 (图解)
1. 拉消息服务
与负载均衡服务一样， 消费者端拉消息的入口在 客户端实例中，为 PullMessageService 。
内部有几个关键点：
其内部维护了...
RocketMQ消息过滤与查询的实现
消息过滤
RocketMQ分布式消息队列的消息过滤方式有别于其它MQ中间件，是在Consumer端订阅消息时再做消息过滤的。
RocketMQ这么做是还是在于其Producer端写入消息和Consomer端订阅消息采用分离存储的机制来实现...
RocketMQ-延迟消息的处理流程介绍
概述
RocketMQ 支持发送延迟消息，但不支持任意时间的延迟消息的设置，仅支持内置预设值的延迟时间间隔的延迟消息；
预设值的延迟时间间隔为：
1s、 5s、 10s、 30s、 1m、 2m、 3m、 4m、 5m、 6m、 7m、...
RocketMQ原理分析场景问题
硬核干货分享，欢迎关注【Java补习课】成长的路上，我们一起前行 !
《高可用系列文章》 已收录在专栏，欢迎关注！
一、RocketMQ的基本原理
RocketMQ基本架构图如下
从这个架构图上我们可以知道，RocketMQ有4块核...
RocketMQ设计之主从复制和读写分离
目录一、主从复制二、读写分离一、主从复制
RocketMQ为了提高消费的高可用性，避免Broker发生单点故障引起Broker上的消息无法及时消费，同时避免单个机器上硬盘坏损出现消费数据丢失。
RocketMQ采用Broker数据主从复制...