Java创建多线程局域网聊天室实例

本文将详细讲解如何使用Java创建多线程的局域网聊天室实例。你将学习到Java中多线程的具体实现，以及如何利用网络编程实现局域网聊天室。

线程概述

线程是计算机中最小的执行单元。在Java中，可以通过继承Thread类或实现Runnable接口的方式来创建线程。本示例中我们将使用Runnable方式创建线程。

class ChatServer implements Runnable {
    public void run() {
        // 线程执行的内容
    }
}

服务器端

首先我们需要编写服务器端的代码，并开启服务器等待客户端的连接。在本示例中，使用ServerSocket监听端口来接受客户端的连接。

public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = new ServerSocket(9999); //监听端口号9999
    while (true) {
        Socket clientSocket = serverSocket.accept(); //等待客户端连接
        ChatHandler handler = new ChatHandler(clientSocket); //处理该连接
        new Thread(handler).start(); //创建新线程
    }
}

上述代码中，我们等待客户端的连接，并创建一个新的线程来处理该连接。下面我们将讲解如何实现处理连接的代码。

处理客户端连接

下面我们创建一个ChatHandler类，用来处理连接。在该类中，我们需要实现一个基本的输入输出流，以便与客户端进行交互。

class ChatHandler implements Runnable {

    private Socket clientSocket;

    public ChatHandler(Socket socket) {
        this.clientSocket = socket;
    }

    public void run() {
        // 实现输入输出流的代码
    }

}

在ChatHandler中，我们需要实现一个输入输出流来与客户端进行交互。在本示例中，我们将使用Scanner和PrintWriter类来实现输入输出流。

class ChatHandler implements Runnable {

    private Socket clientSocket;

    public ChatHandler(Socket socket) {
        this.clientSocket = socket;
    }

    public void run() {
        try {
            Scanner input = new Scanner(clientSocket.getInputStream());
            PrintWriter output = new PrintWriter(clientSocket.getOutputStream(), true);
            while (input.hasNextLine()) {
                String line = input.nextLine();
                // 进行消息的处理
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

客户端

下面我们将编写客户端的代码。客户端需要连接服务器，并与服务器进行交互，发送消息和接受消息等操作。

public static void main(String[] args) throws IOException {
    Socket socket = new Socket("127.0.0.1", 9999); //连接服务器
    Scanner scanner = new Scanner(socket.getInputStream());
    PrintWriter output = new PrintWriter(socket.getOutputStream(), true);
    while (scanner.hasNextLine()) {
        String line = scanner.nextLine();
        // 处理收到的消息
    }
}

在客户端中，我们需要使用Socket类连接服务器，并实现输入输出流。

实现聊天室功能

在前面的代码中，我们已经完成了客户端和服务器的交互。下面我们将实现聊天室的功能，发送消息和接受消息等操作。

在服务器中，我们需要将收到的消息广播给所有连接的客户端。我们可以用一个List来存储所有连接的客户端，当收到消息时遍历List向每个客户端发送消息。

class ChatServer implements Runnable {

    private List<PrintWriter> clients = new ArrayList<>();

    public void run() {
        // 等待客户端的连接
        while (true) {
            Socket clientSocket = serverSocket.accept();
            PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true);
            clients.add(writer); // 将新客户端存储在集合中
            ChatHandler handler = new ChatHandler(clientSocket, writer);
            new Thread(handler).start();
        }
    }

    // 广播消息给所有客户端
    public synchronized void broadcast(String message) {
        for (PrintWriter writer : clients) {
            writer.println(message);
        }
    }

}

下面我们修改ChatHandler类，让它能够向服务器发送消息：

class ChatHandler implements Runnable {

    private Socket clientSocket;
    private PrintWriter writer;

    public ChatHandler(Socket socket, PrintWriter writer) {
        this.clientSocket = socket;
        this.writer = writer;
    }

    public void send(String message) {
        writer.println(message);
    }

    public void run() {
        try {
            Scanner input = new Scanner(clientSocket.getInputStream());
            while (input.hasNextLine()) {
                String line = input.nextLine();
                // 发送消息给所有客户端
                server.broadcast(line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

在客户端实现中，我们需要让用户能够输入消息，并将其发送给服务器。

class ChatClient {

    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("localhost", 9999);
        Scanner scanner = new Scanner(System.in);
        PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
        while (scanner.hasNextLine()) {
            String line = scanner.nextLine();
            writer.println(line); // 将用户输入的消息发送给服务器
        }
    }

}

现在，当用户在客户端输入消息时，服务器将会广播该消息给所有连接的客户端，从而实现了一个简单的局域网聊天室。

小结

本文讲解了如何使用Java实现局域网聊天室。我们使用了多线程和网络编程的知识，完成了一个简单的聊天室的实例。在实现中，我们学习到了如何使用Socket类连接服务器，并使用Scanner和PrintWriter实现输入输出流。同时，我们也学习到了如何在多线程中实现服务器的广播功能，使得每个客户端都能够收到其他客户端发送的消息。