大纲1.Guava提供的RateLimiter限流使用示例2.Guava提供的RateLimiter简介与设计3.继承RateLimiter的SmoothBursty源码4.继承RateLimiter的SmoothWarmingUp源码1.Guava提供的RateLimiter限流使用示例(1)拦截器示例(2)AOP切面示例(1)拦截器示例一.pom文件中引入Guava的依赖包 <!-- https://mvnrepository.com/artifact/com.google.guava/guava --> <dependency> <groupId>co...

大纲1.FlowSlot根据流控规则对请求进行限流2.FlowSlot实现流控规则的快速失败效果的原理3.FlowSlot实现流控规则中排队等待效果的原理4.FlowSlot实现流控规则中Warm Up效果的原理1.FlowSlot根据流控规则对请求进行限流(1)流控规则FlowRule的配置Demo(2)注册流控监听器和加载流控规则(3)FlowSlot根据流控规则对请求进行限流(1)流控规则FlowRule的配置Demo从下图可知，流控规则包含以下属性：一.规则id、资源名、针对来源这三个属性是所有规则共有的属性，会分别封装到AbstractRule的id、resource、limitAp...

大纲1.NodeSelectorSlot构建资源调用树2.LogSlot和StatisticSlot采集资源的数据3.Sentinel监听器模式的规则对象与规则管理4.AuthoritySlot控制黑白名单权限5.SystemSlot根据系统保护规则进行流控1.NodeSelectorSlot构建资源调用树(1)Entry的处理链的执行入口(2)NodeSelectorSlot的源码(3)Context对象中存储的资源调用树总结(1)Entry的处理链的执行入口每当一个线程处理包含某些资源的接口请求时，会调用SphU的entry()方法去创建并管控该接口中涉及的Entry资源访问对象。在创建E...

大纲1.Sentinel底层的核心概念2.Sentinel中Context的设计思想与源码实现3.Java SPI机制的引入4.Java SPI机制在Sentinel处理链中的应用5.Sentinel默认处理链ProcessorSlot的构建1.Sentinel底层的核心概念(1)资源和规则(2)Context(3)ProcessorSlot(4)Node(1)资源和规则一.什么是资源、规则和Entry二.使用责任链模式 + 过滤器来收集资源的调用数据三.如何设计Entry资源访问类四.如何设计Entry资源访问类的子类一.什么是资源、规则和Entry资源：可以是一个方法、一个接口或一段代码。...

大纲1.Sentinel流量治理框架简介2.Sentinel源码编译及Demo演示3.Dashboard功能介绍4.流控规则使用演示5.熔断规则使用演示6.热点规则使用演示7.授权规则使用演示8.系统规则使用演示9.集群流控使用演示1.Sentinel流量治理框架简介(1)与Sentinel相关的问题(2)什么是流量治理(3)流量治理的手段(4)Sentinel的核心功能(5)总结(1)与Sentinel相关的问题问题一：在调用第三方接口或其他部门的接口时需要控制速度。例如第三方接口限制QPS为1000，需要在请求第三方接口时进行限流。问题二：服务存在被大流量打垮的可能，为了保护服务就需要流量...

大纲1.两阶段提交Two-Phase Commit(2PC)2.三阶段提交Three-Phase Commit(3PC)3.ZAB协议算法4.ZAB协议与Paxos算法5.zk的数据存储原理之内存数据6.zk的数据存储原理之事务日志7.zk的数据存储原理之数据快照8.zk的数据存储原理之数据初始化和数据同步流程1.两阶段提交Two-Phase Commit(2PC)(1)数据库事务通过undo和redo保证数据强一致性(2)分布式事务通过2PC保证数据强一致性(3)2PC的优点和缺点(1)数据库事务通过undo和redo保证数据强一致性2PC即二阶段提交算法，是强一致性算法。它是数据库领域内，...

大纲1.zk是如何实现数据一致性的(1)数据一致性分析(2)实现数据一致性的广播模式(3)实现数据一致性的恢复模式2.zk是如何进行Leader选举的(1)服务器启动时的Leader选举(2)服务器运行时的Leader选举(3)Leader选举的算法设计(4)Leader选举的实现细节1.zk是如何实现数据一致性的(1)数据一致性分析(2)实现数据一致性的广播模式(3)实现数据一致性的恢复模式zk集群中的服务器分为Leader服务器、Follower服务器及Observer服务器。Leader选举是一个过程，在这个过程中主要做了两项工作：工作一：选举出Leader服务器工作二：进行数据同步zk...

