Java实现局域网聊天室功能(私聊、群聊)

Java实现局域网聊天室功能(私聊、群聊)攻略

1. 功能简介

本文将介绍如何使用Java语言实现一个局域网聊天室，实现私聊和群聊的功能。

局域网聊天室指的是可以在同一局域网内的多台电脑之间进行实时通信，同时支持私聊和群聊。基于此框架，可以扩充出更多的功能，例如文件传输、语音聊天等。

本文所提供的方法并非唯一，但本文介绍的实现方案为Java原生Socket通信实现方式，基于此方式可进行扩展。

2. 实现过程

• 服务端实现

代码示例：

public class Server {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket socket = null;
        List<Socket> clients = new ArrayList<>();
        BufferedReader reader = null;
        PrintWriter writer = null;

        try {
            serverSocket = new ServerSocket(8888);
            System.out.println("服务端启动，等待客户端连接...");
            while (true) {
                socket = serverSocket.accept();
                clients.add(socket);
                System.out.println("有新客户端连接，当前客户端数：" + clients.size());
                reader = new BufferedReader(
                        new InputStreamReader(socket.getInputStream()));
                String message = reader.readLine();
                System.out.println("客户端" + socket.getPort() + "发送消息：" + message);
                for (Socket client : clients) {
                    if (socket != client) {
                        writer = new PrintWriter(
                                new OutputStreamWriter(client.getOutputStream()), true);
                        writer.println("客户端" + socket.getPort() + "发送消息：" + message);
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                reader.close();
                writer.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

说明：

1. 创建ServerSocket对象，监听端口号为8888，等待有新客户端连接。
2. 创建ArrayList集合，用于存储连接到服务器的客户端Socket。
3. 使用while循环，不断地等待新的客户端连接。
4. 当客户端连接后，将客户端的Socket对象添加到集合中。
5. 读取客户端发送的消息，打印输出到控制台。

6. 遍历客户端集合，将接收到的消息发送给每个客户端（除发送者以外）。

7. 客户端实现

代码示例：

public class Client {
    public static void main(String[] args) {
        Socket socket = null;
        BufferedReader reader = null;
        PrintWriter writer = null;
        BufferedReader console = null;

        try {
            socket = new Socket("localhost", 8888);
            System.out.println("已连接到服务器，可以开始聊天！");
            reader = new BufferedReader(
                    new InputStreamReader(socket.getInputStream()));
            writer = new PrintWriter(
                    new OutputStreamWriter(socket.getOutputStream()), true);
            console = new BufferedReader(
                    new InputStreamReader(System.in));

            while (true) {
                String input = console.readLine();
                writer.println(input);
                String message = reader.readLine();
                System.out.println(message);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                reader.close();
                writer.close();
                console.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

说明：

1. 创建Socket对象，指定本地IP地址和端口号8888，连接到服务器。
2. 使用while循环，不断从控制台读取用户输入的信息。
3. 将用户输入的信息使用PrintWriter对象输出到服务器。
4. 读取服务器返回的消息，并打印到控制台。

3. 实现效果

使用上述代码示例，编译运行服务端程序和客户端程序，可以在同一局域网内实现多个客户端之间的通信，包括群聊和私聊。

例如，启动两个客户端程序。客户端1想向客户端2发送私聊消息，只需在控制台输入以下格式的消息：

@客户端2 你好吗？

客户端2将会收到客户端1的私聊消息。

4. 总结

使用Java语言实现局域网聊天室功能，可以通过Socket通信实现。服务端需要监听端口号，使用ArrayList集合存储客户端Socket，并使用while循环不断等待新客户端连接。客户端需要先连接到服务器，然后使用PrintWriter对象向服务器发送消息，并读取服务器返回的消息。

通过扩展此框架，可以实现更多的功能，例如文件传输、语音聊天等。