您的位置:首页 > 娱乐 > 八卦 > 十大深夜看黄禁用免费撒娇_企业网站制作方法_全球网站排名查询网_网络推广产品要给多少钱

十大深夜看黄禁用免费撒娇_企业网站制作方法_全球网站排名查询网_网络推广产品要给多少钱

2024/12/23 7:51:26 来源:https://blog.csdn.net/ryo1060732496/article/details/143140296  浏览:    关键词:十大深夜看黄禁用免费撒娇_企业网站制作方法_全球网站排名查询网_网络推广产品要给多少钱
十大深夜看黄禁用免费撒娇_企业网站制作方法_全球网站排名查询网_网络推广产品要给多少钱

高可用系列

高可用开源库之 Hystrix-01-概览

高可用开源库之 Hystrix-02-聊一聊

高可用开源库之 Resilience4j-01-Netflix Hystrix 的替代者 overview

高可用开源库之 Resilience4j-02-chat 聊一聊

高可用开源库之 阿里流控组件 sentinel-01-overview 面向云原生微服务的高可用流控防护组件

高可用开源库之 阿里流控组件 sentinel-02-chat

Hystrix

Hystrix 是一个延迟和容错库,旨在隔离对远程系统、服务和第三方库的访问点,防止级联故障, 并在不可避免出现故障的复杂分布式系统中恢复能力。

特性

  • 延迟和容错

停止级联故障。回退和优雅的退化。快速失败和快速恢复。

带断路器的线程和信号量隔离。

  • 实时操作

实时监控和配置更改。观察服务和财产变化立即生效,因为他们分散在一个舰队。

警惕,做出决定,影响改变,在几秒钟内看到结果。

  • 并发性

并行执行。并发性意识到请求缓存。通过请求崩溃自动批处理。

快速开始

jar 引入

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

HystrixCommand

HystrixCommand 的最简单实现:

public class CommandHelloWorld extends HystrixCommand<String> {private final String name;public CommandHelloWorld(String name) {super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));this.name = name;}@Overrideprotected String run() {// a real example would do work like a network call herereturn "Hello " + name + "!";}
}

ps: 还有一个等效的开始类,HystrixObservableCommand 此处省去不谈。

同步执行

String s = new CommandHelloWorld("World").execute();

异步执行

  • Future
Future<String> fs = new CommandHelloWorld("World").queue();
String s = fs.get();

监听

实现方式

Observable<String> ho = new CommandHelloWorld("World").observe();
// or Observable<String> co = new CommandHelloWorld("World").toObservable();

监听方式

ho.subscribe(new Action1<String>() {@Overridepublic void call(String s) {// value emitted here}});

实际案例

  • testObservable()
@Test
public void testObservable() throws Exception {Observable<String> fWorld = new CommandHelloWorld("World").observe();Observable<String> fBob = new CommandHelloWorld("Bob").observe();// blockingassertEquals("Hello World!", fWorld.toBlocking().single());assertEquals("Hello Bob!", fBob.toBlocking().single());// non-blocking// - this is a verbose anonymous inner-class approach and doesn't do assertionsfWorld.subscribe(new Observer<String>() {@Overridepublic void onCompleted() {// nothing needed here}@Overridepublic void onError(Throwable e) {e.printStackTrace();}@Overridepublic void onNext(String v) {System.out.println("onNext: " + v);}});// non-blocking// - also verbose anonymous inner-class// - ignore errors and onCompleted signalfBob.subscribe(new Action1<String>() {@Overridepublic void call(String v) {System.out.println("call: " + v);}});
}
  • 输出日志
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.onNext: Hello World!
call: Hello Bob!

替代方案

resilience4j

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com