SpringCloud核心组件Hystrix断路器与容错机制

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixCommandProperties;
 
// 定义一个简单的命令，用于执行可能失败的操作
public class SimpleHystrixCommand extends HystrixCommand<String> {
    private final String name;
 
    public SimpleHystrixCommand(String name) {
        // 设置命令组的键，这在断路器的上下文中进行聚合
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"))
                // 设置命令的属性，例如超时时间和断路器的策略
                .andCommandPropertiesDefaults(
                        HystrixCommandProperties.Setter()
                                .withExecutionTimeoutInMilliseconds(1000)
                )
        );
        this.name = name;
    }
 
    @Override
    protected String run() {
        // 在这里执行可能失败的操作
        return "Hello " + name + "!";
    }
 
    @Override
    protected String getFallback() {
        // 在这里提供备用逻辑，当操作失败时执行
        return "Fallback " + name + "!";
    }
 
    public static void main(String[] args) {
        // 执行命令并处理结果或回退
        SimpleHystrixCommand command = new SimpleHystrixCommand("World");
        String result = command.execute();
        System.out.println(result);
 
        // 当需要异步执行时
        SimpleHystrixCommand asyncCommand = new SimpleHystrixCommand("Async");
        String resultAsync = asyncCommand.queue().blockingGet();
        System.out.println(resultAsync);
    }
}

这个简单的例子展示了如何创建一个Hystrix命令，并定义了正常执行逻辑和备用逻辑。当执行可能失败的操作时，如果操作超时或者抛出异常，则会执行备用逻辑。这个例子也展示了如何异步执行命令并等待结果。