java - Java中的多线程服务器

Question

服务器本质上是一个项目队列，而客户端充当这些项目的生产者和/或消费者。

服务器必须:

• 监听 put/take 请求并相应地处理它们 - 这通常不会花费太长时间，它包括:
  1. 解析一个短字符串；
  2. 一个HashMap.get;
  3. 获取锁；
  4. PriorityQueue.poll 或 PriorityQueue.offer；
• 尽快将所有项目 Activity 通知每位客户，以便每位客户都能实时了解正在发生的事情。

最简单的设置方法是让一个线程接受客户端，然后为每个客户端创建两个线程:

• 处理 InputStream 的一个，它会阻塞等待请求；
• 另一个处理 OutputStream，它监听队列中的事件，并将信息发送到客户端。

当然这不是可扩展的，而且每个客户端有两个线程似乎很浪费。

我也想过用单线程，这样会

• 为 read 设置一个大约 1 秒的套接字超时；
• 如果 read 超时，或者在处理完请求后，继续将每个新事件发送给客户端；
• 循环这两个 Action 。

但是，轮询请求和事件也是一种浪费。

另一种方法是使用线程池，并将上述两个操作中的每一个都放在它们各自的 Runnable 中。然后，这些可运行对象将在 Executor 中相互排队。 这看起来同样浪费，甚至更多。

我一直在阅读 some questions ，我现在对 NIO 很好奇，因为非阻塞操作和事件驱动的服务器似乎是正确的方法。

上述任何设计是否适合这项任务，或者我应该用 NIO 来解决它吗？

就数字而言，这更像是一个练习而不是一个真实的系统，因此它不必处理成千上万的客户端，但理想情况下，它应该 em> 能够很好地执行和扩展。

Answer 1

那么你需要继续使用 ThreadPool 因为你需要管理 Runners!我建议你在你的业务中实现 MOA 结构，因为这个客户端连接到服务器并且服务器等待客户端请求(数据)，然后服务器队列作业(如果没有可用于处理的线程)并立即响应一个长值，该值指向服务器上的客户端进程 ID 并关闭套接字。 现在，如果客户请求已处理并准备好采取行动怎么办？所以这里有两种方法，好的一种是服务器向客户端发送信号(因此客户端需要监听服务器响应[ServerSocket])关于完成的请求。或者客户端定期检查服务器并检查进程的状态。