sockets Java服务器客户端通信似乎被卡住了

Question

你好，斯塔克弗勒社区

我遇到了一个关于Java中socket通信的问题

以下是我的服务器和客户端类的示例代码：

服务器：

public class OTPServer {


static ServerSocket serverSocket;
final static int PORT = 4242;
static Socket clientConnection;

public static void main(String[] args) {

    try {
        serverSocket = new ServerSocket(PORT);
        System.out.println("Socket initialized");
        String serverMessage = "Hello, I am the Host";
        ServerTool serverTool = new ServerTool();

        while (true) {
            clientConnection = serverSocket.accept();
            if(clientConnection.isConnected()) {
                System.out.println("Client connected");
            }

            BufferedReader clientInputReader = new BufferedReader(new InputStreamReader(clientConnection.getInputStream()));
            DataOutputStream serverOutput = new DataOutputStream(clientConnection.getOutputStream());
            System.out.println("Sending message to client: " + serverMessage);
            serverOutput.writeBytes(serverTool.encodeMessage(serverMessage));
            serverOutput.flush();
            String clientMessage = clientInputReader.readLine();
            System.out.println("Encoded answer from client: " + clientMessage);
            String decodedMessage = serverTool.decodeMessage(clientMessage);
            System.out.println("Decoded answer from client: " + decodedMessage);

            serverOutput.close();
            clientInputReader.close();

        }
    } catch (IOException e) {
        e.printStackTrace();
    }
    System.out.println("Hello, I am the OTP Server!");

}

以下是客户：

public class OTPClient {

static Socket clientSocket;
final static int PORT = 4242;
final static String HOST = "localhost";


public static void main(String[] args) {
    System.out.println("I am the OTP Client!");
    String serverMessage;
    String clientResponse = "I am the Client";
    OTPTool otpTool = new OTPTool();

    try {

        clientSocket = new Socket(HOST, PORT);
        BufferedReader serverInput = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        DataOutputStream outputStream = new DataOutputStream(clientSocket.getOutputStream());
        System.out.println("Connection to Host established");
        serverMessage = serverInput.readLine();
        System.out.println("Encoded Message from Server: " + serverMessage);
        String decodedMessage = otpTool.decodeMessage(serverMessage);
        System.out.println("Decoded message from Server: " + decodedMessage);
        System.out.println("Answering with own message: " + clientResponse);
        outputStream.writeBytes(clientResponse);
        outputStream.flush();
        outputStream.close();
    } catch (IOException e) {
        e.printStackTrace();
    }

}

现在我的问题在哪里：

连接建立后，服务器似乎会将其消息发送给客户端，并等待答复。客户端不会打印他从服务器收到的消息。 一旦我取消服务器，客户端就会打印从服务器收到的消息以及信息，答案是send end exits，退出代码为0，所以这部分似乎很好，只是不知怎么卡住了。 正如您在给出的示例代码中看到的，我已经尝试刷新outputStream

我有什么明显的遗漏吗？ 我知道，这确实是基本的东西，但这是我第一次使用socket进行通信

提前谢谢

致以最良好的祝愿， 罗尼

顺便说一句：我知道服务器只连接到一个请求连接的客户端。这对我来说绝对足够了

Answer 1

它被卡住了，因为serverInput.readLine();阻塞直到遇到换行或文件结尾。在服务器端，您没有发送换行符，因此客户端会阻塞