spring - 对假客户端的响应式(Reactive)支持

Question

我计划使用 spring webflux 将我的微服务从阻塞实现重构为响应式(Reactive) API。我有几个疑问:

1)是否选择基于注解的 Controller 或功能路由器？
2) 是否支持响应式(Reactive)假装客户端？

请帮忙。

Answer 1

我发现这个问题不完整，没有关于如何设置的正确使用示例。
由于 op 没有提到目标语言，我想分享适用于我的情况的 Kotlin 设置:
build.gradle.kts

implementation("org.springframework.boot:spring-boot-starter-webflux")
implementation("com.playtika.reactivefeign:feign-reactor-core:2.0.22")
implementation("com.playtika.reactivefeign:feign-reactor-spring-configuration:2.0.22")
implementation("com.playtika.reactivefeign:feign-reactor-webclient:2.0.22")

配置.kt

@Configuration
@EnableWebFlux
@EnableReactiveFeignClients
class Config {
}

MyFeignClient.kt

@Component
@ReactiveFeignClient(
        url = "\${package.service.my-service-url}",
        name = "client"
)
interface MyFeignClient {
    @GetMapping(value = ["/my/url?my_param={my_value}"], consumes = ["application/json"])
    fun getValues(
            @PathVariable(name = "my_value") myValue: String?,
        ): Mono<MyEntity?>?
}

然后是一些服务类中的代码:

val myClient: MyFeignClient = WebReactiveFeign.builder<MyFeignClient>()
        .contract(ReactiveContract(SpringMvcContract()))
        .target(MyFeignClient::class.java, "http://example.com")
// feel free to add .block() to get unpacked value or just chain your logic further
val response = myClient.getValues(param)