等待客户端消息以读取的套接字服务器

Question

等待客户端消息以读取的套接字服务器

7

我有一个Java套接字服务器，如下所示：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class MiddleSocket {
    private ServerSocket middleman;
    private int port = 1027;
    private Socket client;


    protected void createSocketServer()
    {
        try
        {
            middleman = new ServerSocket(port);
            client = middleman.accept();
            middleman.close();
            PrintWriter out = new PrintWriter(client.getOutputStream(),true);
            BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
            BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
            while(true)
            {
                System.out.println("echo: " + in.readLine());
                out.println("test");
            }
        }
        catch(IOException e)
        {
            System.out.println(e);
        }
    }

}

它在从客户端读取内容等方面的工作是正确的。然而，我希望套接字服务器仅在有来自客户端的消息时尝试读取，因为在循环中即使未收到客户端的消息，它也会继续读取，这会输出一堆

echo: null

请问除了wait()之外是否有其他机制可以让while循环知道仅需坐等并在收到客户端发来的消息后触发以读取该消息。一旦读取该消息并发送回复，则会闲置等待接收下一个消息吗？

- jgr208

3个回答

2

你可以使用InputStream.read()或InputStream.read(byte[])，两者都会阻塞。

这里有一个示例：点击链接查看。

- ControlAltDel

1

我希望套接字服务器只在客户端有消息时尝试读取，因为在循环中，即使没有从客户端接收到消息，它仍会继续读取，这会输出一堆内容。

echo: null

这是因为你忽略了流的结尾，这就是 null 的含义。它并不意味着客户端没有任何消息，而是对等方已关闭连接。

- user207421

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

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

- WillBD · Accepted Answer

您可以简单地按照以下方式进行操作：

String line;
while ((line = in.readLine()) != null) {
   \\Do stuff
}

这应该具有预期的行为。

编辑：

这是在评论中使用您的代码谈论的完整示例：

package javaapplication12;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class SocketExample {
    private ServerSocket middleman;
    private int port = 8080;
    private Socket client;


    protected void createSocketServer()
    {
        try
        {
            while (true){
                middleman = new ServerSocket(port);
                client = middleman.accept();
                middleman.close();
                PrintWriter out = new PrintWriter(client.getOutputStream(),true);
                BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
                BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
                String line;
                while((line = in.readLine()) != null)
                {
                    System.out.println("echo: " + line);
                    out.println("test");
                }
            }
        }
        catch(IOException e)
        {
            System.out.println(e);
        }
    }

    public static void main(String[] args){
        SocketExample test = new SocketExample();
        test.createSocketServer();
    }
}