Tomcat 8 JSR 356 WebSocket 线程

Question

我正在使用 Tomcat 8 中的 JSR-356 WebSocket 支持来驱动我正在处理的应用程序。到目前为止，看起来所有消息都在单个线程中处理。虽然我理解这背后的原因 - 以及为什么以这种方式实现 websockets，但有没有办法使用 ExecutorService 来处理传入的消息(无需在我的代码中创建 ExecutorService)？

这将允许具有 1 个(或只有几个)网络选择器线程(以支持大量连接的客户端)的可扩展性，同时允许对实际消息进行标准的基于线程的处理(当消息需要为客户处理)。

我没有看到任何特别允许更改的内容。

Answer 1

线程模型因您使用的连接器而异。对于可扩展性，您希望使用 NIO(默认)或 APR/native(从 8.0.0-RC3 开始有问题)。蔚来真的是当下唯一的选择。 APR/native 问题应该很快就会解决(当我看到这个问题时，我正在处理这个问题)。

NIO 使用一个选择器和一个线程池来处理接收到的消息。 When the selector detects that data is available it passes the socket to a thread from the thread pool (via an executor) to process it.该处理可能导致数据在内部被缓冲，应用程序被通知部分消息，应用程序被通知完整消息或这些的组合。对应用程序的通知由处理传入数据的同一线程处理。

如果从多个客户端接收到多条消息，那么将分派(dispatch)多个线程来处理这些消息。

JSR 356 API 中没有允许应用程序选择通过 ExecutorService 处理消息或部分消息的功能，应用程序已收到一条新消息的通知，但应用程序未实现消息。对于只处理整个消息的应用程序来说，实现它应该相对简单。如果应用程序处理部分消息，那么它将变得更加困难。

APR/native(一旦修复)将以与 NIO 相同的方式运行。BIO 始终使用阻塞 IO(即使 JSR356 API 指示非阻塞)并且还需要每个连接的客户端一个线程，而不是每个连接的客户端一个线程处理数据。