在Java TCP服务器上检查客户端断开连接 - 仅输出结果

Question

在Java TCP服务器上检查客户端断开连接 - 仅输出结果

javasocketstcp

4

我有一个Java TCP服务器，当客户端连接到它时，每30秒向客户端输出一条消息。严格要求客户端不向服务器发送任何消息，服务器也不能向客户端发送除30秒间隔消息之外的任何数据。

当我断开客户端时，服务器将在下一次尝试向客户端写入时才会意识到这一点。因此，服务器可能需要长达30秒的时间才能识别到断开连接。

我想要做的是每隔几秒钟检查一次是否已经断开连接，而不必等待，但我不确定如何做到这一点，因为a）服务器不接收来自客户端的数据，b）服务器不能发送任何其他数据。请问有人能够给予一些指导吗？谢谢。

- Myn

2个回答

1

如果您正在管理多个客户端，那么我猜您会使用非阻塞套接字（如果没有，请考虑使用非阻塞）。您可以使用选择器来监视所有连接的套接字，以检查它们是否可读或可写，或者该套接字上存在某些错误。当某个客户端断开连接时，您的选择器将标记该套接字并返回。如需更多帮助，请搜索“Socket Select函数”。

- Tayyab

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Brian Roach · Accepted Answer

即使您的服务器没有从客户端“接收”数据，对客户端套接字的非阻塞读取将告诉您，要么没有内容可读（正如您所期望的那样），要么客户端已断开连接。如果您正在使用NIO，则可以简单地使用非阻塞Selector循环（带有非阻塞套接字），并仅在30秒标记上进行写入。如果一个SelectionKey是可读的，并且SocketChannel上的读取返回-1，则表示客户端已断开连接。

编辑：另一种使用阻塞的方法是仅选择30秒超时。任何客户端断开连接都会导致选择返回，并且您将通过读取集合知道哪些是它们。在此情况下，您需要跟踪在选择中被阻止的时间，以了解何时在30秒标记上执行写操作（将下一个选择的超时设置为差值）。

大编辑：在与下面的Myn交谈后，提供完整示例：

public static void main(String[] args) throws IOException {

    ServerSocket serverSocket = null;
    try {
        serverSocket = new ServerSocket(4444);
    } catch (IOException e) {
        System.err.println("Could not listen on port: 4444.");
        System.exit(1);
    }

    Socket clientSocket = null;
    try {
        clientSocket = serverSocket.accept();
    } catch (IOException e) {
        System.err.println("Accept failed.");
        System.exit(1);
    }

    // Set a 1 second timeout on the socket
    clientSocket.setSoTimeout(1000);

    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
    BufferedReader in = new BufferedReader(
            new InputStreamReader(
            clientSocket.getInputStream()));

    long myNextOutputTime = System.currentTimeMillis() + 30000;

    String inputLine = null;
    boolean connected = true;
    while (connected)
    {
        try {
            inputLine = in.readLine();
            if (inputLine == null)
            {
                System.out.println("Client Disconnected!");
                connected = false;
            }
        }
        catch(java.net.SocketTimeoutException e)
        {
            System.out.println("Timed out trying to read from socket");
        }

        if (connected && (System.currentTimeMillis() - myNextOutputTime > 0))
        {
            out.println("My Message to the client");
            myNextOutputTime += 30000;
        }


    }

    out.close();
    in.close();
    clientSocket.close();
    serverSocket.close();
}

值得注意的是，PrintWriter 实际上将您远离实际的套接字，您无法在写入时捕获套接字断开连接（它永远不会抛出异常，您必须使用 checkError() 手动检查）。您可以改用 BufferedWriter（需要使用 flush() 推送输出）并像处理 BufferedReader 一样处理它，以便在写入时捕获断开连接。