yoho.core服务调用
一、服务调用所涉及到的组件
1.hystrix
Netflix公司开发的处理依赖隔离的框架,同时也是可以帮我们做依赖服务的治理和监控. Hystrix如何解决依赖隔离:
- 1:Hystrix使用命令模式HystrixCommand(Command)包装依赖调用逻辑,每个命令在单独线程中/信号授权下执行。
- 2:可配置依赖调用超时时间,超时时间一般设为比99.5%平均时间略高即可.当调用超时时,直接返回或执行fallback逻辑。
- 3:为每个依赖提供一个小的线程池(或信号),如果线程池已满调用将被立即拒绝,默认不采用排队.加速失败判定时间。
- 4:依赖调用结果分:成功,失败(抛出异常),超时,线程拒绝,短路。 请求失败(异常,拒绝,超时,短路)时执行fallback(降级)逻辑。
- 5:提供熔断器组件,可以自动运行或手动调用,停止当前依赖一段时间(10秒),熔断器默认错误率阈值为50%,超过将自动运行。
-
6:提供近实时依赖的统计和监控
异步调用使用 command.queue()get(timeout, TimeUnit.MILLISECONDS); 同步调用使用 command.execute() 等同于 command.queue().get();
RestTemplate是Spring提供的用于访问Rest服务的客户端,RestTemplate提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。
用户调用ServiceCaller.call,具体由HystrixServiceCaller执行,生成HytrixPostCommand命令,通过command.queue().get()进行同步调用 Hystrix线程池执行command.run具体过程如下:
调用ServiceFinderAdaptor.getService(),ServiceFinderAdaptor先通过ZookeeperFinder查找服务,找不到再通过LocalFileFinder通过本地查找(会定期从zookeeper上同步到本地),
ZookeeperFinder会通过CuratorXDiscoveryClientWrapper调用ServiceDiscovery获取服务,服务有本地缓存并自动更新,ServiceCache保存一个服务的多个提供者(会自动刷新)。
获取到服务提供者list后,通过Strategry进行具体的选择策略选取一个服务提供者,
得到一个具体的服务提供者后,同过RestTemplateUtils进行具体的http调用。 异步调用只是不调用future.get,返回future,由调用者get。