软文的概念是什么,优化大师班级,做软件与做网站建设有什么区别,项目管理系统软件在微服务架构中#xff0c;我们将系统拆分成了一个个的服务单元#xff0c;各单元间通过服务注册与订阅的方式互相依赖。由于每个单元都在不同的进程中运行#xff0c;依赖通过远程调用的方式执行#xff0c;这样就有可能因为网络原因或是依赖服务自身问题出现调用故障或延…在微服务架构中我们将系统拆分成了一个个的服务单元各单元间通过服务注册与订阅的方式互相依赖。由于每个单元都在不同的进程中运行依赖通过远程调用的方式执行这样就有可能因为网络原因或是依赖服务自身问题出现调用故障或延迟而这些问题会直接导致调用方的对外服务也出现延迟若此时调用方的请求不断增加最后就会出现因等待出现故障的依赖方响应而形成任务积压最终导致自身服务的瘫痪。
举个例子在一个电商网站中我们可能会将系统拆分成用户、订单、库存、积分、评论等一系列的服务单元。用户创建一个订单的时候在调用订单服务创建订单的时候会向库存服务来请求出货判断是否有足够库存来出货。此时若库存服务因网络原因无法被访问到导致创建订单服务的线程进入等待库存申请服务的响应在漫长的等待之后用户会因为请求库存失败而得到创建订单失败的结果。如果在高并发情况之下因这些等待线程在等待库存服务的响应而未能释放使得后续到来的创建订单请求被阻塞最终导致订单服务也不可用。
在微服务架构中存在着那么多的服务单元若一个单元出现故障就会因依赖关系形成故障蔓延最终导致整个系统的瘫痪这样的架构相较传统架构就更加的不稳定。为了解决这样的问题因此产生了断路器模式。
什么是断路器
断路器模式源于Martin Fowler的Circuit Breaker一文。“断路器”本身是一种开关装置用于在电路上保护线路过载当线路中有电器发生短路时“断路器”能够及时的切断故障电路防止发生过载、发热、甚至起火等严重后果。
在分布式架构中断路器模式的作用也是类似的当某个服务单元发生故障类似用电器发生短路之后通过断路器的故障监控类似熔断保险丝向调用方返回一个错误响应而不是长时间的等待。这样就不会使得线程因调用故障服务被长时间占用不释放避免了故障在分布式系统中的蔓延。
Netflix Hystrix
在Spring Cloud中使用了Hystrix 来实现断路器的功能。Hystrix是Netflix开源的微服务框架套件之一该框架目标在于通过控制那些访问远程系统、服务和第三方库的节点从而对延迟和故障提供更强大的容错能力。Hystrix具备拥有回退机制和断路器功能的线程和信号隔离请求缓存和请求打包以及监控和配置等功能。
下面我们来看看如何使用Hystrix。
准备工作
在开始加入断路器之前我们先拿之前构建两个微服务为基础进行下面的操作主要使用下面几个工程
chapter9-1-1 eureka-server工程服务注册中心端口1111compute-service工程服务单元端口2222chapter9-1-2 eureka-ribbon通过ribbon实现的服务单元依赖compute-service的服务端口3333eureka-feign通过feign实现的服务单元依赖compute-service的服务端口3333
若您还没有使用Spring Cloud的经验可以先阅读《服务注册与发现》与《服务消费者》对Spring Cloud构建的微服务有一个初步的认识。
Ribbon中引入Hystrix
依次启动eureka-server、compute-service、eureka-ribbon工程访问http://localhost:1111/可以看到注册中心的状态访问http://localhost:3333/add调用eureka-ribbon的服务该服务会去调用compute-service的服务计算出1020的值页面显示30关闭compute-service服务访问http://localhost:3333/add我们获得了下面的报错信息
Whitelabel Error PageThis application has no explicit mapping for /error, so you are seeing this as a fallback.Sat Jun 25 21:16:59 CST 2016There was an unexpected error (typeInternal Server Error, status500).I/O error on GET request for http://COMPUTE-SERVICE/add?a10b20: Connection refused: connect; nested exception is java.net.ConnectException: Connection refused: connectpom.xml中引入依赖hystrix依赖
dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-starter-hystrix/artifactId/dependency在eureka-ribbon的主类RibbonApplication中使用EnableCircuitBreaker注解开启断路器功能
SpringBootApplicationEnableDiscoveryClientEnableCircuitBreakerpublic class RibbonApplication { Bean LoadBalanced RestTemplate restTemplate() { return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(RibbonApplication.class, args); }}改造原来的服务消费方式新增ComputeService类在使用ribbon消费服务的函数上增加HystrixCommand注解来指定回调方法。
Servicepublic class ComputeService { Autowired RestTemplate restTemplate; HystrixCommand(fallbackMethod addServiceFallback) public String addService() { return restTemplate.getForEntity(http://COMPUTE-SERVICE/add?a10b20, String.class).getBody(); } public String addServiceFallback() { return error; }}提供rest接口的Controller改为调用ComputeService的addService
RestControllerpublic class ConsumerController { Autowired private ComputeService computeService; RequestMapping(value /add, method RequestMethod.GET) public String add() { return computeService.addService(); }}验证断路器的回调 依次启动eureka-server、compute-service、eureka-ribbon工程访问http://localhost:1111/可以看到注册中心的状态访问http://localhost:3333/add页面显示30关闭compute-service服务后再访问http://localhost:3333/add页面显示error
更多关于Hystrix的使用可参考How To Use
Feign使用Hystrix
注意这里说的是“使用”没有错我们不需要在Feigh工程中引入HystixFeign中已经依赖了Hystrix我们可以在未做任何改造前尝试下面你的操作
依次启动eureka-server、compute-service、eureka-feign工程访问http://localhost:1111/可以看到注册中心的状态访问http://localhost:3333/add调用eureka-feign的服务该服务会去调用compute-service的服务计算出1020的值页面显示30关闭compute-service服务访问http://localhost:3333/add我们获得了下面的报错信息
Whitelabel Error PageThis application has no explicit mapping for /error, so you are seeing this as a fallback.Sat Jun 25 22:10:05 CST 2016There was an unexpected error (typeInternal Server Error, status500).add timed-out and no fallback available.如果您够仔细会发现与在ribbon中的报错是不同的看到add timed-out and no fallback available这句或许您已经猜到什么看看我们的控制台可以看到报错信息来自hystrix-core-1.5.2.jar所以在这个工程中我们要学习的就是如何使用Feign中集成的Hystrix。
使用FeignClient注解中的fallback属性指定回调类
FeignClient(value compute-service, fallback ComputeClientHystrix.class)public interface ComputeClient { RequestMapping(method RequestMethod.GET, value /add) Integer add(RequestParam(value a) Integer a, RequestParam(value b) Integer b);}创建回调类ComputeClientHystrix实现FeignClient的接口此时实现的方法就是对应FeignClient接口中映射的fallback函数。
Componentpublic class ComputeClientHystrix implements ComputeClient { Override public Integer add(RequestParam(value a) Integer a, RequestParam(value b) Integer b) { return -9999; }}再用之前的方法验证一下是否在compute-service服务不可用的情况下页面返回了-9999。
关于Feign的更多使用方法可参考Feign
完整示例Chapter9-1-3
【转载请注明出处】http://blog.didispace.com/springcloud3/
