在客户端JAVA中调用socket.close()时套接字未关闭服务器端

Question

我在使用 java 套接字时遇到问题。我有一个 ServerSocket 正在监听accept() 并为每个客户端请求生成线程。客户端和服务器之间的通信工作正常。我正在使用输入流从服务器线程中的客户端读取数据，例如：

inputStream = mySocket.getInputStream();
bytes = inputStream.read(buffer);

我的问题是，如果我从客户端调用 socket.close() ，则 bytes = inputStream.read(buffer) 的阻塞调用不会发生任何事情;，它继续阻塞。但如果我从服务器关闭套接字，那么客户端的 inputStream.read(buffer); 就会返回“-1”。

服务器-主线程：

//SERVER MAIN THREAD, SPAWNS CLIENT THREADS
ServerSocket serverSocket = new ServerSocket(SERVERPORT);
while (listening){

new ServerThread(serverSocket.accept(), monitor).start();
}

服务器-客户端线程：

public class ServerThread extends Thread{

public ServerThread(Socket socket, Monitor monitor) {
        this.socket = socket;
        this.monitor = monitor;
    }

    public void run(){
        byte[] buffer = new byte[1024];
        int bytes;
        //Listen
        while(true){
            try {
                InputStream inputStream = socket.getInputStream();
                monitor.doStuffWithOtherThreads(Object myObject);
                bytes = inputStream.read(buffer); //Problem
                if (bytes == -1){
                    System.out.println("breaks");
                    break;
                }

                byte[] readBuf = (byte[]) buffer;
                String readMessage = new String(readBuf, 0, bytes);
                System.out.println(readMessage);
                System.out.println(bytes);


            } catch (IOException e) {
                System.out.println("Connection closed");
                break;
            }
        }
    }

客户端：

InetAddress serverAddr = InetAddress.getByName("serverhostname");

socket = new Socket(serverAddr, PORT);

socket.close(); //Close the socket connection from client. Nothing happens in the serverthread

Answer 1

您发布的服务器代码不检查-1。因此，要么这就是问题所在，要么这不是真正的代码，在这种情况下，您应该发布真实代码进行评论。

编辑您发布的代码的行为与您所描述的不同。

Answer 2

在你的 Android 客户端代码中尝试一下：

socket.shutdownOutput(); 
socket.close(); 

应该会更好；-)

Answer 3

我不知道我是否理解你的问题，但我想说，由服务器关闭套接字是正常的。

在服务器端（在独立线程中），您有侦听套接字：

ServerSocket socketServeur = new ServerSocket(port);

然后可能（在同一线程中，如果它是小型服务器）接受传入连接的循环（没有异常管理，可能socket.close位于finally块中） ：

while (! askedToClose) {
    Socket socket = socketServeur.accept();
    doSomethingWithRequest(socket);
    socket.close();
}

在客户端，您有：

Socket clientSocket = new Socket();
clientSocket.connect(new InetSocketAddress(port));
OutputStream output = clientSocket.getOutputStream();
// send something to server
InputStream input = clientSocket.getInputStream(); // will block until data is available
// reading response

服务器应该知道它何时到达请求末尾。例如在http中它可能是（取自scala中的mockHttpServer，因此可能会出现一些错误，但过程是相同的）：

void doSomethingWithRequest(Socket socket) {
    BufferedReader inputReader = new BufferedReader(new InputStreamReader(socket.getInputStream));
    StreamWriter outputWriter = new OutputStreamWriter(socket.getOutputStream);

    StringBuilder requestBuilder = new StringBuilder();
    do {
        requestBuilder.append(inputReader.read().toChar());
    } while (!requestBuilder.toString().endsWith("\r\n\r\n"));

    saveUri(getUriFromRequest(requestBuilder.toString()));

    outputWriter.write("HTTP/1.1 200 OK\r\n\r\n");
    outputWriter.flush();

    inputReader.close();
    outputWriter.close();
}

编辑：
我读了添加的代码，但仍然不明白：

• 您调用 Socket.close()，但此方法不是静态的，
• 您在“服务器”中永远循环
• 我的印象是您对客户端和服务器使用相同的套接字

你有3个“套接字”：

• 监听套接字（ServerSocket对象）
• 接受套接字（由socketServer.accept（）发送的对象套接字）
• 客户端套接字（如上面的示例）

服务器打开和关闭监听和“接受”套接字，并且不应受到不良客户端套接字管理的影响。

然后，如果您希望服务器接受多个并发连接，您可以添加一个线程池来接受连接并处理请求和响应。