个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
25
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Feign 集成 Hystrix实现不同的调用接口不同的设置方式由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
小编在写项目时遇到一个需求
假设现在有三个项目A、B、C,其中A、B作为服务提供方，C作为调用方，需要实现C在调用A、B时实现不同的超时时间，比如C调用A时超时是2s，调用B时超时是3s。。。.
本来以为是很简单的事，但是面向百度编程时发现没有搜索到，官网也没有，这就难受了，小编属于那种不会主动研究源码的，都是项目有需要或者说看到别人改造了啥玩意特别有意思，否则都不去喵一眼，现在没办法只能研究一波源码，手动改造.
正文分为三个部分描述 。
先说说如果找到关键的源代码，如果对hystrix feign 集成比较熟悉的朋友，可以略过，直接看方案，如果希望知道源码怎么走的朋友建议看下，这个花了我挺长时间的，网上的源码解析都是只有关键代码展示，但是具体细节怎么走，没有描述，要不然我也不会花很长时间进行研究阅读.
首先我们知道 feign 是spring cloud 中用来进行服务之间的调用，openFeign 当中集成了 ribbon实现了负载均衡的实际的请求 。
Hystrix是个熔断器，就是在某些任务执行时及时的失败返回而不是挂着线程，造成服务器的级联瘫痪，feign在进行微服务之间调用时如果出现了服务超时，Hystrix进行熔断，立马返回结果.
如果大家上网去搜 Hystrix 超时配置，应该都是这样 。
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=3000
那么 Hystrix 组件工作时肯定需要解析这个配置，调用它 。
spring boot 配置有个特点，命名方式都是 {组件名}Properties 这种形式，那么搜索下就找到了关键的配置类 。
com.netflix.hystrix.HystrixCommandProperties
可以看到这里属性都是final，就是说不能set，那么只有构造函数或者静态代码块可以改，后者明显不合适，找找构造方法就能看到 。
这就很像了嘛！随便点一个进去看 。
private static HystrixProperty<Boolean> getProperty(String propertyPrefix, HystrixCommandKey key, String instanceProperty, Boolean builderOverrideValue, Boolean defaultValue) { return forBoolean() .add(propertyPrefix + ".command." + key.name() + "." + instanceProperty, builderOverrideValue) .add(propertyPrefix + ".command.default." + instanceProperty, defaultValue) .build(); }
像不像拼接上面配置，那么关键是这个 HystrixCommandKey 怎么传进来的问题，这时候打个断点就行，启动项目，进行调用 。
这时候就有调用方法栈了，可以直接看 invoke:104, HystrixInvocationHandler (feign.hystrix) 。
@Override public Object invoke(final Object proxy, final Method method, final Object[] args) throws Throwable { ............. // setterMethodMap 封装 hystrixCommand 配置信息（超时时间、是否重试.....） HystrixCommand<Object> hystrixCommand = new HystrixCommand<Object>(setterMethodMap.get(method)) { @Override protected Object run() throws Exception { .... HystrixInvocationHandler.this.dispatch.get(method).invoke(args); .... } @Override protected Object getFallback() { ......... } }; ...... return hystrixCommand.execute(); }
大致就这样，其实就是用hystrixCommand调用feign，最主要的是 setterMethodMap 从哪里设置的， 。
final class HystrixInvocationHandler implements InvocationHandler { private final Target<?> target; private final Map<Method, MethodHandler> dispatch; private final FallbackFactory<?> fallbackFactory; // Nullable private final Map<Method, Method> fallbackMethodMap; private final Map<Method, Setter> setterMethodMap; HystrixInvocationHandler(Target<?> target, Map<Method, MethodHandler> dispatch, SetterFactory setterFactory, FallbackFactory<?> fallbackFactory) { this.target = checkNotNull(target, "target"); this.dispatch = checkNotNull(dispatch, "dispatch"); this.fallbackFactory = fallbackFactory; this.fallbackMethodMap = toFallbackMethod(dispatch); this.setterMethodMap = toSetters(setterFactory, target, dispatch.keySet()); } }
一样也是final属性，那么也是构造函数赋值的，一样的打个断点，重新启动下项目 。
target:56, HystrixTargeter (org.springframework.cloud.openfeign)
看到这里代码 核心部分 。
// HystrixTargeter 这个类看代码就知道，对应这 @FeignClient 注解的接口@SuppressWarnings("unchecked")class HystrixTargeter implements Targeter { @Override public <T> T target(FeignClientFactoryBean factory, Feign.Builder feign, FeignContext context, Target.HardCodedTarget<T> target) { ..... feign.hystrix.HystrixFeign.Builder builder = (feign.hystrix.HystrixFeign.Builder) feign; // 这里其实是容器中拿到 SetterFactory 配置类 SetterFactory setterFactory = getOptional(factory.getName(), context, SetterFactory.class); if (setterFactory != null) { builder.setterFactory(setterFactory); } // 从 @FeignClient 注解中读取或者默认 Class<?> fallback = factory.getFallback(); if (fallback != void.class) { return targetWithFallback(factory.getName(), context, target, builder, fallback); } Class<?> fallbackFactory = factory.getFallbackFactory(); if (fallbackFactory != void.class) { return targetWithFallbackFactory(factory.getName(), context, target, builder, fallbackFactory); } return feign.target(target); } ..... private <T> T getOptional(String feignClientName, FeignContext context, Class<T> beanType) { return context.getInstance(feignClientName, beanType); }}
看下 feign.hystrix.SetterFactory 。
public interface SetterFactory { HystrixCommand.Setter create(Target<?> target, Method method); // 默认实现 final class Default implements SetterFactory { @Override public HystrixCommand.Setter create(Target<?> target, Method method) { String groupKey = target.name(); String commandKey = Feign.configKey(target.type(), method); // HystrixCommandKey、group 赋值 return HystrixCommand.Setter .withGroupKey(HystrixCommandGroupKey.Factory.asKey(groupKey)) .andCommandKey(HystrixCommandKey.Factory.asKey(commandKey)); } }}
看到这里结合上面 HystrixCommandProperties 代码 是不是有点感觉了，就是说关键配置信息的 HystrixCommandKey 是这里指定的 。
是不是真的，可以验证下，打个断点，然后手动把 commandKey 修改了，然后上面 HystrixCommandProperties 断点处验证就行，我这里不贴代码了 。
那结合代码发现 SetterFactory 这接口是关键，而这又是注入的那么简单了只要我们手动实现这接口并且注入到 spring 容器中就行 。
在 feign.hystrix.SetterFactory.Default#create 方法中手动实现不同的feign 接口不同的配置,甚至不同的feign 。
我这里目前是用注解实现的,大家也可以用方法名等规则实现 。
最终目的就是让指定的feign 方法获取指定的配置 。
@FeignClient(value = "itemRobot", path = "cloud/device")public interface DeviceApi { @RequestMapping(value = "/login", method = RequestMethod.GET) ServerResponse<String> login(@RequestParam String appId); @RequestMapping(value = "/logout", method = RequestMethod.GET) ServerResponse<String> logout(@RequestParam String appId);}
# login() 方法映射hystrix.command.login.execution.isolation.thread.timeoutInMilliseconds=10000# logout() 方法映射hystrix.command.logout.execution.isolation.thread.timeoutInMilliseconds=10000
如果是基于方法级别的不同配置，hystrix 官方有给这样的注解 。
com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand
@HystrixCommand(groupKey="accountPayGroup",commandKey="accountPay",threadPoolKey="account",threadPoolProperties= { @HystrixProperty(name="coreSize",value="20"), @HystrixProperty(name="maxQueueSize",value="50") },commandProperties={ @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds",value="3000"), @HystrixProperty(name="circuitBreaker.errorThresholdPercentage",value="40") })
ps:我用了发现不生效，目前还在调试，有了进展，再写一篇 。
但是不能基于feign 调用不同接口实现，所以如果想基于方法实现不同配置用官方这个就行，如果想一个接口下所有方法一样配置，不同接口实现不同，那么用我下面这方式也行.
指定注解 。
@Target({TYPE, METHOD})@Retention(RUNTIME)public @interface CusHystrixCommandKey { // 对应 commandKey String name();}
实现 SetterFactory 。
import com.netflix.hystrix.HystrixCommand;import com.netflix.hystrix.HystrixCommandGroupKey;import com.netflix.hystrix.HystrixCommandKey;import feign.Feign;import feign.Target;import feign.hystrix.SetterFactory;import org.springframework.cloud.openfeign.FeignClient;import org.springframework.stereotype.Component;import java.lang.reflect.Method;@Componentpublic class MyHystrixFactory implements SetterFactory { @Override public HystrixCommand.Setter create(Target<?> target, Method method) { String groupKey = target.name(); String commandKey = Feign.configKey(target.type(), method); CusHystrixCommandKey annotation = method.getAnnotation(CusHystrixCommandKey.class); if (annotation == null) { // 如果指定方法没有 CusHystrixCommandKey 注解，用 FeignClient.value() 作为key FeignClient feignClient = method.getDeclaringClass().getAnnotation(FeignClient.class); commandKey = feignClient.value(); } else { // 否则获取指定的name() 作为key commandKey = annotation.name(); } return HystrixCommand.Setter .withGroupKey(HystrixCommandGroupKey.Factory.asKey(groupKey)) .andCommandKey(HystrixCommandKey.Factory.asKey(commandKey)); }}
测试页面就不贴了，老方法，万能的断点 。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持我.
原文链接：https://blog.csdn.net/weixin_39660224/article/details/109477040 。
最后此篇关于Feign 集成 Hystrix实现不同的调用接口不同的设置方式的文章就讲到这里了,如果你想了解更多关于Feign 集成 Hystrix实现不同的调用接口不同的设置方式的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
25
4
0
我有 table 像这样 -------------------------------------------- id size title priority
我的应用在不同的 Activity (4 个 Activity )中仅包含横幅广告。所以我的疑问是， 我可以对所有横幅广告使用一个广告单元 ID 吗？ 或者 每个 Activity 使用不同的广告单元
我有任意(但统一)数字列表的任意列表。 (它们是 n 空间中 bin 的边界坐标，我想绘制其角，但这并不重要。)我想生成所有可能组合的列表。所以:[[1,2], [3,4],[5,6]] 产生 [[1
我刚刚在学校开始学习 Java，正在尝试自定义控件和图形。我目前正在研究图案锁，一开始一切都很好，但突然间它绘制不正确。我确实更改了一些代码，但是当我看到错误时，我立即将其更改回来(撤消，ftw)，但
在获取 Distinct 的 Count 时，我在使用 Group By With Rollup 时遇到了一个小问题。 问题是 Rollup 摘要只是所有分组中 Distinct 值的总数，而不是所有
这不起作用: select count(distinct colA, colB) from mytable 我知道我可以通过双选来简单地解决这个问题。 select count(*) from (
这个问题在这里已经有了答案: JavaScript regex whitespace characters (5 个回答) 2年前关闭。 你能解释一下为什么我会得到 false比较 text ===
这个问题已经有答案了: 奥 git _a (56 个回答) 已关闭 9 年前。 我被要求用 Javascript 编写一个函数 sortByFoo 来正确响应此测试: // Does not cras
所以，我不得不说，SQL 是迄今为止我作为开发人员最薄弱的一面。也许我想要完成的事情很简单。我有这样的东西(这不是真正的模型，但为了使其易于理解而不浪费太多时间解释它，我想出了一个完全模仿我必须使用的
这个问题在这里已经有了答案: How does the "this" keyword work? (22 个回答) 3年前关闭。 简而言之:为什么在使用 Objects 时，直接调用的函数和通过引用传
这个问题在这里已经有了答案: 关闭 12 年前。 Possible Duplicate: what is the difference between (.) dot operator and (-
我真的不明白这里发生了什么但是: 当我这样做时: colorIndex += len - stopPos; for(int m = 0; m < len - stopPos; m++) { c
思考 MySQL 中的 Group By 函数的最佳方式是什么？ 我正在编写一个 MySQL 查询，通过 ODBC 连接在 Excel 的数据透视表中提取数据，以便用户可以轻松访问数据。 例如，我有:
我想要的SQL是这样的: SELECT week_no, type, SELECT count(distinct user_id) FROM group WHERE pts > 0 FROM bas
商店表: +--+-------+--------+ |id|name |date | +--+-------+--------+ |1 |x |Ma
对于 chrome 和 ff，当涉及到可怕的 ie 时，这个脚本工作完美。有问题 function getY(oElement) { var curtop = 0; if (oElem
我现在无法提供代码，因为我目前正在脑海中研究这个想法并在互联网上四处乱逛。 我了解了进程间通信和使用共享内存在进程之间共享数据(特别是结构)。 但是，在对保存在不同 .c 文件中的程序使用 fork(
我想在用户集合中使用不同的功能。在 mongo shell 中，我可以像下面这样使用: db.users.distinct("name"); 其中名称是用于区分的集合字段。 同样我想要，在 C
List nastava_izvjestaj = new List(); var data_context = new DataEvidencijaDataContext();
我的 Rails 应用程序中有 Ransack 搜索和 Foundation，本地 css 渲染正常，而生产中的同一个应用程序有一个怪癖: 应用程序中的其他内容完全相同。 我在 Chrome 和 Sa
我是一名优秀的程序员,十分优秀！