/**
?* CREATE BY songzhongjin ON 2021.05.08 15:58 星期六
?* DESC:feign方式 測(cè)試Deom
?*/
@FeignClient(name = "testService", url = "http://xxxxxx:8088")
public interface FeignTest {
? ? /**
? ? ?* 通過(guò)feign調(diào)用接口
? ? ?* @param map
? ? ?* @return
? ? ?*/
? ? @PostMapping(value = "/xxxxx/sys/login")
? ? String login(Map<String, Object> map);
}

/**
?* CREATE BY songzhongjin ON 2021.05.08 16:02 星期六
?* DESC:
?*/
@RestController
public class Test {
? ? @Autowired
? ? FeignTest feignTest;
? ? @Autowired
? ? MetaDataService metaDataService;
? ? @PostMapping("/test")
? ? public void test() {
? ? ? ? HashMap<String, Object> map = new HashMap<>();
? ? ? ? map.put("user_id", "xxx");
? ? ? ? map.put("password", "xxxxx");
? ? ? ? //調(diào)用 T 具體對(duì)象具體封裝?
? ? ? ? MetaDataResponseVO<T> login = feignTest.login(map);
? ? ? ? List<T> data = login.getData();
? ? ? ? System.out.println(login.getData());
? ? ? ? //處理業(yè)務(wù)data
? ? }
}

@Data
public class MetaDataResponseVO<T> implements Serializable {
? ? private static final long serialVersionUID = 316492198399615153L;
? ? /**
? ? ?* 狀態(tài)碼.
? ? ?*/
? ? private String retcode;
? ? /**
? ? ?* 狀態(tài)碼描述.
? ? ?*/
? ? private String retmsg;
? ? /**
? ? ?* 響應(yīng)包體.
? ? ?*/
? ? private List<T> data;
}

/**
?* feign攔截器配置，調(diào)用前先鑒權(quán).
?*/
@Component
public class MetaDataFeignConfig implements RequestInterceptor {
??? ?public FeignBasicAuthRequestInterceptor() {
? ? }
? ? /**
? ? ?* 給feign請(qǐng)求加上accessToken請(qǐng)求頭.
? ? ?*
? ? ?* @param template
? ? ?*/
? ? @Override
? ? public void apply(RequestTemplate template) {
? ? ? ? //feign加請(qǐng)求頭 自定義fangjia.auth.token"
? ? ? ? template.header("access_token", System.getProperty("fangjia.auth.token"));
? ? }
}

@Configuration
public class FeignConfiguration {
? ? /**
? ? ?* 日志級(jí)別
? ? ?*
? ? ?* @return
? ? ?*/
? ? @Bean
? ? Logger.Level feignLoggerLevel() {
? ? ? ? return Logger.Level.FULL;
? ? }
? ? /**
? ? ?* 創(chuàng)建 Feign 請(qǐng)求攔截器, 在發(fā)送請(qǐng)求前設(shè)置認(rèn)證的 Token, 各個(gè)微服務(wù)將 Token 設(shè)置 到環(huán)境變量中來(lái)達(dá)到通用的目的
? ? ?*
? ? ?* @return
? ? ?*/
? ? @Bean
? ? public FeignBasicAuthRequestInterceptor basicAuthRequestInterceptor() {
? ? ? ? return new FeignBasicAuthRequestInterceptor();
? ? }
}

? ? @Value("${feign-client.meta-data.user}")
? ? private String userId;
? ? @Value("${feign-client.meta-data.password}")
? ? private String password;
? ? private static final String METADATA_ACCESS_TOKEN = "metaDataAccessToken";
? ? /**
? ? ?* 獲取token，設(shè)置到上下文.
? ? ?*/
? ? public void signInMetaData() {
? ? ? ? //拿緩存
? ? ? ? String accessToken = redisUtils.get(METADATA_ACCESS_TOKEN);
? ? ? ? log.warn("-----------從redis拿meta的token結(jié)果--token ={}-------------", accessToken);
? ? ? ? //System.setProperty("fangjia.metadata.token",token) 設(shè)置token值
? ? ? ? System.setProperty("feign.metadata.token", accessToken);
? ? ? ? log.warn("--------------設(shè)置metaData接口鑒權(quán)結(jié)束-----------------");
? ? }

@FeignClient(name = “metaDataClient”, url = “${feign-client.meta-data.url}”, configuration = MetaDataFeignConfig.class)

package com.infinitus.dmm.openapi;
/**
?* 無(wú)限極元數(shù)據(jù)接口.
?*
?* @author 林志鵬
?* @date 2021/5/7
?*/
@FeignClient(name = "metaDataClient", url = "${feign-client.meta-data.url}", configuration = MetaDataFeignConfig.class)
public interface MetaDataClient {
? ? /**
? ? ?* 拉取物理系統(tǒng)列表.
? ? ?*/
? ? @RequestMapping(value = "/sc/mtdsystemlist", method = RequestMethod.GET)
? ? MetaDataResponseVO<MetaDataSystem> pullPhysicalSystemList();

?/**
? ? ?* 拉取物理系統(tǒng)列表.
? ? ?*
? ? ?* @return
? ? ?*/
? ? public List<MetaDataSystem> pullPhysicalSystem() {
? ? ? ? //鑒權(quán)feign
? ? ? ? signInMetaData();
? ? ? ? //業(yè)務(wù)feign
? ? ? ? MetaDataResponseVO<MetaDataSystem> responseVO = metaDataClient.pullPhysicalSystemList();
? ? ? ? if (Objects.nonNull(responseVO)) {
? ? ? ? ? ? List<MetaDataSystem> data = responseVO.getData();
? ? ? ? ? ? if (Objects.nonNull(data) && !data.isEmpty()) {
? ? ? ? ? ? ? ? return data;
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? return new ArrayList<>();
? ? }

@FeignClient(name = “metaDataClient”, url = “${feign-client.meta-data.url}”)

#給metaDataClient服務(wù)設(shè)置超時(shí)時(shí)間 這里metaDataClient是我自己,全局的話metaDataClient替換default
feign:
? client:
? ? config:
? ? ? metaDataClient:
? ? ? ? connect-timeout: 50000
? ? ? ? read-timeout: 50000
? hystrix:
? ? enabled: false

/**
?* Feign請(qǐng)求攔截器配置.
?*
?* @author linzp
?* @version 1.0.0
?* @date 2021/4/16 21:19
?*/
@Configuration
public class FeignInterceptorConfig implements RequestInterceptor {
? ? public FeignInterceptorConfig() {}
? ? @Override
? ? public void apply(RequestTemplate template) {
? ? ? ? ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
? ? ? ? HttpServletRequest request = attributes.getRequest();
? ? ? ? //設(shè)置token到請(qǐng)求頭
? ? ? ? template.header(ConstantCommon.HEADER_TOKEN_KEY, request.getHeader(ConstantCommon.HEADER_TOKEN_KEY));
? ? }
}

# 更換hystrix策略，解決無(wú)法傳遞threadLocal變量問(wèn)題
hystrix:
? ? command:
? ? ? ? default:
? ? ? ? ? ? execution:
? ? ? ? ? ? ? ? isolation:
? ? ? ? ? ? ? ? ? ? strategy: SEMAPHORE