Java 简单聊天 - 向所有客户端发送消息

Question

我正在学习如何在 Java 中编程，我决定编写简单的聊天程序。

我已经写了服务器、客户端和ThreadedConnection 类。我现在的目标是来自一个客户的消息将显示在其他客户上。我当前的代码按以下方式工作：当一个客户端发送一条消息时，其他客户端只有在发送自己的消息时才会收到该消息。例子：客户1：你好
你好
客户2 嗨
你好
客户3 怎么了
嗨

我认为问题出在我从服务器获取输入的方式上。可能我的程序一直在等待，直到它从用户 (stdin) 获得输入并且它阻止了程序的进一步部分的执行。但老实说，我不知道如何用其他方式做到这一点。

if((message=stdin.readLine())!=null)
           out.println(message);
if((message=in.readLine())!=null)
           System.out.println(message);

如果有任何提示，我将不胜感激。我试图在互联网上找到答案，但通常我找到的程序对我来说太难理解了。

服务器代码：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class Server {

    private static List<ThreadedConnection> clientList=new ArrayList<>();;

    public synchronized void broadcastMessageToAllClients(String message){

        for(ThreadedConnection tc: clientList)
            tc.sendMessage(message);
    }

    public static void main(String[] args) throws IOException {

        try {

            Server server=new Server();
            ServerSocket serverSocket = new ServerSocket(8189);

            while (true) {

                Socket socket = serverSocket.accept();
                Runnable threadedServer = new ThreadedConnection(socket, server);
                clientList.add((ThreadedConnection)threadedServer);
                Thread thread = new Thread(threadedServer);
                thread.start();
            }
        } catch (Exception e) {

            System.out.println("An error occured.");
            e.printStackTrace();
        }
    }
}

线程连接代码：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ThreadedConnection implements Runnable {

    private Server server;
    private Socket socket;
    private PrintWriter out;
    private BufferedReader in;

    public ThreadedConnection(Socket socket, Server server) {

        this.socket = socket;
        this.server = server;
    }

    @Override
    public void run() {

        try {

            out = new PrintWriter(socket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            String message;
            while(true){

                if((message=in.readLine())!=null)
                    server.broadcastMessageToAllClients(message);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void sendMessage(String message){

        out.println(message);
    }
}

客户代码：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class Client {

    public static void main(String[] args) throws IOException {

        try (
                Socket socket = new Socket("127.0.0.1", 8189);
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
        ) {

            String message;
            while(true){

                if((message=stdin.readLine())!=null)
                    out.println(message);
                if((message=in.readLine())!=null)
                    System.out.println(message);
            }
        }
    }
}

Answer 1

如果您想同时从控制台和套接字接收消息，您应该将这些功能拆分为两个线程。所以控制台 reader 将留在主线程中（因为它在您的实际代码中），但套接字 reader 应该在新线程中。

发生这种情况是因为 BufferedReader 的函数 readLine() 等待直到收到下一个输入。这意味着你的套接字 reader 只有当你在控制台中输入一些文本时才会被调用。

Java 简单聊天 - 向所有客户端发送消息

Java simple chat - Sending message to all clients

java

sockets

io

chat