CoApi - 同时支持响应式编程和同步编程模型的 HTTP 客户端

更新内容

• 特性: 新增 WebClientBuilderCustomizer API，以支持自定义 CoApi WebClient.Builder
• 特性: 新增 RestClientBuilderCustomizer API，以支持自定义  CoApi RestClient.Builder

简介

在 Spring Framework 6 中，引入了全新的 HTTP 客户端 - Spring6 HTTP Interface。 该接口允许开发者通过使用 @HttpExchange 注解将 HTTP 服务定义为 Java 接口。

然而，当前版本尚未提供自动配置的支持，需要开发者自己实现配置。

虽然 Spring 生态中已经存在 Spring Cloud OpenFeign ，但它并未支持响应式编程模型。 为解决这个问题，Spring Cloud OpenFeign 推荐了替代方案 feign-reactive。然而，这个替代方案目前已处于不积极维护状态，并且不支持 Spring Boot 3.2.x。

CoApi 应运而生，它提供了类似于 Spring Cloud OpenFeign 的零样板代码自动配置的支持，同时支持响应式编程模型和同步编程模型。开发者只需定义接口，即可轻松使用。

安装

使用 Gradle(Kotlin) 安装依赖

 implementation("me.ahoo.coapi:coapi-spring-boot-starter")

使用 Gradle(Groovy) 安装依赖

 implementation 'me.ahoo.coapi:coapi-spring-boot-starter'

使用 Maven 安装依赖

 <dependency> <groupId>me.ahoo.coapi</groupId> <artifactId>coapi-spring-boot-starter</artifactId> <version>${coapi.version}</version> </dependency>

使用

定义 CoApi - 第三方接口

baseUrl ： 定义请求的基础地址，该参数可以从配置文件中获取，如：baseUrl = "${github.url}"，github.url 是配置文件中的配置项 }

 @CoApi(baseUrl = "${github.url}") public interface GitHubApiClient { @GetExchange("repos/{owner}/{repo}/issues") Flux<Issue> getIssue(@PathVariable String owner, @PathVariable String repo); }

配置文件：

 github: url: https://api.github.com

定义 CoApi - 客户端负载均衡

 @CoApi(serviceId = "github-service") public interface ServiceApiClient { @GetExchange("repos/{owner}/{repo}/issues") Flux<Issue> getIssue(@PathVariable String owner, @PathVariable String repo); }

使用 CoApi

 @RestController class GithubController( private val gitHubApiClient: GitHubApiClient, private val serviceApiClient: ServiceApiClient ) { @GetMapping("/baseUrl") fun baseUrl(): Flux<Issue> { return gitHubApiClient.getIssue("Ahoo-Wang", "CoApi") } @GetMapping("/serviceId") fun serviceId(): Flux<Issue> { return serviceApiClient.getIssue("Ahoo-Wang", "CoApi") } }

案例参考

Example

服务提供者

Example-Provider

• TodoApi : 规定了客户端消费方与服务提供者之间的共同契约，旨在防范重复冗余定义的风险，同时消除了服务提供者实现与客户端 SDK 的不一致性。
• TodoClient : 客户端消费方通过 TodoClient 访问服务提供者的 API。
• TodoController : 服务提供者负责实现 TodoApi 接口。

定义 API

 @HttpExchange("todo") interface TodoApi { @GetExchange fun getTodo(): Flux<Todo> }

定义 Client

 @CoApi(serviceId = "provider-service") interface TodoClient : TodoApi

实现 API

 @RestController class TodoController : TodoApi { override fun getTodo(): Flux<Todo> { return Flux.range(1, 10) .map { Todo("todo-$it") } } }

服务消费者

Example-Consumer

服务消费者通过 @EnableCoApi 注解开启 CoApi 的自动配置。

 @EnableCoApi(apis = [TodoClient::class]) @SpringBootApplication class ConsumerServer

 @RestController class TodoController(private val todoClient: TodoClient) { @GetExchange fun getProviderTodo(): Flux<Todo> { return todoClient.getTodo() } }