点对点聊天不接收/发送消息

Question

我正在尝试创建相互连接的对等点，并且能够向他们同时连接的每个人发送/接收消息。它们都在同一台机器上运行。一旦连接到对等点并获得套接字连接，我将启动两个线程，一个正在读取，一个正在写入。但是，readLine() 无限期地阻塞，我不确定问题出在哪里。对等方成功连接，但消息交换失败。中断一个对等点会导致从与其连接的其他对等点读取"null" 消息。

编辑：在PrintWriter 中使用autoflush = true 会将"ConnectionReset" 异常抛出到连接到中断对等点的其他对等点。

我尝试在发送消息之前等待读取线程启动，从对等端的任一端获取套接字连接，将输入/输出流存储在存储为成员变量的列表中，并且只传递套接字/所有流到每个线程。也尝试了不同的阅读方式，在阅读线程中以 cmets 显示。

class ConnectionListener extends  Thread{

        public void run(){

            try {
                while (!allPeersJoined()) {

                    Socket socket = null;
                    socket = peerServer.accept();



                    new PeerReader(socket).start();
                    new PeerWriter(socket).start();
                }

            }catch (IOException e){
                e.printStackTrace();
            }

        }

    }
}

    class PeerWriter extends Thread{


        PrintWriter writer;

        public PeerWriter(Socket socket){
            try {
                this.writer = new PrintWriter(socket.getOutputStream(), true);
            }catch (IOException e){
                e.printStackTrace();
            }

        }

        @Override
        public void run() {
            writer.println("Hello");
        }


    }

    class PeerReader extends Thread{

        BufferedReader reader;

        public PeerReader(Socket socket){
            try {
                this.reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            }catch (IOException e){
                e.printStackTrace();
            }

        }

        @Override
        public void run() {
            String input = "";


            System.out.println("Waiting to receive messages...");
            try {


                System.out.println(reader.readLine());


//                while((input = reader.readLine()) != null){
//                    System.out.println(input);
//                }

            }catch (IOException e){
                e.printStackTrace();
            }

        }
    }

编辑：添加套接字创建

Thread t = new ConnectionListener();
t.start();

// Connect to all peers
for (String peer : peers) {
    new Socket("127.0.0.1", Integer.valueOf(peer));
}

Answer 1

您正在创建多个套接字，但从不使用它们。

现在 ConnectionListener 获取您的连接，在已连接的套接字上发送字节，但套接字从不响应......因为您从未告诉过它们。

您应该以与 ConnectionListener 相同的方式创建一个名为 ClientConnection，它有自己的写入器和读取器。