TokenServer有哪几种开发方式呢

1352 应用程序

问答对人有帮助，内容完整，我也想知道答案 0 TokenServer有哪几种开发方式呢？ TokenClient和TokenServer端开发的流程有哪些呢？ 0
2021-12-27 06:12:19　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × heks 该类别下有 16 个回答。邀请回答 ChristineGu 该类别下有 16 个回答。邀请回答 HengDu 该类别下有 16 个回答。邀请回答 dfasda 该类别下有 15 个回答。邀请回答 nhonglan 该类别下有 15 个回答。邀请回答 yonglanzhang 该类别下有 15 个回答。邀请回答 chm5 该类别下有 14 个回答。邀请回答 muwersddg 该类别下有 14 个回答。邀请回答杀狼000 该类别下有 14 个回答。邀请回答 wenminglang 该类别下有 14 个回答。邀请回答 C880U 该类别下有 14 个回答。邀请回答 jhdfvs 该类别下有 14 个回答。邀请回答 billbian 该类别下有 13 个回答。邀请回答 a732538 该类别下有 13 个回答。邀请回答 hrtuoyu 该类别下有 13 个回答。邀请回答 hfgdzc 该类别下有 13 个回答。邀请回答 thyysbk 该类别下有 13 个回答。邀请回答凡人wlj 该类别下有 13 个回答。邀请回答 kszdj113 该类别下有 13 个回答。邀请回答飞雪9366 该类别下有 13 个回答。邀请回答举报 YYXIAO 相关推荐 • 嵌入式程序开发方式有哪几种？优缺点是什么？ 2257 • 芯片的启动方式有哪几种呢 2226 • STM32下载方式有哪几种呢 3049 • pcb的组织方式有哪几种 7699 • 电流保护的接线方式有哪几种 2691 • SPI协议的工作方式有哪几种呢 1657 • 存储管理的存储方式有哪几种呢？分别有何优缺点呢 2577 • STM32程序下载的方式有哪几种 6127 • 如何去开发一种嵌入式程序？有哪几种方法？ 2109 • 在linux系统与uboot中网卡驱动的典型工作方式有哪几种 1066 2个回答

