当前位置：首页 > article >正文

Spring Cloud — 微服务容错保护 Hystrix入门

article 2025/2/24 19:20:26

微服务之间是通过网络进行相互调用，如果单个服务出现问题，用户调用相关服务时或造成调用延迟或失败，进而可能让整个系统奔溃。提前做好应急措施，当遇到问题时，可及时启动应急方案，让系统进行自我调节和保护。

1 Hystrix

Hystrix 是一个用于处理分布式系统延迟和容错的库，旨在通过隔离服务的访问点、停止级联故障以及提供回退选项来提高系统的整体弹性。

1.1 Hystrix 入门

maven依赖：

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

在Application类增加@EnableCircuitBreaker注解来开启Hystrix支持。

Hystrix 提供降级有2种方式：1）通过@HystrixCommand注解；2）通过继承HystrixCommand或HystrixObservableCommand类。

1.1.1 @HystrixCommand注解

@RequestMapping("/home")
@RestController
public class HomeController {

    private final RestTemplate restTemplate;
    private final UserService userService;

    public HomeController(RestTemplate restTemplate, UserService userService) {
        this.restTemplate = restTemplate;
        this.userService = userService;
    }

    @HystrixCommand(fallbackMethod = "infoCallback")
    @GetMapping("/info")
    public String info(String name) {
        return restTemplate.getForObject("http://provider/user/info?name=" + name + "consumer",String.class);
    }

    @HystrixCommand(fallbackMethod = "updateCallback")
    @PostMapping("/update")
    public String update(@RequestBody User user) {
        return userService.update(user);
    }

    public String infoCallback(String name) {
        return "/info 降级";
    }

    public String updateCallback(User user) {
        return "/update 降级，" + user;
    }
}

fallbackMethod所指定的方法要与原方法具有相同的方法签名。

1.1.2 继承HystrixCommand

public class UserInfoFailCommand extends HystrixCommand<String> {

    private final RestTemplate restTemplate;
    private final String name;

    public UserInfoFailCommand(RestTemplate restTemplate, String name) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup")));
        this.restTemplate = restTemplate;
        this.name = name;
    }

    @Override
    protected String run() throws Exception {
        return restTemplate.getForObject("http://provider/user/info?name=" + name,String.class);
    }

    @Override
    protected String getFallback() {
        return "userInfoFailCommand 降级 info";
    }
}

@RequestMapping("/home")
@RestController
public class HomeController {

    private final RestTemplate restTemplate;

    public HomeController(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @GetMapping("/info3")
    public String info3(String name) {
        UserInfoFailCommand command = new UserInfoFailCommand(restTemplate,name);
        return command.execute();
    }
}

默认是阻塞式的，可提供同步和异步两种方式。同步通过execute()方法直接返回结果，异步执行通过queue()方法返回一个Future对象。

1.1.3 继承HystrixObservableCommand

public class UserInfoObservableCommand extends HystrixObservableCommand<String> {

    private final RestTemplate restTemplate;
    private final String name;

    public UserInfoObservableCommand(RestTemplate restTemplate, String name) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup")));
        this.restTemplate = restTemplate;
        this.name = name;
    }

    @Override
    protected Observable<String> construct() {
        String res = restTemplate.getForObject("http://provider/user/info?name=" + name, String.class);
        return Observable.just(res + ",UserInfoObservableCommand construct");
    }

    @Override
    protected Observable<String> resumeWithFallback() {
        return Observable.just("UserInfoObservableCommand info 降级");
    }
}

@RequestMapping("/home")
@RestController
public class HomeController {

    private final RestTemplate restTemplate;

    public HomeController(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @GetMapping("/info4")
    public String info4(String name) {
        UserInfoObservableCommand command = new UserInfoObservableCommand(restTemplate, name);
        Iterator<String> iterator = command.observe().toBlocking().getIterator();
        StringBuilder sb = new StringBuilder();
        while (iterator.hasNext()) sb.append(iterator.next());
        return sb.toString();
    }
}

非阻塞的。只能是异步调用。通过observe()和toObservable()方法返回一个Observable对象。observe()方法会立即发出请求，toObservable()方法只有在订阅该对象时，才会发出请求。

1.1.4 在Feign中使用Hystrix回退

@Component
public class UserServiceCallback implements UserService{

    @Override
    public String info(String name) {
        return "info 降级2：" + name;
    }

    @Override
    public String update(User user) {
        return "update 降级2：" + user;
    }

}

@RequestMapping("/home")
@RestController
public class HomeController {

    private final UserService userService;

    public HomeController(UserService userService) {
        this.userService = userService;
    }

    @GetMapping("/info2")
    public String info2(String name) {
        return userService.info(name + "feign");
    }

    @PostMapping("/update")
    public String update(@RequestBody User user) {
        return userService.update(user);
    }
}

需要在配置文件中feign.hystrix.enabled属性设置为true。