Spring WebFlux如何获取外部服务响应？原理与相关疑问解答

我刚接触Spring响应式编程，正在学习相关知识。例如在与外部服务进行HTTP集成时，了解到Spring响应式可借助非阻塞socket channels和selector实现。抽象来说，EventLoop线程处理输入请求并启动执行HTTP查询，之后无需等待响应，可自由处理其他请求，因为这是非阻塞的。

我阅读了一篇文章，对什么是callback function感到困惑（我猜测它能让我们无需阻塞并处理其他请求？）。我不理解EventLoop在切换处理其他请求、不等待响应的情况下，是如何处理外部服务响应的。

我尝试用selector和socket channels进行测试，抽象来看，我认为EventLoop线程只是通过selector.select()方法检查是否有来自客户端的事件，然后返回数据。我的理解正确吗？

解答 #

1. 回调函数（Callback Function）是什么

回调函数就是一段预先定义好的代码，会在特定事件触发时自动执行。在非阻塞场景中，当你发起HTTP请求后，不用一直等待结果，只需告诉系统：“等外部服务返回响应时，就执行这段回调代码处理结果”。这样EventLoop线程就能立刻去处理其他请求，不会被阻塞在当前请求上。

比如调用非阻塞HTTP客户端发起请求时，你会传入一个回调逻辑，当响应返回时，这个回调就会被触发，负责处理响应数据、更新业务状态或者触发后续流程。

2. EventLoop如何处理外部服务响应

你的理解方向是对的，这里补充关键细节：

• EventLoop线程会通过selector.select()持续监听所有已注册socket通道的事件（比如“有数据可读”——也就是外部服务的响应已返回）。
• 当你发起非阻塞HTTP请求时，对应的socket通道会被注册到selector上，监听“可读”事件，之后EventLoop就可以去处理其他请求。
• 一旦外部服务把响应发回，该socket通道会触发“可读”事件，selector.select()就会返回这个就绪的通道。
• 此时EventLoop会回到这个通道，执行之前注册好的回调函数，处理响应数据。

整个过程中EventLoop以单线程（或固定大小线程池）循环处理就绪事件，不会为单个请求阻塞等待，这就是非阻塞IO的核心逻辑。

3. 关于selector.select()的理解

你的思路是正确的，但要明确：selector.select()监听的不只是客户端的请求事件，还包括所有已发起的外部请求的响应事件（即socket通道的可读、可写事件）。EventLoop的工作就是不断循环调用selector.select()，获取就绪事件列表，然后逐个处理——不管是新的客户端请求，还是外部服务返回的响应。

内容的提问来源于stack exchange，提问作者Роман Григорьев