💝💝💝欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。
一.简单介绍
1.什么是 FeignClient?
@FeignClient
是 Spring Cloud 中的一个注解,用于创建基于接口的声明式服务客户端。它是在微服务架构中用于进行服务之间通信的一种方式。通过 @FeignClient
,您可以定义一个接口,该接口包含要调用的远程服务的方法,而 Feign 将自动处理底层的 HTTP 请求和负载均衡。
2.FeignClient 优点?
@FeignClient
在微服务架构中的使用具有多个优点和特点,这使得它成为一个方便且强大的工具:
-
声明式 REST 客户端:
@FeignClient
允许您使用声明式的方式定义服务间的 HTTP 调用。通过简单地定义一个接口,而不需要手动编写 HTTP 请求,您可以将服务调用抽象为接口的方法。 -
集成了 Ribbon 负载均衡:
@FeignClient
集成了 Netflix 的 Ribbon 负载均衡器,自动处理了服务的负载均衡。这使得微服务之间的调用更加健壮和可靠。 -
支持服务发现: 默认情况下,
@FeignClient
集成了 Eureka 服务发现,允许您使用服务的逻辑名称而不是直接的 IP 地址进行服务调用。这增加了服务调用的灵活性。 -
支持多种注解: 除了
@FeignClient
,Feign 还支持一系列其他的注解,如@RequestMapping
、@RequestParam
等,使得您可以在接口上使用这些注解定义 HTTP 请求的各个方面。 -
集成了 Hystrix 进行服务降级:
@FeignClient
支持集成 Hystrix,可以通过设置fallback
或fallbackFactory
属性,定义服务降级的逻辑。当远程服务不可用时,可以提供备选方案,防止整个系统崩溃。 -
支持自定义配置: 通过
configuration
属性,您可以自定义 Feign 客户端的配置,包括连接超时、读取超时、重试策略等。这使得您可以根据实际需求进行灵活的配置。 -
集成了 Spring Cloud Contract: Spring Cloud Contract 可以通过测试契约来确保服务之间的契约一致性。
@FeignClient
集成了 Spring Cloud Contract,使得可以通过契约来测试和验证服务之间的通信。 -
简化代码: 使用
@FeignClient
可以大大简化微服务之间的通信代码。由于 Feign 处理了底层的 HTTP 请求和负载均衡,开发者只需要关注业务逻辑,使得代码更加清晰简洁。
@FeignClient
是一个强大的工具,它简化了微服务之间的通信,提高了开发效率,同时集成了一系列的微服务治理功能,使得服务调用更加可靠和灵活。
二.基本使用
1.引入依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
<version>2.2.2.RELEASE</version>
</dependency>
2.获取 token 接口
@FeignClient(
url = "${xxx.open-api.host}",
value = "xxx-open-api",
contextId = "oauth",
path = "/cas/oauth"
)
public interface AuthOpenApi {
@Log("xxx-open-api,获取token")
@GetMapping("/token")
TokenResponse getToken(@SpringQueryMap GetTokenRequest request);
}
3.RequestParam
请求参数类
@Data
public class GetTokenRequest {
private String scope = "xxx";
private String grant_type = "xxx";
private String client_id;
private String client_secret;
public GetTokenRequest() {
this.client_id = SpringContextHolder.getBean(OpenApiProperties.class).getClientId();
this.client_secret = SpringContextHolder.getBean(OpenApiProperties.class).getSecret();
}
}
4.Interceptor
@Slf4j
public class OpenApiRequestInterceptor implements RequestInterceptor {
@Autowired
private JedisClient JedisClient;
@Autowired
private AuthOpenApi AuthOpenApi;
@Autowired
private OpenApiProperties OpenApiProperties;
@Override
public void apply(RequestTemplate requestTemplate) {
String accessToken = JedisClient.get(CommonConstant.REDIS__KEY_PREFIX + "accessToken");
if (StringUtils.isEmpty(accessToken)) {
TokenResponse response = AuthOpenApi.getToken(new GetTokenRequest());
if (response.getCode() != 200) {
throw new ApplicationException("获取 accessToken失败");
}
accessToken = response.getData().getAccessToken();
final int expiresIn = response.getData().getExpiresIn();
log.info("apply() called with: expiresIn = [" + expiresIn + "]");
JedisClient.set(CommonConstant.REDIS__KEY_PREFIX + "accessToken", accessToken, Math.max(expiresIn - 10, 1));
}
long timestamp = System.currentTimeMillis();
String requestId = UUID.randomUUID().toString();
String str = OpenApiProperties.getClientId() + timestamp + requestId + accessToken + this.OpenApiProperties.getSecret();
String signature = DigestUtils.md5Hex(str).toUpperCase();
requestTemplate.header("clientId", this.OpenApiProperties.getClientId());
requestTemplate.header("timestamp", timestamp + "");
requestTemplate.header("requestId", requestId);
requestTemplate.header("signatureMethod", "MD5");
requestTemplate.header("accessToken", accessToken);
requestTemplate.header("signature", signature);
}
}
5.配置文件类
@Configuration
@ConfigurationProperties(prefix = "open-api")
@Data
public class OpenApiProperties {
private String url;
private String clientId;
private String secret;
private String aesKey;
private String aesIv;
}
@EnableFeignClients
@Configuration
public class OpenFeignConfig {
}
6.业务接口
@FeignClient(
url = "${open-api.host}",
value = "open-api",
configuration = {
OpenApiRequestInterceptor.class
},
contextId = "picAuth",
path = "/permission-portal/picture/auth"
)
public interface PicOpenApi {
@Log("open-api,图片授权模块")
@GetMapping
PicResultDto auth(@RequestParam(value = "userNo") String userNo);
}
7.yaml 配置文件
open-api:
host: xxxxx
clientId: insight
secret: xxxx
aesKey: xxxx
aesIv: xxxx
8.使用总结
首先用@FeignClient 定义了 2 个接口,一个是获取 token 的接口,一个是获取图片权限的接口,在获取图片权限的接口中添加了 configuration 属性,该属性指向 OpenApiRequestInterceptor 类,在请求获取图片接口的时候,会前置处理拦截器中的逻辑,在拦截器中我们调用的是获取 token 的接口,并解析返回结果,放入到了 http 的请求头中,非常方便的给获取图片的接口添加了 header 鉴权信息。
三.原理解析
1.value/name
value/name: 用于指定目标服务的名称。value
和 name
都可以用来设置服务的名称,它们是互换的。这是 @FeignClient
唯一需要指定的参数。
@FeignClient(value = "example-service")
public interface ExampleFeignClient {
// ...
}
2.url
url: 如果不想使用服务发现,可以使用 url
参数指定目标服务的 URL。这个 URL 可以是完整的服务地址。
@FeignClient(url = "http://example.com")
public interface ExampleFeignClient {
// ...
}
3.path
path: 用于为 Feign 客户端的所有请求添加一个基本路径。
@FeignClient(value = "example-service", path = "/api")
public interface ExampleFeignClient {
// ...
}
4.configuration
configuration: 用于指定 Feign 客户端的配置类,可以配置连接超时、重试策略、拦截器等。可以指定一个,也可以指定多个,非常给力的功能参数。
@FeignClient(value = "example-service", configuration = MyFeignConfig.class)
public interface ExampleFeignClient {
// ...
}
5.fallback
fallback: 用于指定一个降级处理的类,当调用失败时会执行该类的方法。
@FeignClient(value = "example-service", fallback = ExampleFallback.class)
public interface ExampleFeignClient {
// ...
}
6.fallbackFactory
fallbackFactory: 与 fallback
类似,用于指定一个降级处理的工厂类,可以在工厂类中对异常进行更详细的处理。
@FeignClient(value = "example-service", fallbackFactory = ExampleFallbackFactory.class)
public interface ExampleFeignClient {
// ...
}
7.decode404
decode404: 默认情况下,Feign 不会解码 404 响应。通过设置 decode404 = true
,可以让 Feign 解码 404 响应。
@FeignClient(value = "example-service", decode404 = true)
public interface ExampleFeignClient {
// ...
}
@FeignClient
注解的参数,提供了灵活性和配置选项,以适应不同的微服务调用场景。Feign 会根据这些参数配置底层的 HTTP 请求,实现服务之间的通信。
觉得有用的话点个赞
👍🏻
呗。
❤️❤️❤️本人水平有限,如有纰漏,欢迎各位大佬评论批评指正!😄😄😄
原文地址:https://blog.csdn.net/qyj19920704/article/details/134679445
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_49684.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!