public class FeignApiInterceptor implements RequestInterceptor {
 
    /**
     * 統(tǒng)一處理feign的遠(yuǎn)程調(diào)用攔截
     */
    @Override
    public void apply(RequestTemplate requestTemplate) {
        // 遠(yuǎn)程調(diào)用請(qǐng)求增加頭部信息處理(簡(jiǎn)寫(xiě)代碼如下)
		requestTemplate.header("X-SERVICE-NAME", "...");
    }
}

/**
 * restTemplate遠(yuǎn)程調(diào)用請(qǐng)求增加頭部信息處理
 */
@Slf4j
public class RestApiHeaderInterceptor implements ClientHttpRequestInterceptor {
 
    /**
     * 處理restTemplate的請(qǐng)求攔截
     */
    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
        long startTime = System.currentTimeMillis();
        try {
            HttpHeaders headers = request.getHeaders();
            
            // 遠(yuǎn)程調(diào)用請(qǐng)求增加頭部信息處理(簡(jiǎn)寫(xiě)代碼如下)
			requestTemplate.header("X-SERVICE-NAME", "...");
            
            ClientHttpResponse response = execution.execute(request, body);
            
            // 加入鏈路深度Deep
            // ....
            return response;
        } finally {
            // do something
        }
    }
}

@Configuration
@EnableFeignClients(basePackages = NamingConstant.BASE_PACKAGE)
public class DiscoveryClientConfig {
    
    //......
    
    /**
     * feign請(qǐng)求攔截器
     */
    @Bean
    public RequestInterceptor feignInterceptor() {
        return new FeignApiInterceptor();
    }
    
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(HttpClient httpClient,
                                     Environment environment) {
        RestTemplate restTemplate = new RestTemplate();
        restTemplateBuilder.configure(restTemplate);
        restTemplate.setRequestFactory(buildFactory(httpClient, environment));
        // 加入自定義攔截器
        restTemplate.getInterceptors().add(new RestApiHeaderInterceptor());
        return restTemplate;
    }
    
}

@Slf4j
public class RestApiHeaderInterceptor implements ClientHttpRequestInterceptor {
 
    /**
     * 處理restTemplate的請(qǐng)求攔截
     */
    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
        long startTime = System.currentTimeMillis();
        try {
            // 遠(yuǎn)程調(diào)用請(qǐng)求增加頭部信息處理
            ClientHttpResponse response = execution.execute(request, body);
            // 獲取傳遞線(xiàn)程變量
            Collection<String> values = response.getHeaders()
                    .get(TraceUtil.TRACE_RPCCOUNT);
            if (!CollectionUtils.isEmpty(values)) {
                int value = Integer.valueOf(values.iterator().next());
                // 鏈路深度追加
                TraceUtil.getRpcCounter().addAndGet(value + 1);
            }
            return response;
        } finally {
            // 是否開(kāi)啟鏈路追蹤
            if (TraceUtil.isTraceLoggerOn()) {
                // 輸出鏈路日志(接口耗時(shí))
                TraceUtil.log(StringHelper.join("dt:", System.currentTimeMillis() - startTime,
                        ", TRACE-RPC-", request.getMethod(),
                        ", URI:", request.getURI()));
            }
        }
    }
}

public abstract class BaseWebFilter extends OncePerRequestFilter {
 
    /**
     * 返回類(lèi)名，避免filter不被執(zhí)行
     */
    @Override
    protected String getFilterName() {
        return null;
    }
}

@Override
public BaseWebFilter getFilterInstance() {
    return new BaseWebFilter() {
        @Override
        protected void doFilterInternal(HttpServletRequest request,
                                        HttpServletResponse response, FilterChain chain)
            throws ServletException, IOException {
            // 攔截校驗(yàn)
            if (validateToken(request)) {
                // 校驗(yàn)通過(guò)執(zhí)行下一個(gè)lan'j
                chain.doFilter(request, response);
            } else {
                // 封裝統(tǒng)一認(rèn)證失敗返回信息
                response.setStatus(401);
                response.setCharacterEncoding(
                    Charset.defaultCharset().displayName());
                response.setContentType(
                    MimeTypeUtils.APPLICATION_JSON.toString());
                response.getWriter().println(JsonUtil.toJsonString(Response
                                                                   .err("status.401")));
            }
        }
    };
}

private boolean validateToken(HttpServletRequest request) {
		if (!needValidate(request)) {
			return true;
		}
		String security = resolveToken(request);
		if (security == null) {
			log.info("驗(yàn)證信息缺失，請(qǐng)求地址：{}", request.getRequestURI());
			return false;
		}
		try {
            // 解析security加密規(guī)則
			return true;
		} catch (Exception e) {
			log.info("驗(yàn)證信息無(wú)效：{}，請(qǐng)求地址：{}", security, request.getRequestURI());
			return false;
		}
	}