是
DefaultClusterTokenClient#requestToken
FlowRuleChecker#checkFlow
调用canPassCheck验证规则
client把数据写到netty
封装请求参数
判断是client还是serverTokenService clusterService = pickClusterService();
netty
1. 如果当前就是server，则直接内部调用进行处理了。2. 如果当前是client，则会通过netty向server发起请求，由server处理后把结果返回
如果是client
DefaultTokenService#requestToken
private static TokenService pickClusterService() { if (ClusterStateManager.isClient()) { return TokenClientProvider.getClient(); } if (ClusterStateManager.isServer()) { return EmbeddedClusterTokenServerProvider.getServer(); } return null; }
passClusterCheck
NettyTransportClient#sendRequest
TokenServerHandler#channelRead
如果出现异常，则退化为单机限流fallbackToLocalOrPass
FlowRequestProcessor#processRequest
根据资源名称获得限流规则
否
和单机限流不一样的是，集群限流是在这里完成了集群数据记录，然后进行限流判断的。而单机限流的数据统计是在StatisticSlot里进行实现的
得到数据处理器：限流/热点参数RequestProcessorProvider.getProcessor(request.getType());
read
ClusterFlowChecker#acquireClusterToken
write
遍历规则
单机限流的流程passLocalCheck
FlowRuleChecker#canPassCheck
server读取数据
FlowSlot#entry
DefaultEmbeddedTokenServer#requestToken
向server发起请求transportClient.sendRequest(request);
解析响应结果applyTokenResult
如果是server
this.channel.writeAndFlush(request);
是否是集群限流模式？
向server发起请求clusterService.requestToken
