ITPub博客

首页 > 架构设计 > 数据架构 > 企业级java springcloud b2bc商城系统二次开发:服务容错保护(Hystrix服务降级)

企业级java springcloud b2bc商城系统二次开发:服务容错保护(Hystrix服务降级)

原创 数据架构 作者:IT未来 时间:2019-01-28 09:09:58 0 删除 编辑

动手试一试

在开始使用Spring Cloud Hystrix实现断路器之前,我们先拿之前实现的一些内容作为基础,其中包括:

  • eureka-server 工程:服务注册中心,端口:1001
  • eureka-client 工程:服务提供者,两个实例启动端口分别为2001

下面我们可以复制一下之前实现的一个服务消费者: eureka-consumer-ribbon ,命名为 eureka-consumer-ribbon-hystrix 。下面我们开始对其进行改在:

第一步: pom.xml 的dependencies节点中引入 spring-cloud-starter-hystrix 依赖:

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

第二步:在应用主类中使用 @EnableCircuitBreaker @EnableHystrix 注解开启Hystrix的使用:

@EnableCircuitBreaker
@EnableDiscoveryClient
@SpringBootApplication
public class Application {
	@Bean
	@LoadBalanced
	public RestTemplate restTemplate() {
		return new RestTemplate();
	}
	public static void main(String[] args) {
		new SpringApplicationBuilder(Application.class).web(true).run(args);
	}
}

注意:这里我们还可以使用Spring Cloud应用中的 @SpringCloudApplication 注解来修饰应用主类,该注解的具体定义如下所示。我们可以看到该注解中包含了上我们所引用的三个注解,这也意味着一个Spring Cloud标准应用应包含服务发现以及断路器。

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker
public @interface SpringCloudApplication {
}

第三步:改造服务消费方式,新增 ConsumerService 类,然后将在 Controller 中的逻辑迁移过去。最后,在为具体执行逻辑的函数上增加 @HystrixCommand 注解来指定服务降级方法,比如:

@RestController
public class DcController {
    @Autowired
    ConsumerService consumerService;
    @GetMapping("/consumer")
    public String dc() {
        return consumerService.consumer();
    }
    class ConsumerService {
        @Autowired
        RestTemplate restTemplate;
        @HystrixCommand(fallbackMethod = "fallback")
        public String consumer() {
            return restTemplate.getForObject("http://eureka-client/dc", String.class);
        }
        public String fallback() {
            return "fallback";
        }
    }
}

下面我们来验证一下上面Hystrix带来的一些基础功能。我们先把涉及的服务都启动起来,然后访问 localhost:2101/consumer ,此时可以获取正常的返回,比如: Services: [eureka-consumer-ribbon-hystrix, eureka-client]

为了触发服务降级逻辑,我们可以将服务提供者 eureka-client 的逻辑加一些延迟,比如:

@GetMapping("/dc")
public String dc() throws InterruptedException {
    Thread.sleep(5000L);
    String services = "Services: " + discoveryClient.getServices();
    System.out.println(services);
    return services;
}

重启 eureka-client 之后,再尝试访问 localhost:2101/consumer ,此时我们将获得的返回结果为: fallback 。我们从 eureka-client 的控制台中,可以看到服务提供方输出了原本要返回的结果,但是由于返回前延迟了5秒,而服务消费方触发了服务请求超时异常,服务消费者就通过HystrixCommand注解中指定的降级逻辑进行执行,因此该请求的结果返回了 fallback 。这样的机制,对自身服务起到了基础的保护,同时还为异常情况提供了自动的服务降级切换机制。 Spring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码请加企鹅求求:一零三八七七四六二六

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/31452580/viewspace-2564987/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2017-04-14

  • 博文量
    459
  • 访问量
    103826