答案对人有帮助，有参考价值 0 Sentinel中的星流控制 Sentinel 1.4.0开始引入了流控模块，Sentinel的流控中，应用分为两个角色令牌客户端：决定流控客户端，用于向所属令牌服务器通信请求令牌。令牌服务器：即集群处理流控服务端，来自令牌客户端的请求，根据配置的决定判断是否是否应该发送令牌（是否允许通过）。 TokenServer又有两种开发方式是一种嵌入模式，即Token Server嵌入普通web应用中，在这个模式下同时，多个实例都是对等的token server和client可以随时进行生成，相反是需要限制令牌服务器的总和 QPS，防止影响应用程序。图PS 嵌入模式适用于某些独立应用程序内部的对应应用程序，架构如下：另一种是模式，即作为独立的令牌服务器进程启动，独立部署，隔离独立模式适合作为全球速率限制器给对应应用程序提供操作流控服务，架构如下本文会基于嵌入模式，结合Apollo，应用自定义实现流控，直接进入主题基本概念介绍，针对流控，Sentinel 多个基本类需要介绍，方便大家理解转中的代码先贴上一个重要令牌服务器配置的流控，图片来自Sentinel官方维基先介绍下最的，也就是图片机器分配的JSON串，也就是Sentinel Dashboard后台的JSON串是Sentinel Dashboard后台时产生的，分配Token Server时的界面就像图示的serverId:对应选择的TokenServer的及其Sentinel端口 ip：对应的TokenServer的机器ip 端口：对应的TokenServer的提供Token服务的端口 clientSet:TokenClient的机器列表这个JSON串是实现星流控制的关键，同时需要TokenServer和TokenClient监听到，因此需要配置中点并持久化到配置中心。所以第一个关键是，需要将TokenServer分配配置传输到Apollo中，具体代码实现两个分别做介绍几个类，TokenClient和TokenServer端来做介绍 TokenServer端： ClusterServerConfigManager#loadGlobalFlowConfig：设置Token Server最大允许qps ClusterServerConfigManager#registerServerTransportProperty：设置TokenServer的Token获取端口 ClusterFlowRuleManager.setPropertySupplier：限流TokenServer同样需要监听到限流规则的变化，怎么知道限制多少的qps呢？ TokenClient端： ClusterClientConfigManager#registerClientConfigProperty：设置TokenClient获取Token的超时时间 ClusterClientConfigManager#registerServerAssignProperty：设置TokenClient链接的TokenServer地址通用： ClusterStateManager：设置当前应用为TokenClient，或者TokenServer配置的基本思路和流程先根据一个例子来简单说明下实现想法192.168.0.1，192.168.0.2，192.168.0.3，TokenServer的JSON对应如下，即在Dashboard分配192.168.0.1为TokenServer，其他为TokenClient [ { "clientSet": [ "192.168.0.2@8719", "192.168.0.3@8719", ], "ip": "192.168.0.1", "machineId": "192.168.0.1@8719", "maxAllowedQps": 20000, "port": 18730 } ] 现在的问题来了，应用端都监听到了这个TokenServer的配置设置某个服务为TokenServer(或者是TokenClient)？怎样为Client指定TokenServer的地址？先来看第一个问题，因为我们已经指定了192.168.0.1为TokenServer，伪代码如下 if(currentMachineId == 配置的machineId){ 设置当前应用为TokenServer（ClusterStateManager.registerProperty）设置TokenServer最大QPS（ClusterServerConfigManager.loadGlobalFlowConfig）设置TokenServer端口（ClusterServerConfigManager.registerServerTransportProperty）设置TokenServer根据nameSpace监听集群限流规则的变化（ClusterFlowRuleManager.setPropertySupplier） }else{ // 当前机器在clientSet中 if(clientSet.contains（currentMachineId）){ 设置当前应用为TokenClient（ClusterStateManager.registerProperty）设置TokenClient链接的TokenServer地址（ClusterClientConfigManager.registerServerAssignProperty）设置TokenClient获取Token的超时时间（ClusterClientConfigManager.registerClientConfigProperty） } } 所以192.168.0.1的应用启动时，判断192.168.0.1@8719 = confg.machineId，所以分配其为TokenServer，而192.168.0.2和192.168.0.3的应用启动，时中包含192.168.0.2@8719和192.168.0。3@8719，所以其为TokenClient 所以第二个关键点就是客户端初始化代码，实现如上逻辑 Dashboard修改先来解决第一个关键点，如何将Dboard中的TokenServer配置推送到Apollo中，让应用监听到，直接上代码，修改ClusterGroupEntity ，加入maxAllowedQps字段新建ClusterMapDataApolloPublisher，TokenServer配置的服务类，代码如下，其中的BaseApolloRulePublisher参考上篇文章实现，不再重复贴代码 @Component("clusterMapDataApolloPublisher") public class ClusterMapDataApolloPublisher extends BaseApolloRulePublisher { @Override public void publish(String app, Object rules) throws Exception { if (rules == null) { return; } List clusterAppAssignMapList = (List) rules; List clusterGroupEntityList = new ArrayList<>(); for (ClusterAppAssignMap clusterAppAssignMap : clusterAppAssignMapList) { ClusterGroupEntity clusterGroupEntity = new ClusterGroupEntity(); clusterGroupEntity.setMachineId(clusterAppAssignMap.getMachineId()); clusterGroupEntity.setIp(clusterAppAssignMap.getIp()); clusterGroupEntity.setPort(clusterAppAssignMap.getPort()); clusterGroupEntity.setClientSet(clusterAppAssignMap.getClientSet()); clusterGroupEntity.setMaxAllowedQps(clusterAppAssignMap.getMaxAllowedQps()); clusterGroupEntityList.add(clusterGroupEntity); } super.publish(app, clusterGroupEntityList); } @Override protected String getDataId() { return ApolloConfigUtil.getTokenServerClusterMapDataId(); } } 那么这个配置又在哪里呢？修改com.alibaba.csp.sentinel.dashboard.service.ClusterAssignServiceImpl#applyAssignToApp方法，加入如下代码删除配置的地方呢？修改com.alibaba.csp.sentinel.dashboard.service.ClusterAssignServiceImpl#unbindClusterServers，加入如下代码到这里，TokenServer相关配置就已经传输到Apollo中了，看下我的Apollo中存储结构，key可以自己指定客户端初始化代码下一个关键点是应用端本地配置的TokenServer来当前应用是TokenServer还是TokenClient，同样可以根据SPI确定实现中来进行初始化，直接上代码，具体逻辑不懂看上面的伪代码，最核心的就是根据配置的ip端口和当前应用的ip端口做，判断其是TokenServer还是TokenClient /** * 初始化集群限流规则 */ private void initClusterConfig() { //初始化token server端口相关配置 initServerTransportConfigProperty(); //最大token qps配置 initServerFlowConfig(); //为token server添加命名空间动态监听器 initClusterRuleSupplier(); //为每个client设置目标token server initClientServerAssignProperty(); //初始化token client通用超时配置 initClientConfigProperty(); //等待transport端口分配完毕 while (TransportConfig.getRuntimePort() == -1) { try { Thread.sleep(10); } catch (InterruptedException e) { e.printStackTrace(); } } //初始化客户端状态为client 或者 server initStateProperty(); }

