Как сделать несколько сообщений в сокет программирования?

Question

У меня есть проект, в котором я создаю чат-сервер, где люди (клиент) подключаются и выбирают партнера для общения. Тем не менее, они общаются только тогда, когда оба клиента отправляют сообщение, они видят то, что набрал другой. Я хочу что-то вроде Whatsapp, где мы отправляем много сообщений одно за другим, не дожидаясь отправки другого клиента.

Я пытался создать класс потока, в который я запускаю чат и другие вещи, но ничего не получалось.

//this is the client.java and this is the part of the code where they start chatting
do {
        System.out.print(dis.readUTF());
        System.out.println(dis.readUTF());
        send = in.next();
        dos.writeUTF(send);
        b = dis.readBoolean();
    } while (b);

//this is part of the chatserver.java where the connection is done they start chatting
class handleClient implements Runnable {

    private Socket s1;
    private Socket s2;
    private String name1;
    private String name2;

    public handleClient(Socket s1, Socket s2, String n1, String n2) {
        this.s1 = s1;
        this.s2 = s2;
        this.name1 = n1;
        this.name2 = n2;
    }

    @Override
    public void run() {
        String msg1 = "", msg2 = "";
        boolean b;
        try {
            DataOutputStream dos1 = new DataOutputStream(s1.getOutputStream());
            DataInputStream dis1 = new DataInputStream(s1.getInputStream());

            DataOutputStream dos2 = new DataOutputStream(s2.getOutputStream());
            DataInputStream dis2 = new DataInputStream(s2.getInputStream());

            do {
                dos1.writeUTF(name1 + ": ");
                dos2.writeUTF(name2 + ": ");
                dos2.writeUTF(name1 + ": " + msg1);
                msg1 = dis1.readUTF();
                dos1.writeUTF(name2 + ": " + msg2);
                msg2 = dis2.readUTF();

                b = !msg1.equals(name1 + " is out") && !msg2.equals(name2 + " is out");
                dos1.writeBoolean(b);
                dos2.writeBoolean(b);
            } while (b);

            dos1.close();
            dis1.close();
            dos2.close();
            dis2.close();
            s1.close();
            s2.close();
        } catch (IOException ex) {
            System.err.println(ex.getMessage());
        }
    }
}

Answer 1

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

public class ChatServer {
    public static void main(String[] args) throws Exception {
        ServerSocket server = new ServerSocket(5555);
        List<DataOutputStream> doss = new ArrayList<>();
        while (true) {
            Socket client = server.accept();
            synchronized(doss) {
                doss.add(new DataOutputStream(client.getOutputStream()));
            }
            new Thread(new Runnable() {
                public void run() {
                    try (DataInputStream dis = new DataInputStream(client.getInputStream())) {
                        while (true) {                    // <---------  per-client loop
                            String message=dis.readUTF();
                            synchronized (doss) {
                                for (DataOutputStream dos : doss)
                                    dos.writeUTF(message);
                            }
                        }
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                }
            }).start();
        }
    }
}

Он имеетцентральное хранилище исходящих потоков (doss) и один поток на клиент для чтения входящих потоков.Затем потоки читают строку из своего клиента и перенаправляют ее во все исходящие потоки навсегда (внутренний цикл while(true)).
На стороне клиента циклы практически однострочные, один для чтения сообщения и отправкиэто на сервер, а другой для получения чего-то с сервера и печати на экране:

public class ChatClient {
    public static void main(String[] args) throws Exception {
        Scanner s = new Scanner(System.in);
        System.out.print("Enter your nick: ");
        String name = s.nextLine();
        Socket socket = new Socket("localhost", 5555);
        DataInputStream dis = new DataInputStream(socket.getInputStream());
        DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
        new Thread(new Runnable() {
            public void run() {
                try {
                    while (true)                              // <------- receiver loop, in thread
                        System.out.println(dis.readUTF());
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }).start();
        dos.writeUTF(name + " has joined the conversation");
        while (true)                                          // <------- sender loop
            dos.writeUTF(name + ": " + s.nextLine());
    }
}

Эта штука работает с жестко закодированным localhost на порту 5555, не обрабатывает ошибки привсе (сервер умирает, когда клиент уходит).Это должно было быть коротким.

Answer 2

Как сказал @Mohsen fallahi, используйте веб-сокеты (у вас неявная не блокирующая функциональность)

Чистое решение javascript см .: https://javascript.info/websocket