X-Real-IP feign传递

order-application-service/src/main/java/cn/freemud/config/FeignSupportConfig.java

+package cn.freemud.config;
+
+import cn.freemud.interceptor.FeignInterceptor;
+import feign.RequestInterceptor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class FeignSupportConfig {
+    /**
+     * feign请求拦截器
+     *
+     * @return
+     */
+    @Bean
+    public RequestInterceptor requestInterceptor(){
+        return new FeignInterceptor();
+    }
+}

order-application-service/src/main/java/cn/freemud/interceptor/FeignInterceptor.java

+package cn.freemud.interceptor;
+
+import cn.freemud.utils.AppLogUtil;
+import com.alibaba.fastjson.JSON;
+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;
+import java.util.Enumeration;
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+@Configuration
+public class FeignInterceptor implements RequestInterceptor {
+    @Override
+    public void apply(RequestTemplate requestTemplate) {
+        Map<String, String> headers = getHeaders(getHttpServletRequest());
+        for(String headerName : headers.keySet()){
+            requestTemplate.header(headerName, getHeaders(getHttpServletRequest()).get(headerName));
+        }
+    }
+    private HttpServletRequest getHttpServletRequest() {
+        try {
+            return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        } catch (Exception e) {
+            AppLogUtil.errorLog("FeignInterceptor error {}", "","", e);
+            return null;
+        }
+    }
+    private Map<String, String> getHeaders(HttpServletRequest request) {
+        Map<String, String> map = new LinkedHashMap<>();
+        Enumeration<String> enumeration = request.getHeaderNames();
+        while (enumeration.hasMoreElements()) {
+            String key = enumeration.nextElement();
+            if(needThisHeader(key)){
+                String value = request.getHeader(key);
+                map.put(key, value);
+            }
+        }
+        AppLogUtil.printLog("clientIp for feign client info:" + JSON.toJSONString(map), "","");
+        return map;
+    }
+
+    private boolean needThisHeader(String headerName){
+        // TODO:过滤哪些header需要传递，千万不能把所有的header传下去
+        return true;
+    }
+}