反应器假装不能解串通量响应

Question

我有以下控制器

@RestController
public void MyController {
  @GetMapping("/foo")
  public Flux<Foo> getFoos() { /* return a flux of Foos*/ }
}

和一个假装客户

public interface MyFeignClient {
  @RequestLine("GET /foo")
  Mono<Foo> getFoos();
}

public class MyClients {
  public static MyFeignClient myFeignClient() {
    return ReactorFeign.builder().target(MyFeignClient.class, "http://localhost:8080");
  }
}

但是当我打电话的时候

StepVerifier.create(myFeignClient.foo())
  .consumeNextWith(foo -> println(foo))
  .verifyCompleted();

我收到这个错误

java.lang.AssertionError:预期“consumeNextWith”失败（预期：onNext（）；actual:onError（feign.FeignException:无法反序列化com.example.Foo在[Source:（BufferedReader）；line:1，column:1]读取GET时超出START_ARRAY标记http://localhost:8080/foo))

reactor.test.ErrorFormatter.assertionError（ErrorFormater.java:105）位于reactor.test。ErrorFormatter.failPrefix（ErrorFormatter.java:94）位于reator.test.ErrorFormatter。fail（Error格式化器.java:64）位于reactor.test.错误格式化器.failOptional（Error格式器.java：79）位于reaction.test.DefaultStepVerifierBuilder.lambda$consumeNextWith$1（DefaultStep Verifier Builder.java:256）reactor.test.DefaultStepVerifierBuilder$SignalEvent.test（DefaultStep Verifier Builder.java:2112reactor.core.publisher.FluxSubscribeOn$Subscriber.onError（FluxSubscription.java:157）处reactor.corece.publisher.FlexTake$TakeSubscribers.onEror（FluxTake$take.java:138）的reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriberreactor.core.publisher.FluxSubscribeOn$subscribe_Subscriber.requestUpstream（FluxSubscription.java:131），位于reactor.corece.publisher.FlushSource.subscribe（FluxSource.java:52）的reactor.coreactive.ReactiveInvocationHandler.lambda$invokeMethod$0（ReactiveInvocationHandler.java:99）reactor.core.publisher.Flux.subscribe（Flux.java:7777）位于reactor.corece.publisher.FlushSubscribeOn$SubscriberOnSubscribe.run（FluxSubscribe On.java:194），位于reactor.core.scheduler.WorkerTask.call（WorkerTask.java:264），位于java.base/java.util.concurrent.FutureTask.run（FutureAttask.java:264）java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run（ScheduledThreadPool Executor java:304）位于java.base.java.util.consurrent.ThreadPoolExecutor.runWorker（ThreadPoOLExecuttor.java:1128），位于java.base/java.til.concurrent.SthreadPool执行器$Worker.run（ThreadpoolExecutior.java:628反序列化[Source:（BufferedReader）；line:1，column:1]处读取GET的START_ARRAY标记中com.example.Foo的实例http://localhost:8080/foo在feign.reactive.ReactiveInvocationHandler$1.request（ReactiveInvocationHandler.java:109）的feign.SynchronousMethodHandler.executeAndDecode（SynchronousMet方法处理程序.java:162）的feign.feign.FeignException.errorReading（FeignException.java:130）…还有13个原因是：com.fasterxml.jjackson.databind.exc.MismatchedInputException：无法反序列化com.example.Foo在com.fasterxml.jockson.databind.reportInputException.from（MismatchedInputExeption.java:63）的[Source:（BufferedReader）；line:1，column:1]处的START_ARRAY标记的实例com.fasterxml.jockson.databind.DeserializationContext.handleUnexpectedToken（DeserialiizationContext.java:1139位于com.fasterxml.jockson.databind.ObjectMapper._readMapAndClose（ObjectMapper.java:4013feign.SynchronousMethodHandler.executeAndDecode（SynchronousMethHandler.java:147）处的feign.SSynchronoosMethod_Handler.decode（SyncronousmethodHanlder.java:183）处的jeign.jJackson.JacksonDecoder.decode（JacksonDecoder.java:61）…还有15个

我在这里做错了什么？我该如何修复它？

Answer 1

一个简单的谷歌搜索显示，假装客户端不支持反应式。他们有一个正在孵化的项目试图创造支持

添加Webflux支持问题

假核心

所以回答你的问题

“我做错了什么？”

您已选择使用不支持生产者/使用者的 Http 客户端。

“我怎么能修好它？”

通过使用假装客户端，而是使用支持非阻塞操作的 HttpClient，例如，Spring Web 客户端。