Java聊天室之实现客户端一对一聊天功能

实现Java聊天室中的一对一聊天功能，需要涉及到客户端和服务器端的编写。

1. 设计思路

客户端与服务器端之间需要建立起TCP连接，首先需要在客户端上实现一个发送和接收消息的模块，与此同时，需要在服务器端上能够接收到客户端发送的消息，再将其转发给目标用户。

设计思路如下：

1. 客户端输入目标用户的用户名
2. 通过TCP连接，向服务器端发送一条消息，告知服务器需要与目标用户建立一对一聊天的连接
3. 服务器接收到消息后，将其转发给目标用户
4. 目标用户接收到消息后，向服务器端回复消息
5. 服务器接收到回复消息后，再将其转发给发起连接的用户

2. 客户端实现

客户端需要实现一个发送和接受消息的模块，示例如下：

public class Client {

    // 初始化socket
    private Socket socket;

    // 初始化输入输出流
    private BufferedReader in;
    private PrintWriter out;

    // 连接服务器
    public void connect() {
        try {
            socket = new Socket("localhost", 9999);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(), true);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 发送消息
    public void sendMessage(String message) {
        out.println(message);
    }

    // 接收消息
    public String receiveMessage() {
        try {
            return in.readLine();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }
}

在建立与服务器的连接后，通过sendMessage()方法向服务器发送一条消息，告知服务器需要和目标用户开始一对一聊天的连接。示例如下：

Client client = new Client();
client.connect();
client.sendMessage("connect:user1");

这条消息的格式为“connect:用户名”，服务器需要根据这个信息，判断目标用户是否在线，如果在线，则建立起一对一连接。

3. 服务器端实现

服务器需要实现一个消息转发的模块，示例如下：

public class Server {

    // 初始化socket和用户列表
    private ServerSocket server;
    private List<Client> clients = new ArrayList<>();

    // 监听端口
    public void start() {
        try {
            server = new ServerSocket(9999);
            System.out.println("Server started on port 9999");

            // 监听客户端连接
            while (true) {
                Socket socket = server.accept();
                Client client = new Client(socket, this);
                clients.add(client);
                client.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 客户端向服务器发送消息
    public void receiveMessage(Client client, String message) {
        if (message.startsWith("connect:")) {
            String username = message.substring(8);

            // 遍历用户列表
            for (Client c : clients) {
                if (c != client && c.getUsername() != null && 
                    c.getUsername().equals(username)) {
                    // 将消息转发给目标用户
                    client.sendMessage("Connected to " + username);
                    c.sendMessage(client.getUsername() + " connected to you");
                    System.out.println(client.getUsername() + " connected to " + username);
                    return;
                }
            }
            // 如果目标用户不在线，发送错误消息
            client.sendMessage(username + " is not online");
        } else {
            // 将消息转发给目标用户
            String username = message.substring(0, message.indexOf(":"));
            String msg = message.substring(message.indexOf(":") + 1);
            for (Client c : clients) {
                if (c.getUsername() != null && c.getUsername().equals(username)) {
                    c.sendMessage(client.getUsername() + ": " + msg);
                    return;
                }
            }
            // 如果目标用户不在线，发送错误消息
            client.sendMessage(username + " is not online");
        }
    }

    // 客户端退出
    public void removeClient(Client client) {
        clients.remove(client);
        System.out.println(client.getUsername() + " is offline");
    }

    // 启动服务器
    public static void main(String[] args) {
        Server server = new Server();
        server.start();
    }
}

这个模块实现了对用户发来的消息的接收和转发功能，其中receiveMessage()方法实现了发送消息的逻辑，通过判断消息类型，将消息转发给目标用户。

4. 总结

通过以上的Demo，可以实现Java聊天室中的一对一聊天功能。主要实现思路是，在客户端与服务器建立连接之后，确定目标用户并告知服务器，从而触发服务器进行消息转发。在实际应用中，可以根据需要进行改进，例如增加好友列表、聊天记录等功能。