8、短路器 Netflix Hystrix 之 Plugins

缺乏、安全感 2023-01-10 13:09 94阅读 0赞

## 1、Plugins ##

你可以修改 Hystrix 的行为，或者通过实现插件给它添加额外的行为。

你可以通过 [HystrixPlugins][] 服务注册这些插件。然后，Hystrix 将把它们应用到所有 [HystrixCommand][]、[HystrixObservableCommand][] 和 [HystrixCollapser][] 实现中，覆盖其他所有实现。

## 2、Plugin Types ##

以下是你可以实现的不同插件的介绍( [Javadocs][] 包含更多的细节):

### 2.1 事件通知 ###

在 `HystrixCommand` 和 `HystrixObservableCommand` 执行过程中发生的事件会在 `HystrixEventNotifier`上被触发，从而给警报和统计信息收集提供机会。

### 2.2 Metrics 发布 ###

每个被捕获的度量实例(例如所有 `HystrixCommands` 与给定的 `HystrixCommandKey`)将请求[hystrixmetricpublpublisher][] 实现并初始化它。

这使实现有机会接收度量数据对象，并启动处理度量的后台进程，例如将它们发布到持久存储中。

默认实现不会在任何地方发布它们。

如果您希望使用 [Servo][] (它是一种内存系统，支持通过轮询器或JMX等各种机制检索数据)，请参阅 [https://github.com/Netflix/Hystrix/tree/master/hystrix-contrib/hystrix-servo-metrics-publisher][https_github.com_Netflix_Hystrix_tree_master_hystrix-contrib_hystrix-servo-metrics-publisher] 上的文档

### 2.3 Properties 策略 ###

如果你实现了一个自定义的 `HystrixPropertiesStrategy`，你就可以完全控制如何为系统定义属性。

默认实现使用 [Archaius][]。

### 2.4 并发策略 ###

Hystrix 使用 `ThreadLocal`、`Callable`、`Runnable`、`ThreadPoolExecutor` 和 `BlockingQueue` 实现作为其线程隔离和请求范围功能的一部分。

默认情况下，Hystrix有“开箱即用”的实现，但许多环境(包括Netflix)都希望使用替代方案，所以这个插件允许注入自定义实现或修饰行为。

你可以通过以下方式实现 [HystrixConcurrencyStrategy][] 类:

*  `getThreadPool()` 和 `getBlockingQueue()` 方法是直接注入所选实现的选项，或者只是添加了额外日志记录和度量的修饰版本。
 *  `wrapCallable()` 方法允许你装饰每一个 Hystrix 执行的可调用对象。对于依赖 ThreadLocal 状态实现应用程序功能的系统来说，这可能是必不可少的。包装可调用对象可以根据需要捕获并从父线程复制状态到子线程。
 *  `getRequestVariable()` 方法期望 [HystrixRequestVariable][] 的实现，它的功能类似于`ThreadLocal`，只是作用域是在请求中——在请求中的所有线程上可用。通常，只使用[HystrixRequestContext][] 和它自己的默认实现[HystrixRequestVariable][] 会更简单，也足够了。

### 2.5 Command 执行 Hook ###

`HystrixCommandExecutionHook` 实现让你可以访问 `HystrixInvokable` ( `HystrixCommand` 或`HystrixObservableCommand` )的执行生命周期，这样你就可以注入行为、日志记录、覆盖响应、改变线程状态等等。你可以通过重写以下一个或多个钩子来实现这一点:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI0MTA3MzM_size_16_color_FFFFFF_t_70]

## 3、如何使用 ##

当你第一次调用 `HystrixCommand` 时，它开始访问由插件控制的功能。因为不能在运行时换出插件，所以`HystrixCommand` 在第一次调用期间使用的插件将成为 `HystrixCommand` 在JVM运行期间使用的插件。

如果您在 `Archaius` 中注册了一个插件，那么就会使用该插件实现。如果没有，Hystrix 会选择一个默认插件。下面是一个如何使用 Archaius 实现此目的的示例:[https://github.com/eirslett/pull-request-illustration][https_github.com_eirslett_pull-request-illustration]。

如果你想在第一次调用 `HystrixCommand` 之前注册一个插件，你可以使用如下代码:

HystrixPlugins.getInstance().registerEventNotifier(ACustomHystrixEventNotifierDefaultStrategy.getInstance());

## 4、Abstract vs. Interface ##

上面显示的每个插件都将基类公开为要扩展的抽象类，而不是要实现的接口。

这有两个原因:

**1) 默认行为**

您只需要覆盖需要自定义的那些方法。您可以通过不修改其他方法来保留它们的默认行为。

每个方法实现都是独立的，没有副作用或状态，所以当您覆盖一个方法而不更改另一个方法时，这应该不会有任何影响。

通过抽象基类实现扩展主要是出于下一个原因……

**2) 库维护**

随着 Hystrix 的发展，每一个插件都可能获得新的方法，因为添加了新的功能或发现了需要用户定制的新东西。

如果 Hystrix 使用一个接口来实现这个目的，那么它可能会在每次添加新功能时都需要一个新接口(基本上每个方法都需要一个接口)，或者需要对实现该接口的任何人进行破坏性更改。在Java 8中，当接口上存在“默认方法”时，这个问题就会消失，但这还需要一段时间才能实现，而且这个库可以选择Java 8作为最小支持的JDK版本。

Hystrix 使用抽象基类，这样就可以在点版本中添加新的可选方法，而不是主要版本，而不会破坏现有的实现。

**原文地址：**

*  [Hystrix Wiki Plugins][]

[HystrixPlugins]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/strategy/HystrixPlugins.html
[HystrixCommand]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/HystrixCommand.html
[HystrixObservableCommand]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/HystrixObservableCommand.html
[HystrixCollapser]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/HystrixCollapser.html
[Javadocs]: http://netflix.github.io/Hystrix/javadoc/index.html
[hystrixmetricpublpublisher]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/strategy/metrics/HystrixMetricsPublisher.html
[Servo]: https://github.com/Netflix/servo
[https_github.com_Netflix_Hystrix_tree_master_hystrix-contrib_hystrix-servo-metrics-publisher]: https://github.com/Netflix/Hystrix/tree/master/hystrix-contrib/hystrix-servo-metrics-publisher
[Archaius]: https://github.com/Netflix/archaius
[HystrixConcurrencyStrategy]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/strategy/concurrency/HystrixConcurrencyStrategy.html
[HystrixRequestVariable]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/strategy/concurrency/HystrixRequestVariable.html
[HystrixRequestContext]: http://netflix.github.io/Hystrix/javadoc/index.html?com/netflix/hystrix/strategy/concurrency/HystrixRequestContext.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI0MTA3MzM_size_16_color_FFFFFF_t_70]: /images/20221119/74b553996ef04ca290dfbd50ce4133fd.png
[https_github.com_eirslett_pull-request-illustration]: https://github.com/eirslett/pull-request-illustration
[Hystrix Wiki Plugins]: https://github.com/Netflix/Hystrix/wiki/Plugins