使用Flux的blockFirst()方法编写单元测试时遭遇无限阻塞问题求助

我之前也踩过这个坑，你的问题核心原因很明确：你mock出来的Flux没有发出任何元素或者完成信号，blockFirst()方法的逻辑就是会一直阻塞，直到上游Flux推送第一个元素或者触发完成事件，要是没等到这两个信号，它就会无限卡着。

咱们来看你的测试代码：你只指定了when(client.exchangeForFlux(any(), any())).thenReturn(flux);，但这个flux如果是个“空转”的Flux——比如既不推送元素，也不触发onComplete——那blockFirst()肯定会一直等下去。

给你几个可行的解决办法：

• 返回一个包含元素的Flux：如果你的业务逻辑只需要上游有元素返回，直接用Flux.just()构造一个带数据的Flux就行，这样blockFirst()能拿到第一个元素就会结束：

// 替换成你实际需要的类型对象
when(client.exchangeForFlux(any(), any())).thenReturn(Flux.just(new YourDataType()));

• 返回空Flux：如果上游本来就可能没有数据，用Flux.empty()的话，blockFirst()会返回null但不会阻塞，因为onComplete信号会触发它结束等待：

when(client.exchangeForFlux(any(), any())).thenReturn(Flux.empty());

• 如果需要模拟异常场景：要是想测试上游报错的情况，用Flux.error()，这样blockFirst()会直接抛出对应的异常，也不会一直阻塞：

when(client.exchangeForFlux(any(), any())).thenReturn(Flux.error(new RuntimeException("mock error")));

另外补充个小提醒：生产代码里尽量少用blockFirst()这类阻塞方法，尤其是在Reactor的非阻塞场景里（比如WebFlux应用），阻塞调用会破坏非阻塞模型的性能优势。不过这是后话，先把测试跑通再说～

备注：内容来源于stack exchange，提问作者Code Junkie