java - 如何监听套接字输入而不阻塞其他请求

Question

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

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()。我想中断线程的想法是不行的。正确的做法是什么？

Answer 1

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

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

具体而言，类似于具有 2 个公共(public)函数的 SocketMessenger 类:sendRequest(type, body, callback) 和 registerUnsolicitedHandler(type, callback)。

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

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

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