Java中如何实现简单的聊天程序-Java-PHP中文网

Java中如何实现简单的聊天程序

穿越時空

发布： 2025-06-20 22:03:01

原创

505人浏览过

java中实现简单的聊天程序，核心在于利用socket进行网络通信。1. 服务端通过serversocket监听端口并接受连接请求，每个连接由独立线程处理，防止阻塞主线程；2. 线程接收客户端消息并广播给所有连接的客户端；3. 客户端连接服务器后发送用户名，并进入消息收发循环；4. 使用多线程监听服务器消息并在控制台显示；5. 消息协议定义为"message username: message"格式；6. 高并发可通过线程池或nio提升性能；7. 聊天记录可存储到数据库如mysql或mongodb；8. 用户认证需客户端提供用户名密码，服务端验证后决定是否允许连接；9. 权限管理可根据角色分配权限，如使用spring security框架实现。

Java中如何实现简单的聊天程序

Java中实现简单的聊天程序，核心在于利用Socket进行网络通信，允许客户端和服务端之间发送和接收消息。这涉及到多线程处理并发连接，以及简单的消息协议设计。

解决方案：

服务端实现: 创建一个ServerSocket监听特定端口，接受客户端的连接请求。每个连接请求都创建一个新的线程来处理，防止阻塞主线程。该线程负责接收客户端发送的消息，并将消息广播给所有已连接的客户端。

立即学习“Java免费学习笔记（深入）”；

import java.io.*;
import java.net.*;
import java.util.*;

public class ChatServer {

    private static final int PORT = 12345;
    private static Set<PrintWriter> writers = new HashSet<>();

    public static void main(String[] args) throws Exception {
        System.out.println("Chat Server is running...");
        ServerSocket listener = new ServerSocket(PORT);
        try {
            while (true) {
                Socket socket = listener.accept();
                new Handler(socket).start();
            }
        } finally {
            listener.close();
        }
    }

    private static class Handler extends Thread {
        private String name;
        private Socket socket;
        private BufferedReader in;
        private PrintWriter out;

        public Handler(Socket socket) {
            this.socket = socket;
        }

        public void run() {
            try {
                in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                out = new PrintWriter(socket.getOutputStream(), true);

                while (true) {
                    out.println("SUBMITNAME");
                    name = in.readLine();
                    if (name == null) {
                        return;
                    }
                    synchronized (writers) {
                        if (!writers.contains(name)) {
                            break;
                        }
                    }
                }

                out.println("NAMEACCEPTED");
                writers.add(out);

                while (true) {
                    String input = in.readLine();
                    if (input == null) {
                        break;
                    }
                    for (PrintWriter writer : writers) {
                        writer.println("MESSAGE " + name + ": " + input);
                    }
                }
            } catch (IOException e) {
                System.out.println(e);
            } finally {
                if (name != null) {
                    writers.remove(out);
                }
                try {
                    socket.close();
                } catch (IOException e) {
                }
            }
        }
    }
}

登录后复制

客户端实现: 客户端连接到服务器，发送用户名，然后进入消息发送和接收循环。客户端需要一个线程来监听服务器发送的消息，并在控制台显示。

import java.io.*;
import java.net.*;
import java.util.Scanner;

public class ChatClient {

    private static final String SERVER_ADDRESS = "localhost";
    private static final int PORT = 12345;

    public static void main(String[] args) throws Exception {
        Socket socket = new Socket(SERVER_ADDRESS, PORT);
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

        Scanner scanner = new Scanner(System.in);
        String name = null;

        while (true) {
            String line = in.readLine();
            if (line.equals("SUBMITNAME")) {
                System.out.print("Enter your name: ");
                name = scanner.nextLine();
                out.println(name);
            } else if (line.equals("NAMEACCEPTED")) {
                System.out.println("Name accepted.");
                break;
            }
        }

        // Start a thread to read messages from the server
        new Thread(() -> {
            try {
                while (true) {
                    String line = in.readLine();
                    if (line != null && line.startsWith("MESSAGE")) {
                        System.out.println(line.substring(8)); // Remove "MESSAGE " prefix
                    }
                }
            } catch (IOException e) {
                System.err.println("Error reading from server: " + e.getMessage());
            }
        }).start();

        // Read user input and send messages to the server
        while (true) {
            String input = scanner.nextLine();
            out.println(input);
        }
    }
}

登录后复制