SpringCloud教程(Finchley版本)-04：断路器（Hystrix-Ribbon）

IT云清

发布于 2019-01-22 17:03:55

3900

发布于 2019-01-22 17:03:55

文章被收录于专栏：IT云清IT云清

在微服务系统中，我们把系统拆分成了很多小的服务，各个服务之间通过不同的方式进行依赖和调用，为了保证服务的高可用性，单个服务通常会集群部署，此时，许多服务由于各种问题可能会调用失败，比如超时、异常等。如何能够保证在一个依赖出问题的情况下，不会出现故障传播，导致整体服务失败，这个就是Hystrix需要做的事情。Hystrix提供了熔断、隔离、Fallback、cache、监控等功能，能够在一个、或多个依赖同时出现问题时保证系统依然可用。

本文介绍如何结合上一文SpringCloud教程(Finchley版本)-03：负载均衡（Ribbon），使用Hystrix来实现断路器功能。主要分为以下几个步骤：

1.创建项目
2.引入依赖
3.修改配置文件
4.添加启动注解
5.注入模板类
6.跨服务调用
7.启动项目，测试

1.创建项目

新建一个Springboot项目hystrix_ribbon_server1。

2.引入依赖

		<!--eureka-client-->
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
		</dependency>

		<!--eureka ribbon-->
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
		</dependency>

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

	<!--springcloud依赖管理-->
	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>${spring-cloud.version}</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>

	<spring-cloud.version>Finchley.SR2</spring-cloud.version>

3.修改配置文件

server:
  port: 8017
spring:
  application:
    name: hystrix-ribbon-server
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

4.添加启动注解

5.注入模板类

4.5步骤和前文的Ribbon一样。

package com.java4all.hystrix_ribbon_server1;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@EnableHystrix
@EnableEurekaClient
@SpringBootApplication
public class HystrixRibbonServer1Application {

	/**
	 *
	 * @Bean ： 注入一个名为restTemplate的bean
	 * @LoadBalanced ：表明这个 restTemplate 开启了负载均衡的功能
	 *
	 * */
	@Bean
	@LoadBalanced
	RestTemplate restTemplate(){return new RestTemplate();}

	public static void main(String[] args) {
		SpringApplication.run(HystrixRibbonServer1Application.class, args);
	}
}

6.跨服务调用

写一套简单的业务代码，然后调用前面创建的company-server服务提供的接口。

6.1 controller

@RestController
@RequestMapping(value = "hrs")
public class HrsController {

  @Autowired
  private HrsService hrsService;

  @GetMapping(value = "getCompany")
  public String getCompany(String id){
    String company = hrsService.getCompany(id);
    System.out.println(company);
    return company;
  }
}

6.2 service

public interface RibbonService {

  String getCompany(String id);
}

6.3 serviceImpl

在serviceImpl实现类中，我们引入前面的RestTemplate模板类，来跨服务调用，并开启了负载均衡功能。

在getCompany方法上添加@HystrixCommand注解。该注解对该方法创建了熔断器的功能，并指定了fallbackMethod熔断方法erroCompany，熔断方法直接返回了一个字符串

@Service
public class HrsServiceImpl implements HrsService{

  //启动类中注入了此模板，并且开启了负载均衡功能
  @Autowired
  RestTemplate restTemplate;

  //给方法添加熔断器的功能，并指定熔断方法
  @HystrixCommand(fallbackMethod = "erroCompany")
  @Override
  public String getCompany(String id) {
    //程序名替代服务地址，ribbon会根据服务名自动选择服务实例
    String company = restTemplate
        .getForObject("http://company-server/company/get?id=" + id, String.class);
    return company;
  }
  
  /**熔断方法*/
  public String erroCompany(String id){
    return "服务出错，返回默认企业："+id;
  }
}