使用 Executor 框架在 Weblogic SOAP Webservice 中创建后台线程

Question

我们在 Weblogic 服务器上部署了一个 SOAP 网络服务，流程如下。

SOAP 客户端将向 Web 服务发送消息，Web 服务验证该消息并发送一个确认作为服务的响应。但是，假设在后台执行 SocketConnection 以进一步异步处理消息。

已经提供的实现是使用ExecutorService.newFixedThreadPool 在后台生成一个ChildThread。这是正在使用的代码（并非所有 webservice 实现文件的代码都在此处发布）。

  if ("103".equals(requestType)) {
    ExecutorService executorService = Executors.newFixedThreadPool(1);
    executorService.submit(new MessageProcessing103(coreMsg, otherDetails));
  } else if ("104".requestType) {
         ExecutorService executorService = Executors.newFixedThreadPool(1);
         executorService.submit(new MessageProcessing104(coreMsg, otherDetails));
    }

通过上述实现，可伸缩性绝对是一个问题，但我们现在可以接受它。你能帮忙解决以下问题吗

1. 由于后台线程长期存在，这是否意味着将使用同一个衍生线程来执行所有请求？
2. 如果在几秒内有两个请求进入，第二个请求是处于等待状态还是会产生新线程？
3. 我们不会关闭执行器，那么在这种情况下会遇到什么问题？

Answer 1

1. 对于每个请求，您创建一个只执行该请求的新线程。
2. 一样。
3. 很快您就会遇到 OutOfMemoryError - 创建但未关闭的执行程序会占用所有内存。

我的建议是不要为每个请求创建新的执行器，而是重用同一个执行器。并让该执行程序包含多个线程。一个都没有。

Answer 2

这是我为上述问题设计的方法。

请有人验证并确认这是否仍然会导致任何 内存不足或线程问题。

首先，创建一个线程池来服务平均并行线程。

public static final ExecutorService executorService = Executors.newFixedThreadPool(3);

接下来，为消息类型 103 或 104 调用相应的 MessageProcessor 实例

  if ("103".equals(requestType)) {
       executorService.submit(new MessageProcessing103(coreMsg, otherDetails));
  } else if ("104".requestType) {
       executorService.submit(new MessageProcessing104(coreMsg, otherDetails));
    }

最后，如果 Webservice Context 销毁，则关闭 executorService。为此将在 web.xml 中配置一个监听器。

 <listener>
<listener-class>com.saurav.listener.AppContextListener</listener-class></listener>

AppContextListener 内的代码 --> contextDestroyed() 函数

ImplClass.executorService.shutdown();

如果出现任何异常，将进行相同处理并执行shutdownNow()