Feign调用添加验证信息token到请求头
1、这是最简单的一个方法
但是需要对每个调用都一一添加,就是使用@RequestHeader注解添加参数到请求头中去
1
2
3
4
5
6
7
8
9
|
@FeignClient (name = "capability-register" , fallback = ApiServiceClientFallBack. class ) public interface ApiServiceClient { @GetMapping ( "/apiDebug/" ) Result debug( @RequestParam ( "url" ) String path, @RequestParam ( "param" ) String param, @RequestParam ( "method" ) String method, @RequestParam ( "appKey" ) String appKey, @RequestHeader (name = "Token" ,required = true ) String Token); } |
这里需要注意,其他几个参数都是调用debug接口需要的参数,使用此接口时,直接获取验证信息放进token中,就可以了
2、这个方法是网上大多数人的用法
但是我看到一个大神的博客,说是这种方法有点不好,然后大神自定义了一个Hystrix的策略,这个第三种方法再讲
这种方法是对所有的feign调用统一设置请求头
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
package com.hiynn.provider.configuration; import feign.RequestInterceptor; import feign.RequestTemplate; import org.springframework.context.annotation.Configuration; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest; /** * @author lidai * @date 2019/2/27 16:14 * <p> * Feign调用的时候添加请求头Token */ @Configuration public class FeignConfiguration implements RequestInterceptor { @Override public void apply(RequestTemplate requestTemplate) { ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); HttpServletRequest request = attributes.getRequest(); requestTemplate.header( "Token" , request.getHeader( "Token" )); } } |
有了configuration之后还需要再feign添加configuration属性
1
2
3
4
5
6
7
8
9
|
@FeignClient (name = "capability-register" , fallback = ApiServiceClientFallBack. class ,configuration = FeignConfiguration. class ) public interface ApiServiceClient { @GetMapping ( "/apiDebug/" ) Result debug( @RequestParam ( "url" ) String path, @RequestParam ( "param" ) String param, @RequestParam ( "method" ) String method, @RequestParam ( "appKey" ) String appKey); } |
到这里的时候,如果你debug的话,会发现FeignConfiguration中的attributes获取不到,需要再配置文件中添加如下配置就可以了
1
2
3
4
5
6
|
hystrix: command: default: execution: isolation: strategy: SEMAPHORE |
3、第三种方法就是大神的方法了
和第二种方法的区别就是不需要添加配置文件,但是FeignConfiguration这个还是要的,不需要加配置文件就加一个自定义策略
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
package com.hiynn.provider.configuration; import com.netflix.hystrix.HystrixThreadPoolKey; import com.netflix.hystrix.HystrixThreadPoolProperties; import com.netflix.hystrix.strategy.HystrixPlugins; import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy; import com.netflix.hystrix.strategy.concurrency.HystrixRequestVariable; import com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableLifecycle; import com.netflix.hystrix.strategy.eventnotifier.HystrixEventNotifier; import com.netflix.hystrix.strategy.executionhook.HystrixCommandExecutionHook; import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisher; import com.netflix.hystrix.strategy.properties.HystrixPropertiesStrategy; import com.netflix.hystrix.strategy.properties.HystrixProperty; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Configuration; import org.springframework.web.context.request.RequestAttributes; import org.springframework.web.context.request.RequestContextHolder; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; /** * @author lidai * @date 2019/3/18 10:09 */ @Slf4j @Configuration public class FeignHystrixConcurrencyStrategy extends HystrixConcurrencyStrategy { private HystrixConcurrencyStrategy delegate; public FeignHystrixConcurrencyStrategy() { try { this .delegate = HystrixPlugins.getInstance().getConcurrencyStrategy(); if ( this .delegate instanceof FeignHystrixConcurrencyStrategy) { // Welcome to singleton hell... return ; } HystrixCommandExecutionHook commandExecutionHook = HystrixPlugins.getInstance().getCommandExecutionHook(); HystrixEventNotifier eventNotifier = HystrixPlugins.getInstance().getEventNotifier(); HystrixMetricsPublisher metricsPublisher = HystrixPlugins.getInstance().getMetricsPublisher(); HystrixPropertiesStrategy propertiesStrategy = HystrixPlugins.getInstance().getPropertiesStrategy(); this .logCurrentStateOfHystrixPlugins(eventNotifier, metricsPublisher, propertiesStrategy); HystrixPlugins.reset(); HystrixPlugins.getInstance().registerConcurrencyStrategy( this ); HystrixPlugins.getInstance().registerCommandExecutionHook(commandExecutionHook); HystrixPlugins.getInstance().registerEventNotifier(eventNotifier); HystrixPlugins.getInstance().registerMetricsPublisher(metricsPublisher); HystrixPlugins.getInstance().registerPropertiesStrategy(propertiesStrategy); } catch (Exception e) { log.error( "Failed to register Sleuth Hystrix Concurrency Strategy" , e); } } private void logCurrentStateOfHystrixPlugins(HystrixEventNotifier eventNotifier, HystrixMetricsPublisher metricsPublisher, HystrixPropertiesStrategy propertiesStrategy) { if (log.isDebugEnabled()) { log.debug( "Current Hystrix plugins configuration is [" + "concurrencyStrategy [" + this .delegate + "]," + "eventNotifier [" + eventNotifier + "]," + "metricPublisher [" + metricsPublisher + "]," + "propertiesStrategy [" + propertiesStrategy + "]," + "]" ); log.debug( "Registering Sleuth Hystrix Concurrency Strategy." ); } } @Override public <T> Callable<T> wrapCallable(Callable<T> callable) { RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes(); return new WrappedCallable<>(callable, requestAttributes); } @Override public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey, HystrixProperty<Integer> corePoolSize, HystrixProperty<Integer> maximumPoolSize, HystrixProperty<Integer> keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) { return this .delegate.getThreadPool(threadPoolKey, corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue); } @Override public ThreadPoolExecutor getThreadPool(HystrixThreadPoolKey threadPoolKey, HystrixThreadPoolProperties threadPoolProperties) { return this .delegate.getThreadPool(threadPoolKey, threadPoolProperties); } @Override public BlockingQueue<Runnable> getBlockingQueue( int maxQueueSize) { return this .delegate.getBlockingQueue(maxQueueSize); } @Override public <T> HystrixRequestVariable<T> getRequestVariable(HystrixRequestVariableLifecycle<T> rv) { return this .delegate.getRequestVariable(rv); } static class WrappedCallable<T> implements Callable<T> { private final Callable<T> target; private final RequestAttributes requestAttributes; public WrappedCallable(Callable<T> target, RequestAttributes requestAttributes) { this .target = target; this .requestAttributes = requestAttributes; } @Override public T call() throws Exception { try { RequestContextHolder.setRequestAttributes(requestAttributes); return target.call(); } finally { RequestContextHolder.resetRequestAttributes(); } } } } |
加上这个就可以了,亲测三种方法均可行。
Feign中增加请求头
最近遇到项目在调用
实现RequestInterceptor 接口,然后可以根据feignClient中的值加到请求头中,使用时候在feignClient中配置,这样就可以把参数传入feign中
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
import com.alibaba.fastjson.JSONObject; import com.google.common.collect.Lists; import feign.RequestInterceptor; import feign.RequestTemplate; import org.apache.commons.collections4.CollectionUtils; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.Map; public class FeignConfiguration implements RequestInterceptor { @Override public void apply(RequestTemplate template) { List<String> list = new ArrayList<>(); if ( "get" .equalsIgnoreCase(template.method())){ Map<String, Collection<String>> queries = template.queries(); list = (List<String>) queries.get( "key" ); } else if ( "post" .equalsIgnoreCase(template.method())){ byte [] body = template.body(); Map<String, Object> map = JSONObject.parseObject(body, Map. class ); Object key = map.get( "key" ); if (key != null ){ list.add(key.toString()); } } if (CollectionUtils.isNotEmpty(list)) { template.header( "head" , list); } } } |
1
2
3
4
5
6
7
8
9
10
11
|
import com.hbasesoft.vcc.sgp.integral.goods.config.FeignConfiguration; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam; @FeignClient (name = "test" , path = "/test" , configuration = FeignConfiguration. class ) public interface ErpGoodsCouponsExternalClient { @GetMapping ( "/url" ) Object getData( @RequestParam ( "key" ) String key); } |
以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。
原文链接:https://blog.csdn.net/lidai352710967/article/details/88680173