Feign 自定义编码器、解码器和客户端,Feign 转发请求头(header参数)、Feign输出Info级别日志

Feign 的编码器、解码器和客户端都是支持自定义扩展，可以对请求以及结果和发起请求的过程进行自定义实现，Feign 默认支持 JSON 格式的编码器和解码器，如果希望支持其他的或者自定义格式就需要编写自己的编码器和解码器，如果希望编写自己的编码器，需要实现 feign.codec.Encoder 接口，解码器需要实现 feign.codec.Decoder 接口，示例如下：

自定义编码器和解码器

自定义编码器

实现的自定义编码器只是输出了需要编码的参数信息，而具体的编码还是使用 JSON 格式，使用了 GsonEncoder 编码器来完成具体的编码工作，参数 object 表示需要进行编码的对象，参数 bodyType 为 object 对象的类型，参数 template 表示的就是请求模板，该方法就是需要实现将参数 object 进行编码并赋值到 template 请求模板中。

package org.lixue.feignclient;

import feign.RequestTemplate;

import feign.codec.EncodeException;

import feign.codec.Encoder;

import feign.gson.GsonEncoder;

import java.lang.reflect.Type;

public class MyEncoder implements Encoder{

private GsonEncoder gsonEncoder;

publicMyEncoder(){

gsonEncoder = new GsonEncoder();

}

public void encode(Object object,Type bodyType,RequestTemplate template) throws EncodeException{

System.out.println("encode object is class"+object.getClass().getName());

System.out.println("encode object is value"+object);

System.out.println("encode bodyType is class"+bodyType.getClass().getName());

System.out.println("encode bodyType is value"+bodyType);

gsonEncoder.encode(object,bodyType,template);

自定义解码器

实现的自定义解码器使用了 GsonDecoder 解码器来完成具体的编码工作，解码器相对简单，只需要从响应中获取响应报文，然后按照指定的编码格式相应的解码并创建指定的类型实例即可。

import feign.FeignException;

import feign.Response;

import feign.codec.DecodeException;

import feign.codec.Decoder;

import feign.gson.GsonDecoder;

import java.io.IOException;

import java.lang.reflect.Method;

public class MyDecoder implements Decoder{

private GsonDecoder gsonDecoder;

publicMyDecoder(){

gsonDecoder=newGsonDecoder();

public Object decode(Response response,Type type)throws IOException,DecodeException,FeignException{

return gsonDecoder.decode(response,type);

测试验证

在完成自定义编码器和解码器的开发后，只需要在 Feign 的 builder 方法中，增加解码器和编码器即可，需要注意的是，如果方法请求参数或返回的不是对象，不需要进行编码或解码，就不能增加编码器或解码器，示例代码如下：

import feign.Feign;

import feign.Logger;

public class Startup{

public static void main(String[]args){

HelloWorldClient speakClient=

Feign.builder().target(HelloWorldClient.class,"http://localhost:8080/");

// 参数和返回都不是对象，不需要附加编码器和解码器

System.out.println(speakClient.speak("isbody"));

HelloWorldClient findByIdClient=

Feign.builder().decoder(new GsonDecoder())

.target(HelloWorldClient.class,"http://localhost:8080/");

// 返回的是对象，需要附加解码器

Person person=findByIdClient.findById(34);

System.out.println("personid="+person.getId()+"age="+person.getAge()+"name="+person.getName()+"message="+person.getMessage());

HelloWorldClient createClient=

Feign.builder().client(newMyClient())

.decoder(newMyDecoder())

.encoder(newMyEncoder())

Person newPerson=new Person();

newPerson.setId(3434);

newPerson.setAge(34);

newPerson.setName("343434");

newPerson.setMessage("33333333333333333");

// 参数和返回都是对象，需要附加解码器和编码器

ReturnValuereturnValue=createClient.create(newPerson);

System.out.println(returnValue.parseString());

自定义 Feign 客户端

Feign 使用一个 feign.Client 接口来发送请求，默认实现是使用 HttpURLConnection 连接 HTTP 服务，我们可以实现 feign.Client 接口来完成自定义 Feign 客户端的开发，该接口只有一个方法 execute ，用于执行请求，下面实现了一个自定义的 Feign 客户端，主要完成了请求的日志记录，示例代码如下：

import feign.Client;

import feign.Request;

import java.util.Collection;

import java.util.Map;

public class MyClient implements Client{

public Response execute(Request request,Request.Options options)throws IOException{

System.out.println("execute request method="+request.method());

System.out.println("execute request headers");

Map<String,Collection<String>> headers=request.headers();

for(Map.Entry<String,Collection<String>> entry:headers.entrySet()){

StringBuilderstringBuilder=newStringBuilder();

for(intj=0;j<entry.getValue().size();j++){

if(stringBuilder.length()>0){

stringBuilder.append(",");

stringBuilder.append(entry.getValue());

System.out.println(entry.getKey()+":"+stringBuilder.toString());

byte[] body=request.body();

if(body!=null){

System.out.println("execute request body="+newString(body));

// 使用 Feign 默认的客户端请求

return new Client.Default(null,null).execute(request,options);

和附加编码器、解码器类似，只需要在 Feign 的 builder 方法中附加自定义的客户端即可，代码如下：

Feign.builder().client(new MyClient())

.decoder(new GsonDecoder())

Feign 转发请求头(header参数)

<code>在做接口请求时，我们经常会在header头中增加一些鉴权信息，如token 或 jwt，那么在通过fegin从A server去调用B server的接口时，如果B server的接口需要header信息，我们需要将A sever获取的header转发到B上。</code>

我们需要实现Feign提供的一个接口<code>RequestInterceptor</code>

<code>@Configuration</code>

<code>public</code> <code>class</code> <code>FeignConfiguration </code><code>implements</code> <code>RequestInterceptor{</code>

<code> </code><code>private</code> <code>final</code> <code>Logger logger = LoggerFactory.getLogger(getClass());</code>

<code> </code><code>@Override</code>

<code> </code><code>public</code> <code>void</code> <code>apply(RequestTemplate template) {</code>

<code> </code><code>ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder</code>

<code> </code><code>.getRequestAttributes();</code>

<code> </code><code>HttpServletRequest request = attributes.getRequest();</code>

<code> </code><code>Enumeration<String> headerNames = request.getHeaderNames();</code>

<code> </code><code>if</code> <code>(headerNames != </code><code>null</code><code>) {</code>

<code> </code><code>while</code> <code>(headerNames.hasMoreElements()) {</code>

<code> </code><code>String name = headerNames.nextElement();</code>

<code> </code><code>String values = request.getHeader(name);</code>

<code> </code><code>template.header(name, values);</code>

<code> </code><code>logger.info(</code><code>"feign interceptor header:{}"</code><code>,template);</code>

<code> </code><code>/* Enumeration<String> bodyNames = request.getParameterNames();</code>

<code> </code><code>StringBuffer body =new StringBuffer();</code>

<code> </code><code>if (bodyNames != null) {</code>

<code> </code><code>while (bodyNames.hasMoreElements()) {</code>

<code> </code><code>String name = bodyNames.nextElement();</code>

<code> </code><code>String values = request.getParameter(name);</code>

<code> </code><code>body.append(name).append("=").append(values).append("&");</code>

<code> </code><code>if(body.length()!=0) {</code>

<code> </code><code>body.deleteCharAt(body.length()-1);</code>

<code> </code><code>template.body(body.toString());</code>

<code> </code><code>//logger.info("feign interceptor body:{}",body.toString());</code>

在<code>@FeignClient</code>注解里面的属性加上<code>configuration = FeignConfiguration.class</code>就可以了。如

<code>@FeignClient</code><code>(name = </code><code>"a-server"</code><code>, configuration = FeignConfiguration.</code><code>class</code><code>)</code>

<code>public</code> <code>interface</code> <code>AServer{</code>

bootstrap.yml增加

Feign 自定义编码器、解码器和客户端,Feign 转发请求头(header参数)、Feign输出Info级别日志

Feign调用开启Hystrix时无法获取ThreadLocal

在项目中使用根据请求头处理异常信息国际化的问题，但是在feign调用的时候无法传递请求头，这个问题看了好久最后才知道feign开启hystrix默认会新建一个线程，而我的请求头数据是通过拦截器放到ThreadLocal里的在新线程就无法获取了

先看一下原来是怎么实现的

首先是header封装类

把请求头封装到ThreadLocal中

每次请求的时候通过filter封装把请求头数据放入context中

但是在feign中开启hystrix的话新线程的ThreadLocal是无法获取主线程的数据的，这个时候就要用到InheritableThreadLocal，只需要改一行代码

InheritableThreadLocal是ThreadLocal的子类，可以解决父线程和子线程的数据传输问题

当在主线程开启一个新线程时，会执行Thread的init方法

init方法中有这么一段代码

当父线程中的inheritableThreadLocal被赋值时，会将当前线程的inheritableThreadLocal变量进行createInheritedMap(),看一下这个方法的具体实现，它会继续调用ThreadLocalMap(parentMap),主要的目的是父线程的变量值赋值给子线程。

当读取ThreadLocal的地方是个线程池的时候，inheritableThreadLocal也会有问题

https://www.jianshu.com/p/24a3614dde41?utm_campaign=maleskine&utm_content=note&utm_medium=seo_notes&utm_source=recommendation

Feign输出Info级别日志

　　spring cloud netfix组件中，feign相关的日志默认是不会输出的，需要自定义配置才能输出，并且Feign只对Debug基本的日志做出响应，实际业务需要输出Info级别的日志，所以需要做自定义配置，覆盖相关配置Bean。

　　Feign客户端可以配置各种的Logger.Level对象，告诉Feign记录哪些日志。Logger.Level的值有以下选择。

　　　　NONE，无记录（DEFAULT）。

　　　　BASIC，只记录请求方法和URL以及响应状态代码和执行时间。

　　　　HEADERS，记录基本信息以及请求和响应标头。

　　　　FULL，记录请求和响应的头文件，正文和元数据。

　　　　根据Feign配置的描述，需要将Logger.Level 配置到客户端中：

Feign 自定义编码器、解码器和客户端,Feign 转发请求头(header参数)、Feign输出Info级别日志

　　　　因为feign只对日志级别为debug级别做出响应，所以如果需要打印出日志，还需要修改客户端的日志级别在application.properties中要设定一行这样的配置：

　　　　　　 logging.level.<你的feign client全路径类名>: DEBUG

　　　　操作完成这三步骤，当调用Send 方法的时候就会打印出Debug级别的日志。

　　在实际生产环境中，我们常常需要使用Info级别日志，使用上述针对对每个客户端的配置进行修改，那样将会有大量的配置。所以，需要将修改Feign的日志，对Info级别进行相应。

Feign 自定义编码器、解码器和客户端,Feign 转发请求头(header参数)、Feign输出Info级别日志

　　自定义一个Logger类，继承Feign.Logger，将代码中的Debug修改成为Info

Feign 自定义编码器、解码器和客户端,Feign 转发请求头(header参数)、Feign输出Info级别日志

　　将自定义Logger类加入到Feign客户端配置的Config中，这样Feign系统间调用就能打印出Info级别的日志。

　　打印出Feign系统间调用Info级别的日志，核心的思想是Spring Boot项目中，能够自定义配置，自定义的配置优先级大于默认的配置。详情参见Spring Boot自定义配置。

Feign 自定义编码器、解码器和客户端,Feign 转发请求头(header参数)、Feign输出Info级别日志

继续阅读

RabbitMQ：消费端自定义监听

TCP连接状态详细解释

分布式配置中心+总线——config+bus前言服务端客户端SpringCloud Bus

Spring Cloud 之Config分布式集中配置中心详解

springcloud-config配置中心分布式管理

Config：分布式中心

【SpringCloud】搭建高可用分布式配置中心（Spring Cloud Config）（一）全过程详解（手动刷新）Spring Cloud 2.0.2.RELEASE

Spring Cloud Config 组件、配合GitHub搭建高可用分布式配置中心

Java网络编程-Socket编程初涉二（基于BIO模型的简易多人聊天室）

@linux查看用户操作的记录

Thrift开发之 windows上安装

在线搭建SpringCloud，一分钟搞定

旋转编码器详解(主要讨论增量式编码器与绝对式编码器)0. 前言1. 旋转编码器的类型和优缺点2. 增量式编码器3. 绝对式编码器4. 增量式编码器和绝对式编码器的区别5. 如何选择编码器

知名测网速工具，已解锁全功能

Java网络编程-Socket编程初涉三（伪异步I/O模型的简易多人聊天室）

sleuth链路追踪