本节详细介绍了索引管理相关的API，主要包括Index Create、Delete Index、Get index、indices Exists Index、Open/Close Index 、Shrink Index、Split Index、Rollover Index,特别详细介绍了索引的动态扩容与收缩机制。

本节目录1、集群限流使用场景2、集群限流与单机限流的异同思考3、探究集群限流实现原理3.1 ClusterBuilderSlot 详解3.2 集群限流模式实现原理3.2.1 DefaultClusterTokenClient 详解3.2.2 DefaultTokenService 详解4、总结1、集群限流使用场景首先一个服务有三个服务提供者，但这三台集群的硬件配置不一样，如图所示：为了充分...

以源码为手段一步一步探究 Alibaba Sentienl 滑动窗口的实现原理，同时也是监控指标采集常用设计方法，如果对源码不感兴趣，可以直接跳文末，用一张图揭示了滑动窗口的工作原理。源码分析sentienl 专栏第三篇。

   我们以一个订单流转流程来举例，例如订单子系统创建订单，需要将订单数据下发到其他子系统（与第三方系统对接）这个场景，我们通常会将两个系统进行解耦，不直接使用服务调用的方式进行交互。其业务实现步骤通常为：   1、A系统创建订单并入库。   2、发送消息到MQ。   3、MQ消费者消费消息，发送远程RPC服务调用，完成订单数据的同步。   1、方案一   方案弊端： ...

   上节已经梳理了RocketMQ发送事务消息的流程（基于二阶段提交），本节将继续深入学习事务状态消息回查，我们知道，第一次提交到消息服务器，消息的主题被替换为RMQ_SYS_TRANS_HALF_TOPIC，当执行本地事务，如果返回本地事务状态为UN_KNOW时，第二次提交到服务器时将不会做任何操作，也就是消息还存在与RMQ_SYS_TRANS_HALF_TOPIC主题中，并不能被消息消费者消

为了充分揭示mycat读写分离、写节点挂掉后的自主切换、路由解析等原理，先搭建mycat测试环境，架构如下：1、源码安装 mysql安装Linux编译等基础软件yum -y install gcc gcc-c++ ncurses-devel pcre pcre-devel openssl openssl-devel安装cmakecmake安装包下载地址：http...

本文详细介绍如何使用流收集API(collect)方法对数据进行收集，详细介绍了toList、toSet、toCollection、joining、groupBy(多级分组)的实现原理与详细示例。

pulsar中文文档、消息发送、消息整体架构

1、Reactor反应堆设计模式1.1 单线程模型单线程模型Reactor(此图来源与网络)下面以java nio为基础，实现Reactor模型。Nio服务端代码：package threadmode.r1;import java.io.IOException;import java.net.InetSocketA...

HA主从同步的核心类图如图所示：1、初始RocketMQ HAHAService：主从同步核心实现类。1）AtomicInteger connectionCount：Master维护的连接数。（Slave的个数）。2）List connectionList：具体连接信息。3）AcceptSocketService acceptSocketService：服务端接收连接线程实...