本质就是线程没有及时回收
Hystrix 是 Netflix 公司开源的一个项目,它提供了熔断器功能,能够阻止分布式系统中出现 联动故障。Hystrix 是通过隔离服务的访问点阻止联动故障的,并提供了故障的解决方案,从 而提高了整个分布式系统的弹性。
导入依赖,之后配置与之前一致
导入依赖,之后配置与之前一致
@GetMapping("rent")
public String rent(){
return "租车成功";
}
server:
port: 8080
spring:
application:
name: rent-car-service
ribbon:
ReadTimeOut: 3000 # 给3s超时时间
ConnectTimeout: 3000 # 连接服务超时时间
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka
yml配置
server:
port: 8081
spring:
application:
name: customer-service
ribbon:
ReadTimeOut: 3000 # 给3s超时时间
ConnectTimeout: 3000 # 连接服务超时时间
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka
接口,不要忘记在启动类加@EnableFeignClients
@FeignClient("rent-car-service")
public interface CustomerFeign {
@GetMapping("rent")
String rent();
}
调用方法
@Autowired
private CustomerFeign feign;
@GetMapping("customerRent")
public String customerRent(){
return feign.rent();
}
测试:
若创建时候没出现Hystrix依赖提示,则手动在pom中添加依赖
在消费端的pom中添加
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-starter-netflix-hystrixartifactId>
dependency>
在feign包下创建一个名为hystrix包(类似Service下的ServiceImpl)
要添加Component注解,继承Feign类并重写其中方法,若调用失败最会走这个方法
@Component
public class CustomerFeignHystrix implements CustomerFeign {
/**
* 这个方法是备选方案
* @return
*/
@Override
public String rent() {
return "hystrix的备选方案";
}
}
在Feign接口的注释添加属性,将Hystrix类放入
@FeignClient(value = "rent-car-service",fallback = CustomerFeignHystrix.class)
在消费端开启feign支持hystrix
yml:
feign:
hystrix:
enabled: true
测试:将服务端下线,消费端进行调用
若后续服务端上线,则访问时会自动调用服务端方法
此时会发现注入的Feign报错,原因是我们将接口实例化后也放入了IOC容器,在注入的时候Spring发现了两个同名实例
解决:
1.换成Resource注解
2.使用Qualifier注解
虽然报错,但是Hystrix已经帮我们处理这这个问题,我们无需关注