使用 spring-cloud-starter-alibaba-sentinel 集群模式下不能按照集群限流

tangchen-blip commented 4 years ago

依赖：

org.springframework.cloud spring-cloud-starter-alibaba-sentinel 0.9.0.RELEASE

    <!-- 用于查看Sentinel客户端相关规则 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <!--sentinel指定nacos为数据源 -->
    <dependency>
        <groupId>com.alibaba.csp</groupId>
        <artifactId>sentinel-datasource-nacos</artifactId>
        <version>1.7.0</version>
    </dependency>

问题：在单机模式下能够正常限流在集群模式下配置总qps 1 但是能够同时访问两次通过跟踪发现在注册token server 时监听器里面没有获取到限流规则通过自定义InitFuc给集群模式注入NacosDataSource才能正常限流，请问有其他的方式能够实现吗单机并不需要配自定义InitFuc 代码

@Override

public void init() {
    Properties properties=new Properties();
    properties.put("serverAddr","101.133.156.253:8848");
    properties.put("namespace","compile");
    ClusterFlowRuleManager.setPropertySupplier(namespace -> {
        ReadableDataSource<String, List<FlowRule>> ds = new NacosDataSource<>(properties, "cqz",
               "user-provider-flow-rules", source -> JSON.parseObject(source, new TypeReference<List<FlowRule>>() {}));
        return ds.getProperty();
    });
    // Register cluster parameter flow rule property supplier which creates data source by namespace.
    ClusterParamFlowRuleManager.setPropertySupplier(namespace -> {
        ReadableDataSource<String, List<ParamFlowRule>> ds = new NacosDataSource<>(properties,"cqz",
                "user-provider-flow-rules", source -> JSON.parseObject(source, new TypeReference<List<ParamFlowRule>>() {}));
        return ds.getProperty();
    });
}

配置文件

spring: cloud: sentinel: eager: true transport: dashboard: localhost:8080 heartbeat-interval-ms: 500 port: 8719 datasource: ds2: nacos: server-addr: xxxxxxx:8848 dataId: user-provider-flow-rules groupId: cqz data-type: json namespace: compile rule-type: flow