feign的使用
一、概述
二、feign的使用流程
2.1 在pom文件中添加依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.2 feign的配置
2.2.1 修改日志级别
feign.Logger.Level : 包含四种不同的级别:NONE、BASIC、HEADERS、FULL
NONE:没有任何日志,也是默认配置;
BASIC:可以记录http请求什么时候发送,什么时候结束,耗时多久等基本信息;
HEADERS:除了BASIC中含有的以外,还包含请求头和响应头;
FULL:是最全面的,除了HEADERS中包含的以外,还包含请求体信息和响应体信息。
2.2.1.1 在yml中配置
feign:
client:
config:
userservice: # 针对某个微服务的配置
#default: # 这里用default就是全局配置,如果是写服务名称,则是针对某个微服务的配置
loggerLevel: FULL # 日志级别
2.2.1.2 在代码中写配置类
public class DefaultFeignConfiguration {
@Bean
public Logger.Level logLevel(){
return Logger.Level.BASIC;
}
}
想要局部生效时,就在Feign的具体的接口上的注解上添加configuration = FeignConfiguration.class
@FeignClient(value = "userservice",configuration = DefaultFeignConfiguration.class)
public interface TopoClient {
/**
* 获取关联拓扑
* @param param
* @return
*/
@PostMapping("/api/topo/cmnet/getSerchCmNetTopo")
public BTopo getSerchCmNetTopo(@RequestBody QueryRelParam param);
}
全局生效,在启动类添加EnableFeignClients注解 设置defaultConfiguration 属性;如果只有一个client可以使用clients=类.class,如果多个可以直接扫包
@EnableFeignClients(basePackages = {"com.softwaregroup.communication.topo"}, defaultConfiguration = DefaultFeignConfiguration.class)
2.2.2 响应结果解析器
feign.codec.Decoder: http远程调用的结果做解析,例如解析json字符串为java对象
2.2.3 请求参数编码
feign.codec.Encoder: 将请求参数编码,便于通过http请求发送
2.2.4 支持的注解格式
feign. Contract : 默认是SpringMVC的注解
2.2.5 失败的重试机制
feign. Retryer : 请求失败的重试机制,默认是没有,不过会使用Ribbon的重试
2.3 Nacos支持Feign,可以直接在接口基础上实现负载均衡效果
微服务名称:nrms-topo-ip
@SpringCloudApplication
@EnableDiscoveryClient
@EnableFeignClients(basePackages = {"com.softwaregroup.communication.topo"})
@Slf4j
public class TopoDataPluginDataNetwork {
}
@FeignClient(name = "nrms-topo-cmnet",
configuration = FeignClientsConfiguration.class)
public interface CmNetClientFeign {
/**
* 获取关联拓扑
* @param param
* @return
*/
@PostMapping("/api/topo/getSerchTopo")
public BTopo getSerchTopo(@RequestBody QueryRelParam param);
}
注意!
/**
* @author: zhang
* @date: Created in 2024/7/9 20:24
* 文件说明: <p>Feign 调用增强请求头,防止登录信息无法传递而被服务拦截
*/
@Component
public class FeignInterceptor implements RequestInterceptor {
@Override
public void apply(RequestTemplate requestTemplate) {
//获取客户端访问的请求
ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
if(requestAttributes != null){
HttpServletRequest request = requestAttributes.getRequest();
if (request != null) {
String cookie = request.getHeader("Cookie");
String token = request.getHeader("Authorization");
//同步到 feign 请求中
requestTemplate.header("Cookie", cookie);
requestTemplate.header("Authorization", token);
return;
}
}
}
}
在控制层中引入cmNetClientFeign便可以直接通过cmNetClientFeign调用另一个微服务的接口
@Resource
private CmNetClientFeign cmNetClientFeign;
具体实现控制层
@RestController
@RequestMapping("/api")
@Slf4j
public class CmNetController {
@PostMapping("/topo/getSerchTopo")
public BTopo getSerchCmNetTopo(@RequestBody QueryRelParam param) {
return cmNetService.getSerchCmNetTopo(param);
}
}