在Spring Cloud中，Hystrix是一个用于处理分布式系统的延迟和容错的库，可以防止系统间的级联故障，提高系统的弹性。
以下是一个使用Hystrix的简单示例：
- 首先，在Spring Cloud项目的pom.xml中添加Hystrix依赖：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>- 在启动类上添加@EnableCircuitBreaker注解来启用Hystrix：
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableCircuitBreaker
@EnableDiscoveryClient
public class MyApp {
public static void main(String[] args) {
SpringApplication.run(MyApp.class, args);
}
}- 使用HystrixCommand包装可能失败或者执行时间过长的调用：
import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
public class ServiceController {
@Autowired
private RestTemplate restTemplate;
@GetMapping("/service")
public String service() {
return new HystrixCommand<String>(HystrixCommandGroupKey.Factory.asKey("ServiceCommand")) {
@Override
protected String run() throws Exception {
return restTemplate.getForObject("http://service-provider/provider", String.class);
}
@Override
protected String getFallback() {
return "Service is unavailable";
}
}.execute();
}
}在这个例子中，我们创建了一个HystrixCommand，它会调用service-provider服务的/provider端点。如果调用失败，它将执行回退逻辑，返回"Service is unavailable"。