SOFARPC 已集成 Hystrix 提供熔断能力，当前提供第一个预览版。关于 Hystrix 的更多介绍可以参考 Hystrix 官方文档，Hystrix 集成能力主要由 ScienJus 提供，感谢贡献。

接下来介绍一下如何体验 Hystrix 带来的熔断能力，以下示例使用 SOFARPC 5.5.0 版本，更多 Hystrix 的配置及 SOFABoot 集成使用方式将在后续版本提供，敬请关注。

准备工作

• Hystrix 模块作为可选模块默认不会直接加载，如需要使用，需要先主动加入 Hystrix maven 依赖：

<dependency>
    <groupId>com.netflix.hystrix</groupId>
    <artifactId>hystrix-core</artifactId>
    <version>1.5.12</version>
</dependency>

• 通过配置显式开启 Hystrix，将会自动加载 HystrixFilter：java// 全局开启RpcConfigs.putValue(HystrixConstants.SOFA_HYSTRIX_ENABLED, true);// 对特定 Consumer 开启ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>().setInterfaceId(HelloService.class.getName()).setParameter(HystrixConstants.SOFA_HYSTRIX_ENABLED, String.valueOf(true));

FallbackFactory

FallbackFactory 接口主要提供 Fallback 实现的注入能力，用于在 Hystrix 执行出现异常（抛出异常、超时、线程池拒绝和熔断等）时自动执行降级逻辑。

• 定义接口 Fallback 实现：

public class HelloServiceFallback implements HelloService {
@Override
public String sayHello(String name, int age) {
    return "fallback " + name + " from server! age: " + age;
}
}

• 注入 Fallback 实现：javaConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>().setInterfaceId(HelloService.class.getName()).setParameter(HystrixConstants.SOFA_HYSTRIX_ENABLED, String.valueOf(true));// 可以直接使用默认的 FallbackFactory 直接注入 Fallback 实现SofaHystrixConfig.registerFallback(consumerConfig, new HelloServiceFallback());// 也可以自定义 FallbackFactory 直接注入 FallbackFactorySofaHystrixConfig.registerFallbackFactory(consumerConfig, new HelloServiceFallbackFactory());
  • 当服务端响应失败时，客户端会自动触发 Fallback 逻辑执行。

SetterFactory

SetterFactory 提供 Hystrix 细粒度配置能力，SOFARPC 已提供默认的 DefaultSetterFactory 来生成每个调用方对应的 Setter，如有更定制化的述求，也可以针对每个 ConsumerConfig 提供自定义 SetterFactory。

SofaHystrixConfig.registerSetterFactory(consumerConfig, new CustomSetterFactory());

默认提供的实现中 GroupKey 为 InterfaceId，CommandKey 为方法的名称。

支持 Hystrix 的版本信息

SOFARPC: 5.5.0, SOFABoot: 2.5.3。

SOAF RPC 集成验证 Hystrix 版本：1.5.12。