TCP Server 只接收一条消息答案

【问题标题】：TCP Server only receives one messageTCP Server 只接收一条消息
【发布时间】：2023-03-16 21:05:01
【问题描述】：

我正在尝试创建一个简单的 TCP 服务器和客户端。我希望客户端能够通过只打开一次套接字来发送多条消息。我看过类似的问题 here、here 和 here，但它们并没有多大用处。

我的代码如下：

SampleServerTCP.java

public class SampleServerTCP {
    private static final int DEFAULT_PORT_NUMBER = 39277;

    public static void main(String[] args) throws IOException {
        ServerSocket defaultSocket = new ServerSocket(DEFAULT_PORT_NUMBER);

        System.out.println("Listening on port: " + DEFAULT_PORT_NUMBER);
        while (true){
            Socket connectionSocket = defaultSocket.accept();
            BufferedReader fromClient= new BufferedReader(new     InputStreamReader(connectionSocket.getInputStream()));
            String msg = fromClient.readLine();
            System.out.println("Recieved: " + msg);
        }
    }
}

TCPClientTest.java

public class TCPClientTest {

    public static void main(String args[]) throws UnknownHostException, IOException, InterruptedException{
        Socket clientSocket = new Socket("localhost", 39277); 
        DataOutputStream outToServer = new DataOutputStream(clientSocket.getOutputStream());

        int c = 0;
        while(c<10){
            outToServer.writeBytes(c + "\n");
            outToServer.flush();
            c++;
            Thread.sleep(500);
        }
        clientSocket.close();
    }
}

我得到的唯一输出是：

Listening on port: 39277
Recieved: 0

我哪里错了？

【问题讨论】：

您的服务器只读取一条消息。你为什么感到惊讶？

标签： java sockets tcp

【解决方案1】：

你的问题在这里：

ServerSocket defaultSocket = new ServerSocket(DEFAULT_PORT_NUMBER);

    System.out.println("Listening on port: " + DEFAULT_PORT_NUMBER);
    while (true){
        Socket connectionSocket = defaultSocket.accept();
        BufferedReader fromClient= new BufferedReader(new     InputStreamReader(connectionSocket.getInputStream()));
        String msg = fromClient.readLine();
        System.out.println("Recieved: " + msg);
    }

您正在打开套接字，只读取一行，然后您正在等待下一个套接字。

相反，您应该在 while 循环之外执行 Socket connectionSocket = defaultSocket.accept();，并在循环中从该套接字读取，如下所示：

System.out.println("Listening on port: " + DEFAULT_PORT_NUMBER);
Socket connectionSocket = defaultSocket.accept();
BufferedReader fromClient= new BufferedReader(new     InputStreamReader(connectionSocket.getInputStream()));
String msg = "";
while ((msg = fromClient.readLine()) != null){    
    System.out.println("Recieved: " + msg);
}

【讨论】：

当readLine() 返回 null 时，您必须停止读取并关闭套接字。并且客户端 I/O 应该发生在一个单独的线程中，以便服务器可以同时为多个客户端提供服务。
谢谢。这解决了我的问题。但是，现在一旦客户端完成发送数据，并且套接字和 DataOutputStream 已关闭，服务器将打印“Recieved: null”，直到它停止。有没有办法检查客户端是否完成？最好不要通过 if(msg == null)，是否有内置方法可以使用？
@RichardJones 标准方式是String msg = ""; while((msg = fromClient.readLine()) != null) {。
@Kayaman：谢谢，我将编辑我的答案以包含此内容。 EJP，你是对的，但 OP 问题根本不涉及多线程。
@Alex 这只是我用这段代码指出的两个灾难性问题之一。另一个导致了 OP 在上面的 cmets 中抱怨的无限循环。你已经解决了它，但没有承认任何人。

【解决方案2】：

如下更改您的服务器端代码

公共类 SampleServerTCP { 私有静态最终 int DEFAULT_PORT_NUMBER = 39277;

public static void main(String[] args) throws IOException {
    ServerSocket defaultSocket = new ServerSocket(DEFAULT_PORT_NUMBER);

    System.out.println("Listening on port: " + DEFAULT_PORT_NUMBER);
     Socket connectionSocket = defaultSocket.accept();
     BufferedReader fromClient= new BufferedReader(new     InputStreamReader(connectionSocket.getInputStream()));
     String msg = fromClient.readLine();;
    while (msg!=null){



        System.out.println("Received: " + msg);
        msg = fromClient.readLine();
    }
}

}

【讨论】：

I 在 E 之前，C 之后除外。