Java WebSocket客户端数据传递至父类管理器：观察者模式实践-java教程-PHP中文网

Java WebSocket客户端数据传递至父类管理器：观察者模式实践

心靈之曲

发布： 2025-07-30 18:42:01

原创

901人浏览过

java websocket客户端数据传递至父类管理器：观察者模式实践

本文介绍如何使用观察者模式在Java WebSocket客户端中将数据从子类（WebSocket客户端）传递到父类（客户端管理器）。通过实现观察者模式，可以实现WebSocket客户端状态更新和数据事件的有效管理，同时避免不必要的性能损失，确保系统的可维护性和扩展性。

正文：

在Java WebSocket应用中，经常需要将WebSocket客户端实例中的数据传递到父类管理器中，以便集中管理和处理。一个常见的场景是，AuthClient 类继承自 WebSocketClient，并在 onMessage 回调函数中处理不同的WebSocket状态。而 ClientManager 类负责存储和管理多个 AuthClient 实例。本教程将介绍如何使用观察者模式高效地将数据从 AuthClient 传递到 ClientManager，并提供示例代码。

观察者模式简介

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

观察者模式是一种行为设计模式，它定义了对象之间的一对多依赖关系，使得当一个对象（被观察者）的状态发生改变时，所有依赖于它的对象（观察者）都会收到通知并自动更新。

实现步骤

定义观察者接口 (Observer)

首先，定义一个观察者接口，该接口声明了一个 update 方法，用于接收来自被观察者的更新通知。

public interface Observer {
    void update(String message);
}

登录后复制

定义被观察者接口 (Observable)

然后，定义一个被观察者接口，该接口声明了 registerObserver、removeObserver 和 notifyObservers 方法，用于管理观察者列表和通知观察者。

知我AI·PC客户端

离线运行 AI 大模型，构建你的私有个人知识库，对话式提取文件知识，保证个人文件数据安全

查看详情

import java.util.List;

public interface Observable {
    void registerObserver(Observer observer);
    void removeObserver(Observer observer);
    void notifyObservers(String message);
}

登录后复制

实现具体的被观察者 (AuthClient)

AuthClient 类继承自 WebSocketClient，并实现 Observable 接口。在 AuthClient 中，维护一个观察者列表，并在 onMessage 方法中调用 notifyObservers 方法，将接收到的消息通知给所有注册的观察者。

import java.util.ArrayList;
import java.util.List;

public class AuthClient extends WebSocketClient implements Observable {

    private List<Observer> observers = new ArrayList<>();

    @Override
    public void onMessage(String message) {
        switch (message) {
            // data events here
            default:
                notifyObservers(message);
                break;
        }
    }

    @Override
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObservers(String message) {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }
}

登录后复制

实现具体的观察者 (ClientManager)

ClientManager 类实现 Observer 接口。在 ClientManager 的构造函数中，将自身注册为 AuthClient 的观察者。在 update 方法中，处理接收到的消息。

import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;

public class ClientManager implements Observer {

    private int maxClients;
    private final Map<String, AuthClient> clients;
    private final HashSet<String> tokens;

    public ClientManager(HashSet<String> tokens, int maxClients) {
        this.tokens = tokens;
        this.maxClients = maxClients;
        this.clients = new HashMap<>(maxClients);
    }

    public void addClient(String clientId, AuthClient client) {
        this.clients.put(clientId, client);
        client.registerObserver(this); // Register itself as an observer
    }

    @Override
    public void update(String message) {
        // Process the message received from AuthClient
        System.out.println("Received message from AuthClient: " + message);
        // Add your logic here to handle the message
    }
}

登录后复制

使用示例

以下代码演示了如何使用观察者模式将数据从 AuthClient 传递到 ClientManager。

public class Main {
    public static void main(String[] args) {
        HashSet<String> tokens = new HashSet<>();
        tokens.add("token1");
        tokens.add("token2");

        ClientManager clientManager = new ClientManager(tokens, 10);

        AuthClient authClient1 = new AuthClient();
        AuthClient authClient2 = new AuthClient();

        clientManager.addClient("client1", authClient1);
        clientManager.addClient("client2", authClient2);

        // Simulate receiving a message in AuthClient
        authClient1.onMessage("Hello from AuthClient 1");
        authClient2.onMessage("Hello from AuthClient 2");
    }
}

登录后复制

注意事项

避免循环依赖： 确保观察者和被观察者之间没有循环依赖关系，否则可能导致无限循环。
线程安全： 如果观察者和被观察者在不同的线程中运行，需要考虑线程安全问题。可以使用线程安全的集合类或同步机制来保护共享数据。
性能考虑： 如果观察者数量很多，notifyObservers 方法可能会影响性能。可以考虑使用异步方式通知观察者。

总结

观察者模式是一种有效的解耦对象之间依赖关系的设计模式。通过使用观察者模式，可以将数据从WebSocket客户端传递到客户端管理器，实现状态更新和数据事件的有效管理，同时避免不必要的性能损失。本教程提供了一个简单的示例，展示了如何使用观察者模式在Java WebSocket应用中实现数据传递。在实际应用中，可以根据具体需求进行调整和扩展。

以上就是Java WebSocket客户端数据传递至父类管理器：观察者模式实践的详细内容，更多请关注php中文网其它相关文章！