如何在不阻塞其他请求的情况下侦听套接字输入答案

【问题标题】：How to listen for a socket input without blocking other requests如何在不阻塞其他请求的情况下侦听套接字输入
【发布时间】：2017-12-21 10:28:02
【问题描述】：

我的标题可能不是最具描述性的，但我会尝试展示尽可能多的代码，希望它能帮助大家更好地理解我的问题。这是我的项目的客户端如何查询服务器以获取信息。这是一个典型请求的示例：

private String GENERATEGROUPKEY()
{
    /* `out` is a PrintWriter using the sockets output stream */
    out.println("GENERATEGROUPKEY");

    try
    {
        /* `in` is a BufferedReader using the sockets input stream */
        String response = in.readLine();
        String[] temp = response.split(" ");

        return temp[1];
    }
    catch (IOException ex)
    {
        return null; // throw connection error to client
    }
}

我的问题是，在任何时候，服务器都可以通过同一个套接字向客户端发送一条未经请求的消息，其中包含信息（就像聊天客户端接收消息一样）。我不成功的想法是创建一个线程来监听这样的消息，只要我们不在另一个查询的中间，但这也是不成功的，因为即使我打断了那个线程，它仍然会占用应该'已经转到客户端查询。

private String GENERATEGROUPKEY()
{
    out.println("GENERATEGROUPKEY");
    listenThread.interrupt(); // block listenThread from recieving response

    try
    {
        String response = in.readLine();
        String[] temp = response.split(" ");

        listenThread = new PulseThread(in); // we're done, so allow 
        listenThread.start();
        return temp[1];
    }
    catch (IOException ex)
    {
        listenThread = new PulseThread(in); // we're done, so allow
        listenThread.start(); 
        return null; // throw connection error to client
    }
}

这正是listenThread 的含义

public class PulseThread extends Thread
{
    private BufferedReader in;

    public PulseThread(BufferedReader in)
    {
        this.in = in;
    }

    @Override
    public void run()
    {
        while (true)
        {
            if (Thread.currentThread().isInterrupted())
            {
                break;
            }
            try
            {
                String line = in.readLine();
                System.out.println(line);
                String[] params = line.split(" ");
                if (params[0].equals("PULSED"))
                {
                    NotificationManager.sendNotification("You have been pulsed!", "Pulsed by: " + params[1]);
                }
            }
            catch (Exception ex)
            {

            }
        }
    }
}

我之前的印象是，在BufferedReader 的阻塞调用中间用readLine() 中断线程只会取消阻塞调用，除非我做错了其他事情。

任何帮助将不胜感激，谢谢。

编辑：因此，在这句话上方的几行中查看我的假设，似乎中断线程不会取消readLine()。我想中断线程的想法是不行的。这样做的正确方法是什么？

【问题讨论】：

与，错误，multithreading?哪里说中断线程会取消它被阻塞的 I/O 操作？
@EJP 这不是多线程问题吗？不确定合法和独特问题上的 -1 是否合适，但我离题了。 Javadocs 说，我引用，“如果该线程在可中断通道上的 I/O 操作中被阻塞，则该通道将被关闭。”这不适用于我吗？如果不是，我可能的解决方案是什么，因为我不知道我需要做什么。
@Headline 实际引用说 InterruptibleChannel 就像在 java 类中一样。 BufferedReader 可能会抛出异常，但由于您没有对它做任何事情，所以您不会知道。
另外，如果你正在使用一个通道，并且你中断了正在读取它的线程并且它关闭了那个通道......没有其他东西可以从那个通道读取。

标签： java multithreading sockets

【解决方案1】：

这里的一般模式是，您希望一个线程处理来自套接字的输出（等待时阻塞），然后将消息分派给请求它们的正确事物。

我喜欢并在多个项目中成功使用的一种实现是将随机生成的 ID 添加到“请求”作为通用标头（也包括消息类型）的一部分，并让服务器始终将 ID 镜像回响应，它允许客户端将请求与响应相关联，而无需关心它是什么类型的消息。

具体来说，类似于具有 2 个公共函数的 SocketMessenger 类：sendRequest(type, body, callback) 和 registerUnsolicitedHandler(type, callback)。

sendRequest 使用type 和随机生成的 ID 构建消息头，将其添加到待处理回复列表以及对回调函数的引用，然后将完成的消息发送到服务器。

registerUnsolicitedHandler 顾名思义，将回调函数添加到消息类型映射中，以便在传入消息没有 ID 时使用。

在处理传入消息的单独线程中，它反序列化传入数据以从标头中获取类型和 ID，如果消息具有 ID，它会搜索待处理的回复列表并使用消息正文调用适当的回调（可能安排在主线程，我忽略了一些细节，比如锁定），否则它会在主动请求的处理程序列表中搜索指定类型并调用该回调。

【讨论】：