Java 服务器套接字连接重置

Question

当我的 SECOND 客户端连接到我的服务器时，我收到此错误:

Exception in thread "main" java.net.SocketException: Connection reset
    at java.base/java.net.SocketInputStream.read(SocketInputStream.java:186)
    at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
    at java.base/java.net.SocketInputStream.read(SocketInputStream.java:200)
    at java.base/java.io.DataInputStream.readLine(DataInputStream.java:518)
    at Main.main(Main.java:24)

我不知道我做错了什么。

FIRST客户端工作正常

我的代码:

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;

public class Main {
    public static void main(String[] args) throws IOException {
         ServerSocket serverSocket = new ServerSocket(50505);;
         Socket socket;
         while (true) {
             socket = serverSocket.accept();
             while(socket.isConnected()) {
                 String v;
                 DataInputStream in;
                 InputStream in_sock;
                 in_sock = socket.getInputStream();
                 in = new DataInputStream(in_sock);
                 v = in.readLine();
                 System.out.println(v);
                 OutputStream output = socket.getOutputStream();
                 DataOutputStream out = new DataOutputStream(output);
                 out.writeChars("123\n");
                 out.writeChars("123\n");
                 out.writeChars("123\n");
             }
         }
    }
}

PS:如何在 stackoverflow 上分享错误？喜欢代码？

Answer 1

因此，就像其他人所说的那样，最大的问题是您的服务器由于缺少多线程而只能接受一个连接。

现在您的服务器正在等待与指定端口的连接

socket = serverSocket.accept();

然后，当您的套接字仍然连接时，您从套接字读取一行，将其打印到 System.out，然后在循环中全部写回套接字。现在这会出现问题，因为下次客户端尝试连接到您的 serverSocket 时，它不再接受连接，因为您的代码陷入了从一个 Socket 读取和写入数据的循环中。

解决这个问题的方法是以 Milen 上面提到的方式引入多线程。

您的代码应如下所示。

public class Main {
    public static void main(String[] args) throws IOException {
         ServerSocket serverSocket = new ServerSocket(50505);
         while (true) {
             Socket socket = serverSocket.accept();
             SocketHandler h = new SocketHandler(socket);
             h.start();
         }
    }
}

public class SocketHandler extends Thread{

    Socket clientSock;
    public SocketHandler(Socket sock){
        clientSock = sock;
    }

    public void run(){
        while(clientSock.isConnected()) {
            String v;
            DataInputStream in;
            InputStream in_sock;
            in_sock = socket.getInputStream();
            in = new DataInputStream(in_sock);
            v = in.readLine();
            System.out.println(v);
            OutputStream output = socket.getOutputStream();
            DataOutputStream out = new DataOutputStream(output);
            out.writeChars("123\n");
            out.writeChars("123\n");
            out.writeChars("123\n");
        }
    }
}

现在这段代码有一个接受连接的循环，并为每个连接生成一个新线程!

我建议看一些东西。首先，如果你查看 Java Docs for ServerSocket 你会看到这个构造函数

ServerSocket(int port, int backlog)
Creates a server socket and binds it to the specified local port number, with the specified backlog.

积压是服务器套接字可以保持并存储在某种缓冲区中直到可以接受的传入连接数。如果在您的接受循环处于创建套接字处理程序的中间时客户端正在连接，这将很有用。我建议将其设置为您期望的最大客户数。

其次，在 Javadocs 中查找 Thread 类。要成功扩展 Thread，您需要覆盖 run()。此方法是线程将使用的方法。要生成线程，请调用 ThreadObject.start()。你可以认为 start() 只是调用 run()。