目录
四、在springcloudalibaba中整合sentinel
(3)启动服务,再访问服务后,观察控制台:因为访问接口以后才会注册到sentinel当中。
下载对应版本的sentinel的jar包,通过终端命令:
java -jar jar包名
启动
访问对应路径:控制台如下:
com.alibaba.cloud
spring-cloud-starter-alibaba-sentinel
server:
port: 8002
spring:
application:
name: WXL-DEV-SERVICE-2
cloud:
sentinel:
transport:
dashboard: 127.0.0.1:8080
可以设置阀值来流控:
可以看到当每秒超过2次时被流控:
流控文字可自定义:
@GetMapping("/world")
@SentinelResource(value = "helloWorld",blockHandler = "helloBlock")
public String helloWorld() {
return "Hello world";
}
public String helloBlock(BlockException e){
return "你已被流控";
}
value将该方法定义为sentinel的资源,blockHandler是流控时调用的方法。
这里的意思是如果/hello/add接口一秒钟之内访问超过2次,则/hello/query会被限流。
也要设置熔断时长,熔断时长过完之后会进入半开状态,即若下一次请求为慢请求则再次熔断,直到第一次请求不是慢请求才会恢复正常状态。
org.springframework.cloud
spring-cloud-starter-openfeign
feign:
sentinel:
enabled: true #开启openFeign对sentinel的整合
package com.wxl.feign;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
@FeignClient(name = "WXL-DEV-SERVICE-2", path = "/hello",fallback = ServiceFailFeign.class)
public interface Service1HelloInterface {
@GetMapping("/world")
String helloWorld();
}
并且这里添加参数fallback值为失败时回调的实现类。
实现类如下:
package com.wxl.feign;
import org.springframework.stereotype.Component;
@Component
public class ServiceFailFeign implements Service1HelloInterface{
public String helloWorld() {
return "降级了!!!";
}
}
当接口请求失败时便会调用失败类里的该方法。
这里我们为了使用效果,在服务生产者的接口里故意写入报错代码:
@GetMapping("/world")
public String helloWorld() {
int i=1/0;
return "Hello world";
}
请求该消费者服务接口:
调用了失败回调方法!
com.alibaba.csp
sentinel-datasource-nacos
更多见:
sentinel配置 持久化到nacos_yueF_L的博客-CSDN博客_sentinel持久化到nacos
先自我介绍一下,小编13年上师交大毕业,曾经在小公司待过,去过华为OPPO等大厂,18年进入阿里,直到现在。深知大多数初中级java工程师,想要升技能,往往是需要自己摸索成长或是报班学习,但对于培训机构动则近万元的学费,着实压力不小。自己不成体系的自学效率很低又漫长,而且容易碰到天花板技术停止不前。因此我收集了一份《java开发全套学习资料》送给大家,初衷也很简单,就是希望帮助到想自学又不知道该从何学起的朋友,同时减轻大家的负担。添加下方名片,即可获取全套学习资料哦