Commit 42bfc93d by Nepxion

支持Alibaba Sentinel

parent 1615c9f8
...@@ -14,14 +14,12 @@ import java.util.Collections; ...@@ -14,14 +14,12 @@ import java.util.Collections;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.alibaba.sentinel.annotation.SentinelProtect; import org.springframework.cloud.alibaba.sentinel.annotation.SentinelProtect;
import org.springframework.cloud.alibaba.sentinel.datasource.annotation.SentinelDataSource;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.openfeign.EnableFeignClients; import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import com.alibaba.csp.sentinel.datasource.ReadableDataSource;
import com.nepxion.discovery.plugin.example.service.impl.MyDiscoveryEnabledStrategy; import com.nepxion.discovery.plugin.example.service.impl.MyDiscoveryEnabledStrategy;
import com.nepxion.discovery.plugin.example.service.impl.MyDiscoveryListener; import com.nepxion.discovery.plugin.example.service.impl.MyDiscoveryListener;
import com.nepxion.discovery.plugin.example.service.impl.MyLoadBalanceListener; import com.nepxion.discovery.plugin.example.service.impl.MyLoadBalanceListener;
...@@ -41,8 +39,8 @@ public class DiscoveryApplicationA1 { ...@@ -41,8 +39,8 @@ public class DiscoveryApplicationA1 {
new SpringApplicationBuilder(DiscoveryApplicationA1.class).run(args); new SpringApplicationBuilder(DiscoveryApplicationA1.class).run(args);
} }
@SentinelDataSource("spring.cloud.sentinel.datasource") // @SentinelDataSource("spring.cloud.sentinel.datasource")
protected ReadableDataSource dataSource; // protected ReadableDataSource dataSource;
@Bean @Bean
@LoadBalanced @LoadBalanced
......
...@@ -45,12 +45,13 @@ spring.redis.pool.min-idle=0 ...@@ -45,12 +45,13 @@ spring.redis.pool.min-idle=0
# Sentinel config # Sentinel config
spring.cloud.sentinel.transport.dashboard=localhost:8075 spring.cloud.sentinel.transport.dashboard=localhost:8075
spring.cloud.sentinel.datasource.type=file # spring.cloud.sentinel.datasource.type=file
spring.cloud.sentinel.datasource.recommendRefreshMs=3000 # spring.cloud.sentinel.datasource.recommendRefreshMs=3000
spring.cloud.sentinel.datasource.bufSize=4056196 # spring.cloud.sentinel.datasource.bufSize=4056196
spring.cloud.sentinel.datasource.charset=utf-8 # spring.cloud.sentinel.datasource.charset=utf-8
spring.cloud.sentinel.datasource.converter=mySentinelFlowRuleParser # spring.cloud.sentinel.datasource.converter=mySentinelFlowRuleParser
spring.cloud.sentinel.datasource.file=E://sentinel-rule.json # spring.cloud.sentinel.datasource.file=sentinel-rule.json
# spring.cloud.sentinel.datasource.file=E://sentinel-rule.json
# Admin config # Admin config
# 该项只对Consul有效,而且必须配置在bootstrap.properties里,配置在application.properties无效 # 该项只对Consul有效,而且必须配置在bootstrap.properties里,配置在application.properties无效
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment