Java实现简单局域网聊天室

Java实现简单局域网聊天室攻略

在本文中，我将向您展示如何使用Java语言实现一个简单的局域网聊天室。我们将使用Java的Socket API进行通信。

第一步：创建服务器

我们将从创建服务器开始。服务器将超时等待客户端的连接。一旦客户端连接，服务器将创建一个新的线程对该客户端进行处理。

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(5000)) {
            while (true) {
                Socket socket = serverSocket.accept();
                System.out.println("New client connected");
                ClientHandler clientHandler = new ClientHandler(socket);
                new Thread(clientHandler).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们使用了Java 7中引入的try-with-resources语句，它可以自动关闭ServerSocket。然后，我们创建一个ServerSocket，并且在一个死循环中等待客户端的连接。一旦有一个客户端连接，服务器就会打印新客户端连接的消息，并且创建一个新的线程（ClientHandler）来处理该客户端的请求。

第二步：创建客户端

接下来，让我们创建一个客户端。客户端将尝试连接到服务器，并且输入来自用户的消息。然后，它将发送该消息到服务器。

import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class Client {
    public static void main(String[] args) {
        try (Socket socket = new Socket("localhost", 5000);
             Scanner scanner = new Scanner(System.in);
             PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true)) {

            while (true) {
                System.out.println("Enter message: ");
                String message = scanner.nextLine();
                printWriter.println(message);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们首先创建一个Socket对象，该对象将连接到服务器的IP地址和端口号。然后，我们创建一个Scanner对象来读取用户输入的消息，并创建一个PrintWriter对象来将消息发送到服务器。在一个死循环中，我们要求用户输入消息，并将其发送到服务器。

第三步：创建客户端处理程序

在上面的第一步中，我们创建了一个客户端处理程序（ClientHandler）。现在，让我们实现该类。它将负责处理来自客户端的消息，并发送回所有已连接的客户端。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class ClientHandler implements Runnable {
    private final Socket socket;
    private final List<PrintWriter> clientPrintWriters;

    public ClientHandler(Socket socket) {
        this.socket = socket;
        this.clientPrintWriters = new ArrayList<>();
    }

    @Override
    public void run() {
        PrintWriter printWriter;
        try (BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
            printWriter = new PrintWriter(socket.getOutputStream(), true);
            synchronized (clientPrintWriters) {
                clientPrintWriters.add(printWriter);
            }
            String message;
            while ((message = bufferedReader.readLine()) != null) {
                System.out.println("Message received: " + message);
                synchronized (clientPrintWriters) {
                    for (PrintWriter writer : clientPrintWriters) {
                        writer.println(message);
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们首先创建一个List对象（clientPrintWriters），该对象将包含该客户端之前连接的所有客户端。然后，我们创建了一个PrintWriter对象，该对象将用于向客户端发送消息，并将其添加到clientPrintWriters。

接下来，我们将从BufferedReader中读取来自客户端的消息，然后使用synchronized关键字在访问clientPrintWriters时进行同步。最后，我们将逐一遍历所有已连接的客户端，并将消息发送给它们。

示例：运行客户端和服务器

让我们来看看如何运行客户端和服务器。假设你有两台计算机，分别是192.168.1.1和192.168.1.2。在192.168.1.1上运行服务器，而在192.168.1.2上运行客户端。

首先，我们需要编译我们的代码。运行命令javac Server.java和javac Client.java来分别编译服务器和客户端。

然后，在192.168.1.1上运行服务器。运行命令java Server。服务器将开始等待来自客户端的连接。

接下来，在192.168.1.2上运行客户端。运行命令java Client。客户端将尝试连接到服务器，并且要求输入要发送的消息。

在客户端上输入消息，并按回车键。该消息将发送到服务器，并被转发到所有已连接的客户端。

示例：运行多个客户端

您可以在不同的计算机上运行多个客户端。只需在每个客户端上运行相同的java Client命令即可。所有客户端都将连接到同一个服务器，并且可以互相发送消息。

结论

在本文中，我向您展示了如何使用Java语言实现一个简单的局域网聊天室。我们使用了Java的Socket API进行通信，并且在服务器上为每个连接创建了一个单独的线程。虽然这个聊天室很简单，我们可以根据需要添加新的功能以满足您的需求。