通用feign客户端

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/service/RemoteService.java.ftl

+<#ibiztemplate>
+TARGET=PSSYSTEM
+</#ibiztemplate>
+package ${pub.getPKGCodeName()}.util.service;
+
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.alibaba.fastjson.support.config.FastJsonConfig;
+import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
+import com.alibaba.fastjson.support.springfox.SwaggerJsonSerializer;
+import feign.*;
+import feign.codec.Decoder;
+import org.springframework.beans.factory.ObjectFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
+import org.springframework.cloud.openfeign.FeignContext;
+import org.springframework.cloud.openfeign.support.SpringDecoder;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.concurrent.ConcurrentHashMap;
+
+
+/**
+ * 自定义feigen客户端配置
+ *
+ * @author
+ */
+@Service
+public class RemoteService {
+
+    /**
+     * FeignClientFactoryBean 该工厂类中 设置builder属性时就是通过该对象，源码中可看到
+     */
+    @Autowired
+    protected FeignContext feignContext;
+
+    /**
+     * FeignClient 默认LoadBalancerFeignClient
+     */
+    @Autowired
+    private Client feignClient;
+
+
+    private static final Map<String, Object> FEIGN_CLIENTS = new ConcurrentHashMap<>();
+
+    /**
+     * 定义远程通用接口
+     */
+    public interface RemoteFeignClient {
+        @RequestMapping(method = RequestMethod.POST, value = "/{path}")
+        JSONObject post( @PathVariable("path") String path, @RequestHeader("Authorization") String token,@RequestBody Map  param);
+
+        @RequestMapping(method = RequestMethod.GET, value = "/{path}")
+        JSONObject request( @PathVariable("path") String path, @RequestHeader("Authorization") String token,Map  param);
+
+        @RequestMapping(method = RequestMethod.GET, value = "/{path}")
+        JSONObject get( @PathVariable("path") String path, @RequestHeader("Authorization") String token);
+
+        @RequestMapping(method = RequestMethod.PUT, value = "/{path}")
+        JSONObject put( @PathVariable("path") String path, @RequestHeader("Authorization") String token,@RequestBody Map  param);
+
+        @RequestMapping(method = RequestMethod.DELETE, value = "/{path}")
+        JSONObject delete( @PathVariable("path") String path, @RequestHeader("Authorization") String token);
+    }
+
+    /**
+     * @param serverId
+     * @return
+     */
+    public RemoteFeignClient getClient(String serverId) {
+        return this.create(RemoteFeignClient.class, serverId);
+    }
+
+    /**
+     * 设置编码解码器为FastJson
+     *
+     * @param clazz
+     * @param serviceId
+     * @param <T>
+     * @return
+     */
+    private <T> T create(Class<T> clazz, String serviceId) {
+        Object object = FEIGN_CLIENTS.get(serviceId);
+        if (Objects.isNull(object)) {
+            object = Feign.builder()
+                    //decoder指定对象解码方式
+                    .decoder(this.feignDecoder())
+                    .client(feignClient)
+                    //options方法指定连接超时时长及响应超时时长
+                    .options(new Request.Options(5000, 5000))
+                    //retryer方法指定重试策略
+                    //.retryer(new Retryer.Default(5000, 5000, 3))
+                    .contract(feignContext.getInstance(serviceId, Contract.class))
+                    //target方法绑定接口与服务端地址。返回类型为绑定的接口类型。
+                    .target(clazz, "http://"+serviceId);
+            FEIGN_CLIENTS.put(serviceId, object);
+        }
+
+        return (T) object;
+    }
+
+    private Decoder feignDecoder() {
+        return new SpringDecoder(feignHttpMessageConverter());
+    }
+
+    /**
+     * 设置解码器为fastjson
+     *
+     * @return
+     */
+    private ObjectFactory<HttpMessageConverters> feignHttpMessageConverter() {
+        final HttpMessageConverters httpMessageConverters = new HttpMessageConverters(this.getFastJsonConverter());
+        return () -> httpMessageConverters;
+    }
+
+    private FastJsonHttpMessageConverter getFastJsonConverter() {
+        FastJsonHttpMessageConverter converter = new FastJsonHttpMessageConverter();
+
+        List<MediaType> supportedMediaTypes = new ArrayList<>();
+        MediaType mediaTypeJson = MediaType.valueOf(MediaType.APPLICATION_JSON_UTF8_VALUE);
+        supportedMediaTypes.add(mediaTypeJson);
+        converter.setSupportedMediaTypes(supportedMediaTypes);
+        FastJsonConfig config = new FastJsonConfig();
+        config.getSerializeConfig().put(JSON.class, new SwaggerJsonSerializer());
+        config.setSerializerFeatures(SerializerFeature.DisableCircularReferenceDetect);
+        converter.setFastJsonConfig(config);
+
+        return converter;
+    }
+
+    @Configuration
+    public class FeignTokenInterceptor implements RequestInterceptor {
+
+
+        @Override
+        public void apply(RequestTemplate template) {
+
+            HttpServletRequest request = getServletRequest();
+            if (null == request){
+                return;
+            }
+
+            template.header("uid", getHeaders(request));
+        }
+
+        private HttpServletRequest getServletRequest() {
+            return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        }
+
+        private String getHeaders(HttpServletRequest request){
+            return request.getHeader("uid");
+        }
+
+
+    }
+}
\ No newline at end of file