大纲1.服务器的请求处理链(1)Leader服务器的请求处理链一.PrepRequestProcessor请求预处理器二.ProposalRequestProcessor事务投票处理器三.SyncRequestProcessor事务日志处理器四.AckRequestProcessor投票反馈处理器五.CommitProcessor事务提交处理器六.ToBeAppliedRequestProcessor处理器七.FinalRequestProcessor处理器(2)Follower服务器的请求处理链一.FollowerRequestProcessor请求转发处理器二.SendAckRequest...

大纲1.创建会话(1)客户端的会话状态(2)服务端的会话创建(3)会话ID的初始化实现(4)设置的会话超时时间没生效的原因2.分桶策略和会话管理(1)分桶策略和过期队列(2)会话激活(3)会话超时检查(4)会话清理1.创建会话(1)客户端的会话状态(2)服务端的会话创建(3)会话ID的初始化实现(4)设置的会话超时时间没生效的原因会话是zk中最核心的概念之一，客户端与服务端的交互都离不开会话的相关操作。其中包括临时节点的生命周期、客户端请求的顺序、Watcher通知机制等。比如会话关闭时，服务端会自动删除该会话所创建的临时节点。当客户端会话退出，通过Watcher机制可向订阅该事件的客户端发送...

大纲1.单机版的zk服务端的启动过程(1)预启动阶段(2)初始化阶段2.集群版的zk服务端的启动过程(1)预启动阶段(2)初始化阶段(3)Leader选举阶段(4)Leader和Follower启动阶段1.单机版的zk服务端的启动过程(1)预启动阶段(2)初始化阶段单机版zk服务端的启动，主要分为两个阶段：预启动阶段和初始化阶段，其启动流程图如下：接下来介绍zk服务端的预启动阶段(启动管理)与初始化阶段的具体流程，也就是单机版的zk服务端是如何从初始化到对外提供服务的。(1)预启动阶段在zk服务端进行初始化之前，首先要对配置文件等信息进行解析和载入，而zk服务端的预启动阶段的主要工作流程如下：...

大纲1.ZooKeeper如何进行序列化2.深入分析Jute的底层实现原理3.ZooKeeper的网络通信协议详解4.客户端的核心组件和初始化过程5.客户端核心组件HostProvider6.客户端核心组件ClientCnxn7.客户端工作原理之会话创建过程1.ZooKeeper如何进行序列化(1)什么是序列化以及为什么要进行序列化操作(2)ZooKeeper中的序列化方案(3)如何使用Jute实现序列化(4)Jute在ZooKeeper中的底层实现(5)总结要实现zk客户端与服务端的相互通信，就要解决通过网络传输数据的问题。而要通过网络传输定义好的Java对象数据，就必须要先对其进行序列化。...

大纲1.ZooKeeper的数据模型、节点类型与应用(1)数据模型之树形结构(2)节点类型与特性(持久 + 临时 + 顺序 )(3)节点的状态结构(各种zxid + 各种version)(4)节点的版本(version + cversion + aversion)(5)使用ZooKeeper实现锁(悲观锁 + 乐观锁)2.发布订阅模式：用Watcher机制实现分布式通知(1)Watcher机制是如何实现的(2)Watcher机制的底层原理(3)客户端Watcher注册实现过程(4)服务端处理Watcher过程(5)服务端Watch事件的触发过程(6)客户端回调Watcher的处理过程(7)利用...

大纲1.基于Curator进行基本的zk数据操作2.基于Curator实现集群元数据管理3.基于Curator实现HA主备自动切换4.基于Curator实现Leader选举5.基于Curator实现分布式Barrier6.基于Curator实现分布式计数器7.基于Curator实现zk的节点和子节点监听机制8.基于Curator创建客户端实例的源码分析9.Curator在启动时是如何跟zk建立连接的10.基于Curator进行增删改查节点的源码分析11.基于Curator的节点监听回调机制的实现源码12.基于Curator的Leader选举机制的实现源码1.基于Curator进行基本的zk数据...

大纲1.zk实现数据发布订阅2.zk实现负载均衡3.zk实现分布式命名服务4.zk实现分布式协调(Master-Worker协同)5.zk实现分布式通信6.zk实现Master选举7.zk实现分布式锁8.zk实现分布式队列和分布式屏障1.zk实现数据发布订阅(1)发布订阅系统一般有推模式和拉模式(2)zk采用了推拉相结合来实现发布订阅(3)使用zk来实现发布订阅总结(4)zk原生实现分布式配置的示例(也就是实现注册发现或者数据发布订阅)(1)发布订阅系统一般有推模式和拉模式推模式：服务端主动将更新的数据发送给所有订阅的客户端。拉模式：客户端主动发起请求来获取最新数据(定时轮询拉取)。(2)zk...