【SpringCloud系列】@FeignClient微服务轻舞者

本文介绍: 是 Spr in g Clo u d 中的一个注解，用于创建基于接口的声明式服务客户端。它是在微服务架构中用于进行服务之间通信的一种方式。通过，您可以定义一个接口，该接口包含要调用的远程服务的方法，而 Fe ign 将自动处理底层的 HTTP 请求和负载均衡。

@FeignClient 是 Sp r ing Clo u d 中的一个注解，用于创建基于接口的声明式服务客户端。它是在微服务架构中用于进行服务之间通信的一种方式。通过 @FeignClient，您可以定义一个接口，该接口包含要调用的远程服务的方法，而 Feign 将自动处理底层的 HTTP 请求和负载均衡。

@FeignClient 在微服务架构中的使用具有多个优点和特点，这使得它成为一个方便且强大的工具：

@FeignClient 是一个强大的工具，它简化了微服务之间的通信，提高了开发效率，同时集成了一系列的微服务治理功能，使得服务调用更加可靠和灵活。

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-openfeign</artifactId>
  <version>2.2.2.RELEASE</version>
</dependency>

使用 FeignClient 封装获取 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);
}

请求参数类

@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();
    }
}

拦截器,用于给 FeignClient 添加自定义拦截器

@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);
    }
}

@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 {
}

@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);
}

open-api:
  host: xxxxx
  clientId: insight
  secret: xxxx
  aesKey: xxxx
  aesIv: xxxx

value/name: 用于指定目标服务的名称。value 和 name 都可以用来设置服务的名称，它们是互换的。这是 @FeignClient 唯一需要指定的参数。

@FeignClient(value = "example-service")
public interface ExampleFeignClient {
    // ...
}

url: 如果不想使用服务发现，可以使用 url 参数指定目标服务的 URL。这个 URL 可以是完整的服务地址。

@FeignClient(url = "http://example.com")
public interface ExampleFeignClient {
    // ...
}

@FeignClient(value = "example-service", path = "/api")
public interface ExampleFeignClient {
    // ...
}

@FeignClient(value = "example-service", configuration = MyFeignConfig.class)
public interface ExampleFeignClient {
    // ...
}

@FeignClient(value = "example-service", fallback = ExampleFallback.class)
public interface ExampleFeignClient {
    // ...
}

fallbackFactory: 与 fallback 类似，用于指定一个降级处理的工厂类，可以在工厂类中对异常进行更详细的处理。

@FeignClient(value = "example-service", fallbackFactory = ExampleFallbackFactory.class)
public interface ExampleFeignClient {
    // ...
}

decode404: 默认情况下，Feign 不会解码 404 响应。通过设置 decode404 = true，可以让 Feign 解码 404 响应。

@FeignClient(value = "example-service", decode404 = true)
public interface ExampleFeignClient {
    // ...
}

@FeignClient 注解的参数，提供了灵活性和配置选项，以适应不同的微服务调用场景。Feign 会根据这些参数配置底层的 HTTP 请求，实现服务之间的通信。

显示所有内容

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。

spring 接口服务

博客 目录

一.简单 介绍

1.什么是 FeignClie nt?

2.FeignClie nt 优点?

二.基本 使用

1.引入 依赖

2.获取 token 接口

3.RequestPa ram

4.Interc eptor

5.配置文件类

6.业务接口

7.yaml 配置文件

8.使用总结

三.原理 解析

1.value/name

2.url

3.path

4.configuration

5.fa ll back

6.fa llbackFactory

7.decode404

发表回复取消回复

一.简单介绍

1.什么是 FeignClient?

2.FeignClient 优点?

二.基本使用

1.引入依赖