Spring Cloud对Hystrix的支持

Spring Cloud项目为Netflix OSS Hystrix库提供了全面的支持。之前我已经写过有关如何使用原始Hystrix库包装远程调用的文章。在这里，我将探讨如何将Hystrix与Spring Cloud结合使用

基本

实际上并没有什么大不了的，这些概念仅在特定于Spring引导的增强中保留下来。考虑一个简单的Hystrix命令，该命令包含对Remote服务的调用：

import agg.samples.domain.Message;
import agg.samples.domain.MessageAcknowledgement;
import agg.samples.feign.RemoteServiceClient;
import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class RemoteMessageClientCommand extends HystrixCommand<MessageAcknowledgement> {private static final String COMMAND_GROUP = "demo";private static final Logger logger = LoggerFactory.getLogger(RemoteMessageClientCommand.class);private final RemoteServiceClient remoteServiceClient;private final Message message;public RemoteMessageClientCommand(RemoteServiceClient remoteServiceClient, Message message) {super(HystrixCommandGroupKey.Factory.asKey(COMMAND_GROUP));this.remoteServiceClient = remoteServiceClient;this.message = message;}@Overrideprotected MessageAcknowledgement run() throws Exception {logger.info("About to make Remote Call");return this.remoteServiceClient.sendMessage(this.message);}@Overrideprotected MessageAcknowledgement getFallback() {return new MessageAcknowledgement(message.getId(), message.getPayload(), "Fallback message");}
}

这里没有与Spring相关的类，此命令可以直接在基于Spring的项目中使用，例如在控制器中以下列方式使用：

@RestController
public class RemoteCallDirectCommandController {@Autowiredprivate RemoteServiceClient remoteServiceClient;@RequestMapping("/messageDirectCommand")public MessageAcknowledgement sendMessage(Message message) {RemoteMessageClientCommand remoteCallCommand = new RemoteMessageClientCommand(remoteServiceClient, message);return remoteCallCommand.execute();}
}

Hystrix命令的行为自定义通常是通过NetflixOSS Archaius属性执行的，但是Spring Cloud提供了一个桥梁，使Spring定义的属性显示为Archaius属性，这简而言之意味着我可以使用Spring特定的配置文件来定义我的属性，自定义命令行为时将可见。

因此，如果较早进行自定义，则可以使用Archaius属性来表示HelloWorldCommand的行为，如下所示：

hystrix.command.HelloWorldCommand.metrics.rollingStats.timeInMilliseconds=10000
hystrix.command.HelloWorldCommand.execution.isolation.strategy=THREAD
hystrix.command.HelloWorldCommand.execution.isolation.thread.timeoutInMilliseconds=1000
hystrix.command.HelloWorldCommand.circuitBreaker.errorThresholdPercentage=50
hystrix.command.HelloWorldCommand.circuitBreaker.requestVolumeThreshold=20
hystrix.command.HelloWorldCommand.circuitBreaker.sleepWindowInMilliseconds=5000

这可以在Spring Cloud世界中以完全相同的方式在application.properties文件或application.yml文件中通过以下方式完成：

hystrix:command:HelloWorldCommand:metrics:rollingStats:timeInMilliseconds: 10000execution:isolation:strategy: THREADthread:timeoutInMilliseconds: 5000circuitBreaker:errorThresholdPercentage: 50requestVolumeThreshold: 20sleepWindowInMilliseconds: 5000

基于注释的方法

我个人更喜欢基于直接命令的方法，但是在Spring世界中使用Hystrix的更好方法可能是使用基于hystrix-javanica的注释。最好通过一个示例说明如何使用此注释。这是包装在Hystrix命令中并带有注释的远程调用：

import agg.samples.domain.Message;
import agg.samples.domain.MessageAcknowledgement;
import agg.samples.feign.RemoteServiceClient;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class RemoteMessageAnnotationClient  {private final RemoteServiceClient remoteServiceClient;@Autowiredpublic RemoteMessageAnnotationClient(RemoteServiceClient remoteServiceClient) {this.remoteServiceClient = remoteServiceClient;}@HystrixCommand(fallbackMethod = "defaultMessage", commandKey = "RemoteMessageAnnotationClient" )public MessageAcknowledgement sendMessage(Message message) {return this.remoteServiceClient.sendMessage(message);}public MessageAcknowledgement defaultMessage(Message message) {return new MessageAcknowledgement("-1", message.getPayload(), "Fallback Payload");}}

这些注解使用方面转换为幕后的常规Hystrix命令，但很妙的是，在Spring Cloud项目中没有使用该注解的仪式，它只是工作而已。与以前一样，如果需要自定义行为，则可以使用命令特定的属性来完成。一个小问题是默认情况下命令名称是方法名称，因此在我的示例中，命令名称将是“ sendMessage”，我已使用注释将其自定义为其他名称。