java - 如何检测客户端何时与服务器断开连接

Question

我有一个在服务器(服务器 A)上运行的程序，它在一个端口上监听外部连接(来自外部服务器 B)，然后在另一个端口上监听同一服务器(服务器 A)上的内部连接.然后它将数据从内部连接传递到外部连接，然后再返回。

我想知道是否有一种方法可以检测到外部客户端已断开连接。我一次只需要一个外部连接，但我希望能够在外部客户端重新启动或类似情况时接受一个新连接。

这个套接字级别的东西对我来说都是相当新的，所以如果有更好的方法来解决这个问题，我会洗耳恭听。一个规定是服务器 B 上运行的客户端必须是发起连接的客户端，并且连接必须尽可能长地存在。

public void handleConnection() {
    System.out.println("Waiting for client message...");
    try {
        SSLSocket extSocket = (SSLSocket) this.externalServerSocket.accept();

        ObjectInputStream externalOis = new ObjectInputStream(extSocket.getInputStream());
        ObjectOutputStream externalOos = new ObjectOutputStream(extSocket.getOutputStream());
        System.out.println("Client connection establisthed");
        // Loop here to accept all internal connections
        while (true) {

            SSLSocket internalSocket = (SSLSocket) this.internalServerSocket.accept();
            new ConnectionHandler(externalOis, externalOos, internalSocket);

        }
    } catch (IOException e) {
        System.err.println(e.getMessage());
        return;
    }
}

class ConnectionHandler implements Runnable {
    private SSLSocket internalSocket;

    private ObjectOutputStream internalOos;
    private ObjectInputStream internalOis;

    private ObjectInputStream externalOis;
    private ObjectOutputStream externalOos;

    public ConnectionHandler(ObjectInputStream externalOis,
            ObjectOutputStream externalOos, SSLSocket internalSocket) {

        this.internalSocket = internalSocket;

        try {
            this.internalOis = new ObjectInputStream(this.internalSocket.getInputStream());
            this.internalOos = new ObjectOutputStream(this.internalSocket.getOutputStream());

            this.externalOis = externalOis;
            this.externalOos = externalOos;

        } catch (IOException e) {
            System.err.println(e.getMessage());
        }
        new Thread(this).start();
    }

    @Override
    public void run() {
        try
        {

          // process data
          Object o = internalOis.readObject();
            externalOos.writeObject(o);
            Object o2 = externalOis.readObject();
            internalOos.writeObject(02);

            internalOos.close();
            internalOis.close();

            this.internalSocket.close();

        } catch (IOException e) {
            System.err.println(e.getMessage());
        } catch (ClassNotFoundException e) {
            System.err.println(e.getMessage());
        }
    }
}

Answer 1

如果客户端断开连接，readObject()会抛出EOFException，write()会抛出IOException: connection reset 。这就是您所需要的。