Java 线程池 + Runnable 多线程 + 调用 WebService（企业落地方案）

结论先行：用 ThreadPoolExecutor + Runnable 承载并发任务，用可复用的 SOAP 客户端发起 WebService 调用，并配套超时、重试、限流、熔断与可观测，才能跑得稳、跑得久。🚀

一、架构要点（你需要的只是这三层）

1. 生产层：组装任务参数，入队。
2. 执行层：ThreadPoolExecutor 消费队列，Runnable 执行业务。
3. 远程层：WebService 客户端（JAX-WS/Jakarta 或 Apache CXF），带连接/读取超时与重试退避。

硬性建议

• JDK17/21 运行；如追求极致并发与低成本，可评估虚拟线程版执行器（JDK21）。
• JAX-WS 在 JDK11 起不再内置，必须引入 Jakarta XML Web Services 或 CXF 依赖。

二、线程池与任务模型（示例可直接用）

public final class WsExecutor {
  private static final int CORE = Math.max(4, Runtime.getRuntime().availableProcessors());
  private static final int MAX = CORE * 4;
  private static final int QUEUE_CAPACITY = 10_000;

  public static final ThreadPoolExecutor EXEC = new ThreadPoolExecutor(
      CORE, MAX, 60, java.util.concurrent.TimeUnit.SECONDS,
      new java.util.concurrent.ArrayBlockingQueue<>(QUEUE_CAPACITY),
      r -> {
        Thread t = new Thread(r, "ws-call-" + System.nanoTime());
        t.setDaemon(true);
        t.setUncaughtExceptionHandler((th, ex) -> System.err.println("Uncaught: " + ex));
        return t;
      },
      new java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy() // 背压：队列满时在调用线程执行
  );
}
​

为何这样配

• CORE=CPU 左右，MAX=CORE×4 适配 I/O 密集型远程调用；
• 有界队列 避免内存失控；
• CallerRunsPolicy 在流量尖峰时做“软限流”。

公式提示：线程数 ≈ (QPS × 平均RT秒) × 安全系数（1.2~2）。用压测校准，不要想象。

三、Runnable 任务与 WebService 调用（带超时、重试）

下面以 Jakarta/JAX-WS 实现为例；使用 CXF 时，超时属性名不同（见注释）。

import jakarta.xml.namespace.QName;
import jakarta.xml.ws.BindingProvider;
import jakarta.xml.ws.Service;
import java.net.URL;
import java.time.Duration;

public class InvokeOrderTask implements Runnable {
  private final String payload;

  public InvokeOrderTask(String payload) { this.payload = payload; }

  @Override public void run() {
    int maxRetry = 3;
    long backoff = 200; // ms
    for (int attempt = 1; attempt <= maxRetry; attempt++) {
      try {
        OrderPort port = buildPort(Duration.ofMillis(800), Duration.ofSeconds(2));
        String resp = port.submitOrder(payload);
        // 业务校验
        if (resp == null || resp.isBlank()) throw new RuntimeException("Empty response");
        // 正常落库/落日志
        return;
      } catch (Exception ex) {
        if (attempt == maxRetry) {
          // 打点+告警：记录失败原因和payload摘要
          throw new RuntimeException("WS failed after retries", ex);
        }
        try { Thread.sleep(backoff); } catch (InterruptedException ignored) {}
        backoff = Math.min(backoff * 2, 2000); // 指数退避上限 2s
      }
    }
  }

  private OrderPort buildPort(Duration connectTimeout, Duration readTimeout) throws Exception {
    URL wsdl = new URL("https://example.com/order?wsdl");
    QName serviceName = new QName("http://example.com/", "OrderService");
    QName portName    = new QName("http://example.com/", "OrderPort");
    Service svc = Service.create(wsdl, serviceName);
    OrderPort port = svc.getPort(portName, OrderPort.class);

    BindingProvider bp = (BindingProvider) port;
    var ctx = bp.getRequestContext();

    // JAX-WS RI / Metro（常见实现）
    ctx.put("com.sun.xml.ws.connect.timeout", (int) connectTimeout.toMillis());
    ctx.put("com.sun.xml.ws.request.timeout", (int) readTimeout.toMillis());

    // Apache CXF（若使用CXF，请改用下列键）：
    // ctx.put("jakarta.xml.ws.client.connectionTimeout", String.valueOf(connectTimeout.toMillis()));
    // ctx.put("jakarta.xml.ws.client.receiveTimeout",   String.valueOf(readTimeout.toMillis()));

    // 如需鉴权：ctx.put(BindingProvider.USERNAME_PROPERTY, "u"); ctx.put(BindingProvider.PASSWORD_PROPERTY, "p");
    return port;
  }
}
​

关键点解释

• 指数退避重试：只对网络类/可重试错误生效；业务失败（如参数错误）不要重试。
• 超时：连接/读取分别设定，避免“卡死线程”。
• 无共享状态的 Runnable：任务内部不持久化可变全局对象，线程安全更直观。
• 端到端校验：对返回值做最小校验，防止“成功但无效”。

四、提交任务与优雅关闭

public class Main {
  public static void main(String[] args) {
    for (int i = 0; i < 10000; i++) {
      WsExecutor.EXEC.execute(new InvokeOrderTask("order-" + i));
    }
    Runtime.getRuntime().addShutdownHook(new Thread(() -> {
      WsExecutor.EXEC.shutdown();
      try {
        if (!WsExecutor.EXEC.awaitTermination(30, java.util.concurrent.TimeUnit.SECONDS)) {
          WsExecutor.EXEC.shutdownNow();
        }
      } catch (InterruptedException ignored) { WsExecutor.EXEC.shutdownNow(); }
    }));
  }
}
​

要点

• 用 execute 提交 Runnable；若需要拿到结果/异常链路追踪，升级为 Callable + Future/CompletableFuture。
• 优雅停机：保证队列内任务可完成或快速中断。

五、治理清单（强执行）

六、前瞻选项（可按需升级）✨

• 虚拟线程（JDK21）：Executors.newVirtualThreadPerTaskExecutor() 对 I/O 密集型 WS 调用效果显著，能减少线程池调参成本，但仍需超时与限流兜底。
• 连接复用：服务端若支持 HTTP Keep-Alive/管道化，确认客户端实现侧已启用复用，降低建连成本。
• 异步化：高并发吞吐可迁移到 CompletableFuture 或 Reactive（WebClient/CXF 异步），与线程池配合进一步榨干 I/O 等待时间。