聊天客户端应用程序没有接收和发送任何数据答案

【问题标题】：Chat client application isn't reciving and sending any data聊天客户端应用程序没有接收和发送任何数据
【发布时间】：2018-08-28 10:50:53
【问题描述】：

我有基本的客户端-服务器聊天应用程序。服务器端似乎工作，当我通过 telnet 连接它时，它会接收消息并将其发送回所有连接的客户端。我无法使用我自己的客户端实现同样的效果。

所以从一开始，Server 类

public class Server  {
    private Properties properties;
    private ServerSocket serverSocket;
    private Set<ClientConnection> clientConnections;   

    public Server() throws IOException {
        clientConnections = new HashSet<>();

        serverSocket = new ServerSocket(9999);
        while(true){
            Socket clientSocket = serverSocket.accept();
            ClientConnection clientConnection = new ClientConnection(clientSocket, this);
            clientConnections.add(clientConnection);
            clientConnection.start();
        }
    }

    public Set<ClientConnection> getClientConnections() {
        return clientConnections;
    }
}

在每个连接上都是新的ClientConnection 创建的，在开始时，向新客户端发送“Hello from server”（如果通过 telnet 连接，则工作），然后监听所有传入消息并将它们广播给所有连接的客户端，再次- 如果 telnet 是客户端，则工作。

public class ClientConnection extends Thread {
    private final Socket clientSocket;
    private final Server server;
    private OutputStream outputStream;
    private InputStream inputStream;    

    public ClientConnection(Socket clientSocket, Server server) {
        this.clientSocket = clientSocket;
        this.server = server;
    }

    @Override
    public void run(){
        try {
            handleClient();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private void handleClient() throws IOException {
        outputStream = clientSocket.getOutputStream();
        inputStream = clientSocket.getInputStream();
        outputStream.write("Hello from server".getBytes());
        System.out.println("New client connected");         

        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        String incomingMessage;

        while((incomingMessage = bufferedReader.readLine()) != null) {
            for(ClientConnection connection : server.getClientConnections()) {
                connection.getOutputStream().write(incomingMessage.getBytes());
            }
            System.out.println(incomingMessage);
        }
        clientSocket.close();
    }

    public OutputStream getOutputStream() {
        return outputStream;
    }
}

然后，我得到了带有 ServerConnection 类的客户端应用程序

    public class ServerConnection{
        private Socket socket;
        private OutputStream outputStream;
        private InputStream inputStream;
        private BufferedReader bufferedReader;
        private String host;
        private int port;

        public ServerConnection(String host, int port) {
            this.host = host;
            this.port = port;
        }

        public void connect() throws IOException {


        socket = new Socket(host, port);
        outputStream = socket.getOutputStream();
        inputStream = socket.getInputStream();

        outputStream.write("Hello from client".getBytes());

        bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        String incommingMessage;

            while((incommingMessage = bufferedReader.readLine()) != null) {
                System.out.println(incommingMessage);
            }
        }
    }

它实际上是由服务器端注册的（打印“新客户端已连接”），但它没有收到“来自客户端的Hello”，客户端也没有收到来自服务器的任何消息。

【问题讨论】：

标签： java multithreading sockets networking

【解决方案1】：

请尝试在来自客户端的消息末尾发送新行，即：outputStream.write("Hello from client\r\n\".getBytes());，因为您在服务器代码中使用bufferedReader.readLine()。所以 BufferedReader 正在等待行结束，没有任何事情发生。

【讨论】：

永远不会想到这么简单的新线就可以完成这项工作。

【解决方案2】：

我不会为你编写代码，因为你有你需要的东西。但是这里有一个流程，我自己花了一段时间才完全理解，这应该可以帮助你。

服务器：

Start -> Accept connection -> Read InStream -> Write OutStream (FLUSH THE TOILET OF DATA) -> Loop

客户：

Start -> Connect -> Write OutStream (FLUSH THE TOILET OF DATA) -> Read InStream -> Close Connection

【讨论】：