我有一个使用套接字进行通信的简单客户端-服务器应用程序。一种可能是每次客户端向服务器发送内容时关闭套接字。
但我的想法是保持连接始终打开，即如果客户端与服务器联系，则应将连接放入队列（例如 LinkedBlockingQueue）并保持打开，这将提高性能。
如果队列中的套接字中有新数据可用，我如何检查服务器？我唯一能想象到的就是不断迭代整个队列并检查每个套接字是否有新数据。但这会非常低效，因为如果我有多个线程在队列上工作，那么当一个线程正在扫描队列时，队列就会被阻塞。
或者有没有可能在socket上注册一个回调函数，让socket通知线程数据准备好了？
【问题讨论】：
但我的想法是保持连接始终打开，即如果客户端与服务器联系，则应将连接放入队列（例如 LinkedBlockingQueue）并保持打开，这将提高性能。
保持连接打开将提高性能，但存在扩展问题：打开的套接字会使用内核资源。 （虽然我不会使用队列...）
如果队列中的套接字中有新数据可用，我如何检查服务器？
如果您有多个连接到不同客户端的套接字，并且您希望以（大致）到达的顺序处理数据，则有两种常用技术：
为每个套接字创建一个线程，并让每个线程简单地进行读取。这将（自然）阻塞线程，直到数据可用。
使用 NIO 通道选择器机制（请参阅 Selector），它允许您找出一组 I/O 通道中的哪一个已准备好进行读取或写入。
每个套接字的线程往往会占用大量资源（线程堆栈），并且如果您有多个同时处于活动状态的线程，则根本无法很好地扩展。 （上下文切换过多，线程调度程序的负载过大。）
相比之下，选择器映射到主机操作系统提供的本机系统调用，因此它们高效且响应迅速……如果使用得当。
（您还可以获取套接字的非阻塞通道，并以循环方式轮询它们。但这既不高效也不响应。）
如您所见，这些想法都不适用于队列。要么你有多个线程，每个线程都处理一个套接字，要么你有一个线程处理一个数组或（数组）套接字列表。队列抽象不是为索引或迭代而设计的。
或者有没有可能在socket上注册一个回调函数，让socket通知线程数据准备好了？
查看@Lolo 的回答。
【讨论】：
一个实用的解决方案是使用 NIO2 AsynchronousSocketChannels 执行异步读取操作，并带有一个可以指定为 CompletionHandler 的回调。
【讨论】：