2021-12-27 14:43:41 评论举报刘溪

答案对人有帮助，有参考价值 0 初始化代码 private void initServerFlowConfig() { ClusterServerFlowConfigParser serverFlowConfigParser = new ClusterServerFlowConfigParser(); ReadableDataSource serverFlowConfigDs = new ApolloDataSource<>(namespaceName, ApolloConfigUtil.getTokenServerClusterMapDataId(), defaultRules, s -> { ServerFlowConfig config = serverFlowConfigParser.convert(s); if (config != null) { ClusterServerConfigManager.loadGlobalFlowConfig(config); } return config; }); } private void initStateProperty() { // Cluster map format: // [{"clientSet":["112.12.88.66@8729","112.12.88.67@8727"],"ip":"112.12.88.68","machineId":"112.12.88.68@8728","port":11111}] // machineId: , commandPort for port exposed to Sentinel dashboard (transport module) ReadableDataSource clusterModeDs = new ApolloDataSource<>(namespaceName, ApolloConfigUtil.getTokenServerClusterMapDataId(), defaultRules, new ClusterAssignStateParser()); ClusterStateManager.registerProperty(clusterModeDs.getProperty()); } private void initServerTransportConfigProperty() { ReadableDataSource serverTransportDs = new ApolloDataSource<>(namespaceName, ApolloConfigUtil.getTokenServerClusterMapDataId(), defaultRules, new ClusterTransportConfigParser()); ClusterServerConfigManager.registerServerTransportProperty(serverTransportDs.getProperty()); } private void initClientServerAssignProperty() { // Cluster map format: // [{"clientSet":["112.12.88.66@8729","112.12.88.67@8727"],"ip":"112.12.88.68","machineId":"112.12.88.68@8728","port":11111}] // machineId: , commandPort for port exposed to Sentinel dashboard (transport module) ReadableDataSource clientAssignDs = new ApolloDataSource<>(namespaceName, ApolloConfigUtil.getTokenServerClusterMapDataId(), defaultRules, new ClusterAssignConfigParser()); ClusterClientConfigManager.registerServerAssignProperty(clientAssignDs.getProperty()); } private void initClientConfigProperty() { ReadableDataSource clientConfigDs = new ApolloDataSource<>(namespaceName, ApolloConfigUtil.getTokenClientConfigDataId(), defaultRules, source -> JSON.parseObject(source, new TypeReference() { })); ClusterClientConfigManager.registerClientConfigProperty(clientConfigDs.getProperty()); } /** * 初始化集群限流规则监听器 */ private void initClusterRuleSupplier() { // Register cluster flow rule property supplier which creates data source by namespace. ClusterFlowRuleManager.setPropertySupplier(namespace -> { ReadableDataSource> ds = new ApolloDataSource<>(namespace, ApolloConfigUtil.getFlowDataId(), defaultRules, source -> JSON.parseObject(source, new TypeReference>() { })); return ds.getProperty(); }); // Register cluster parameter flow rule property supplier. ClusterParamFlowRuleManager.setPropertySupplier(namespace -> { ReadableDataSource> ds = new ApolloDataSource<>(namespace, ApolloConfigUtil.getParamFlowDataId(), defaultRules, source -> JSON.parseObject(source, new TypeReference>() { })); return ds.getProperty(); }); } 解析配置相关代码如下 public class ClusterAssignConfigParser implements Converter { @Override public ClusterClientAssignConfig convert(String source) { if (source == null) { return null; } RecordLog.info("[ClusterClientAssignConfigParser] Get data: " + source); List groupList = JSON.parseObject(source, new TypeReference>() { }); if (groupList == null \|\| groupList.isEmpty()) { return null; } return extractClientAssignment(groupList); } private ClusterClientAssignConfig extractClientAssignment(List groupList) { // Skip the token servers. for (ClusterGroupEntity group : groupList) { if (MachineUtils.isCurrentMachineEqual(group)) { return null; } } // Build client assign config from the client set of target server group. for (ClusterGroupEntity group : groupList) { if (group.getClientSet().contains(MachineUtils.getCurrentMachineId())) { String ip = group.getIp(); Integer port = group.getPort(); return new ClusterClientAssignConfig(ip, port); } } // Not assigned. return null; } } public class ClusterAssignStateParser implements Converter { @Override public Integer convert(String source) { if (source == null) { return null; } RecordLog.info("[ClusterClientAssignConfigParser] Get data: " + source); List groupList = JSON.parseObject(source, new TypeReference>() { }); if (groupList == null \|\| groupList.isEmpty()) { return ClusterStateManager.CLUSTER_NOT_STARTED; } return extractMode(groupList); } private int extractMode(List groupList) { // If any server group machine matches current, then it's token server. for (ClusterGroupEntity group : groupList) { if (MachineUtils.isCurrentMachineEqual(group)) { return ClusterStateManager.CLUSTER_SERVER; } if (group.getClientSet() != null) { for (String client : group.getClientSet()) { if (client != null && client.equals(MachineUtils.getCurrentMachineId())) { return ClusterStateManager.CLUSTER_CLIENT; } } } } return ClusterStateManager.CLUSTER_NOT_STARTED; } } public class ClusterServerFlowConfigParser implements Converter { @Override public ServerFlowConfig convert(String source) { if (source == null) { return null; } RecordLog.info("[ClusterServerFlowConfigParser] Get data: " + source); List groupList = JSON.parseObject(source, new TypeReference>() { }); if (groupList == null \|\| groupList.isEmpty()) { return null; } return extractServerFlowConfig(groupList); } private ServerFlowConfig extractServerFlowConfig(List groupList) { for (ClusterGroupEntity group : groupList) { if (MachineUtils.isCurrentMachineEqual(group)) { return new ServerFlowConfig() .setExceedCount(ClusterServerConfigManager.getExceedCount()) .setIntervalMs(ClusterServerConfigManager.getIntervalMs()) .setMaxAllowedQps(group.getMaxAllowedQps()) .setMaxOccupyRatio(ClusterServerConfigManager.getMaxOccupyRatio()) .setSampleCount(ClusterServerConfigManager.getSampleCount()); } } return null; } } public class ClusterTransportConfigParser implements Converter { @Override public ServerTransportConfig convert(String source) { if (source == null) { return null; } RecordLog.info("[ClusterServerTransportConfigParser] Get data: " + source); List groupList = JSON.parseObject(source, new TypeReference>() { }); if (groupList == null \|\| groupList.isEmpty()) { return null; } return extractServerTransportConfig(groupList); } private ServerTransportConfig extractServerTransportConfig(List groupList) { for (ClusterGroupEntity group : groupList) { if (MachineUtils.isCurrentMachineEqual(group)) { return new ServerTransportConfig().setPort(group.getPort()).setIdleSeconds(600); } } return null; } } 缺点及不足 TokenServer挂掉后，TokenClient无法failOver到另外一个可用的TokenServer 单个TokenServer在流量大时，可能有状态最好的方案是 TokenServer 独立部署，但我最近的实践过程发现基于 Apollo 的实现，有如下侧面先人提出的大背景应用需要监听自己的appId，所以有自己的appId，不同的应用不一样，同时也需要监听Sentinel规则 TokenServer端需要监听到规则的变化，所以也需要监听某个appId 那么问题来了，虚拟仪表板发送规则到业务的appId中的某个名称空间，那么TokenServer无法监听多个业务appId中的规则变化，仪表板发送规则到统一的Sentinel配置appId中，那么业务应用如何同时监听自己业务的appId和SentinelappId呢？这是一个配置点，暂时我没有好想法，有想法可以私信我啊

2021-12-27 14:43:46 评论举报张易