Как клиенту правильно ожидать ответа от сервера после отправки сообщения?

Я пытаюсь сделать так, чтобы клиент и сервер правильно отображали сообщения.

Это означает, что клиент должен отправить сообщение серверу, сервер должен получить и отправить одно и то же сообщение обратно клиенту, а затем клиент распечатает полученное сообщение.

У меня возникли проблемы с тем, чтобы клиент правильно дождался, пока сервер закончит отправку ответа, прежде чем клиент получит его и распечатает.

Единственный способ, которым это работает, - это когда я комментирую код EchoClient2.java RECEIVE MESSAGE.

EchoClient2.java

import java.io.*;
import java.net.*;
import java.nio.charset.StandardCharsets;

public class EchoClient2 {
    private Socket clientSocket;
    private DataOutputStream out;
    private DataInputStream in;

    private void start(String ip, int port) {
        try {
            clientSocket = new Socket(ip, port);
            out = new DataOutputStream(clientSocket.getOutputStream());
            in = new DataInputStream(clientSocket.getInputStream());
        } catch (IOException e) {
            System.out.println("Error when initializing connection");
        }
    }

    private void sendMessage(String message) throws IOException {
        //SENDING MESSAGE
        byte[] messageBytes = message.getBytes(StandardCharsets.UTF_8);

        System.out.println("Client will send the text: " + message);

        out.write(messageBytes);
        out.flush();
    
        //RECEIEVE MESSAGE - Doesn't give server a chance to respond?
        byte[] data = new byte[8];
        ByteArrayOutputStream getData = new ByteArrayOutputStream();
        int numBytes;
        while ((numBytes = in.read(data)) != -1) { 
            getData.write(data, 0, numBytes);
        }
        
        byte[] message2Bytes = getData.toByteArray();
        String text = new String(message2Bytes, StandardCharsets.UTF_8);
        
        System.out.println("Server sent the client text: " + text);
    }

    private void stop() {
        try {
            in.close();
            out.close();
            clientSocket.close();
        } catch (IOException e) {
            System.out.println("error when closing");
        }
    }

    public static void main(String[] args) throws IOException {
        EchoClient2 client = new EchoClient2();
        client.start("127.0.0.1", 4444);
        client.sendMessage("exit");
        client.stop();
    }
}

EchoServer2.java

import java.net.*;
import java.nio.charset.StandardCharsets;
import java.io.*;

public class EchoServer2 {
    private ServerSocket serverSocket;
    private Socket clientSocket;
    private DataOutputStream out;
    private DataInputStream in;

    public void start(int port) {
        try {
            serverSocket = new ServerSocket(port);
            clientSocket = serverSocket.accept();
            out = new DataOutputStream(clientSocket.getOutputStream());
            in = new DataInputStream(clientSocket.getInputStream());   
        } catch (IOException e) {
            System.out.println("Error when establishing/accepting server connection");
        }
    }

    private void actionMessage() throws IOException {
        //RECEIEVE MESSAGE
        byte[] data = new byte[8];
        ByteArrayOutputStream getData = new ByteArrayOutputStream();
        int numBytes;
        while ((numBytes = in.read(data)) != -1) { 
            getData.write(data, 0, numBytes);
        }

        byte[] messageBytes = getData.toByteArray();
        String text = new String(messageBytes, StandardCharsets.UTF_8);
        
        System.out.println("Server got " + text + " and will send this back to client");

        //SENDING BACK SAME MESSAGE
        out.write(messageBytes);
        out.flush();
    }

    public void stop() {
        try {
            in.close();
            out.close();
            clientSocket.close();
            serverSocket.close();
        } catch (IOException e) {
            System.out.println(e.getMessage());
        }
    }

    public static void main(String[] args) throws IOException {
        EchoServer2 server = new EchoServer2();

        System.out.println("Now waiting for incoming connection...");

        server.start(4444);

        server.actionMessage();
        
        server.stop();
    }
}

Кто-нибудь знает, почему это не работает должным образом?


java arrays sockets dataoutputstream datainputstream
person CHOCO BLOCK    schedule 07.10.2020    source источник
comment
Также строка exit не имеет смысла, ее можно заменить любой другой строкой.   -  person CHOCO BLOCK    schedule 07.10.2020

Ответы (1)


arrow_upward
1
arrow_downward

Сервер считывает ввод клиента 8-байтовыми фрагментами пока клиент не отключится (чего он не делает), ТОГДА он записывает ответ обратно. Вместо этого сервер должен записывать каждый фрагмент по мере его поступления, а затем отключаться после отключения клиента. Это означает перемещение out.write() внутри цикла чтения while.

private void actionMessage() throws IOException {
    byte[] data = new byte[8];
    int numBytes;
    while ((numBytes = in.read(data)) != -1) {
        out.write(data, 0, numBytes);
        out.flush();
    }
}

Это хорошо для простого эхо-сервера, но не очень полезно для более реалистичного сервера обмена сообщениями. Вам нужен более определенный протокол для обмена сообщениями туда и обратно без потери соединения между ними (если только вы не хотите реализовать протокол без сохранения состояния, такой как HTTP, который позволяет отключать соединения между запросами). Например:

Клиент:

private void sendMessage(String message) throws IOException {
    System.out.println("Client will send the text: " + message);

    //SEND MESSAGE
    byte[] messageBytes = message.getBytes(StandardCharsets.UTF_8);
    out.writeInt(messageBytes.length);
    out.write(messageBytes);
    out.flush();

    //RECEIVE MESSAGE
    int len = in.readInt();
    byte[] data = new byte[len];
    in.readFully(data);
    String text = new String(data, StandardCharsets.UTF_8);
    System.out.println("Server sent the client text: " + text);
}

public static void main(String[] args) throws IOException {
    EchoClient2 client = new EchoClient2();
    client.start("127.0.0.1", 4444);
    try {
        client.sendMessage("hello");
        client.sendMessage("exit");
    } catch (IOException e) {
        ...
    }
    client.stop();
}

Сервер:

private void actionMessage() throws IOException {
    //RECEIVE MESSAGE
    int len = in.readInt();
    byte[] data = new byte[len];
    in.readFully(data);
    String text = new String(data, StandardCharsets.UTF_8);
    System.out.println("Server got " + text + " and will send this back to client");

    //SEND MESSAGE
    data = text.getBytes(StandardCharsets.UTF_8);
    out.writeInt(data.length);
    out.write(data);
    out.flush();
}

public static void main(String[] args) throws IOException {
    EchoServer2 server = new EchoServer2();
    System.out.println("Now waiting for incoming connection...");
    server.start(4444);
    while (true) {
        try {
            server.actionMessage();
        } catch (IOException e) {
            ...
            break;
        }
    }
    server.stop();
}
person Remy Lebeau    schedule 07.10.2020
comment
Спасибо. Ваш второй пример имеет гораздо больше смысла, чем пытаться иметь дело с циклами. - person CHOCO BLOCK; 07.10.2020