Spring WebFlux WebClient如何传递对象ID到异步响应处理器

不需要依赖远程接口返回关联ID，直接在Reactive流组装阶段把本地持有的数据库ID和响应结果绑定即可，以下是3种生产可用的实现，按需选择：

• 最简实现：Lambda捕获局部变量，替换原有静态方法引用
  绝大多数单一场景用这个方案就够，不需要额外依赖复杂API：

  // 发起请求前持有的数据库记录ID
  Long dbRecordId = xxx; // 本地已经拿到的关联ID
  var monoReply = webClient.post().uri(url)
                  .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                  .body(Mono.just(myRequestObject), MyRequest.class)
                  .retrieve()
                  .bodyToMono(MyResponse.class);
  // 替换原有的方法引用，用lambda直接捕获上下文的ID传入处理方法
  monoReply.subscribe(resp -> handleLoginResponse(resp, dbRecordId));
  
  // 调整处理方法参数，增加ID入参
  private String handleLoginResponse(MyResponse myResponse, Long dbRecordId) {
      String token = myResponse.getToken();
      // 这里可以直接使用dbRecordId查询、更新对应数据库记录
  }
  

  只要捕获的变量是实际不可变的（逻辑上不会在流执行过程中被修改），这种写法是线程安全的，没有并发问题。
• 流中透传：Mono.zip绑定ID和响应
  如果ID需要在流的多个中间处理步骤中使用，可以把ID和响应打包成元组传递：

  Long dbRecordId = xxx;
  Mono<Tuple2<MyResponse, Long>> monoWithBindId = Mono.zip(
          monoReply,
          Mono.just(dbRecordId)
  );
  // 后续所有算子都可以从元组中同时拿到响应和绑定的ID
  monoWithBindId.subscribe(tuple -> {
      MyResponse resp = tuple.getT1();
      Long bindId = tuple.getT2();
      handleLoginResponse(resp, bindId);
  });
  

• 长链路透传：Reactor Context上下文
  如果调用链路很长，ID需要跨多个方法、多个算子传递，用Reactor自带的上下文机制最规范，不需要在每个方法参数里手动透传ID：

  Long dbRecordId = xxx;
  monoReply
          .flatMap(resp -> Mono.deferContextual(ctx -> {
              // 任意流节点都可以从上下文取出提前写入的ID
              Long bindId = ctx.get("BIND_DB_ID");
              return Mono.just(handleLoginResponse(resp, bindId));
          }))
          // 订阅时写入上下文
          .contextWrite(Context.of("BIND_DB_ID", dbRecordId))
          .subscribe();
  

避坑提醒：绝对不要在WebFlux异步场景下用ThreadLocal传递参数。WebFlux基于事件循环模型，请求发起、响应回调可能运行在不同线程，ThreadLocal存储的值会丢失，甚至出现多请求数据串扰的严重问题。

内容的提问来源于stack exchange，提问作者Shehan Simen