Sentinel Dashboard集成Zookeeper持久化的方式

這篇文章主要講解了“Sentinel Dashboard集成Zookeeper持久化的方式”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“Sentinel Dashboard集成Zookeeper持久化的方式”吧！

集成方式

拷貝test模塊對應(yīng)文件到main對應(yīng)位置，刪除引入test scope

FlowControllerV2修改ruleProvider、rulePublisher 的@Qualifier為拷貝過來的FlowRuleZookeeperProvider、FlowRuleZookeeperPublisher

@Autowired
@Qualifier("flowRuleZookeeperProvider")
private DynamicRuleProvider<List<FlowRuleEntity>> ruleProvider;
@Autowired
@Qualifier("flowRuleZookeeperPublisher")
private DynamicRulePublisher<List<FlowRuleEntity>> rulePublisher;

靜態(tài)文件配置修改

至此，打包后可以直接在控制臺修改規(guī)則寫入到zk

上面修改只針對FlowControllerV2改動，網(wǎng)關(guān)流控走的是GatewayFlowRuleController，對應(yīng)的entity不一樣，參考上面改造新增GatewayFlowRuleZookeeperProvider、GatewayFlowRuleZookeeperPublisher，修改GatewayFlowRuleController持久化方式，

list.json 查詢直接查詢zk數(shù)據(jù)

//            List<GatewayFlowRuleEntity> rules = sentinelApiClient.fetchGatewayFlowRules(app, ip, port).get();
            List<GatewayFlowRuleEntity> rules = ruleProvider.getRules(app);

new.json、save.json、delete.json 內(nèi)存存儲后同步持久化zk

entity = repository.save(entity);
publishRules(entity.getApp());

/**
 * zk 推送規(guī)則
 * @param app
 * @throws Exception
 */
private void publishRules(/*@NonNull*/ String app) throws Exception {
    List<GatewayFlowRuleEntity> rules = repository.findAllByApp(app);
    rulePublisher.publish(app, rules);
}

感謝各位的閱讀，以上就是“Sentinel Dashboard集成Zookeeper持久化的方式”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對Sentinel Dashboard集成Zookeeper持久化的方式這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！