Java 小程序实时更新数据：预约系统实战教程

要实现实时更新数据，可以使用 WebSocket 技术来实现实时通信。WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，可以在客户端和服务器之间建立持久性的连接，实现实时数据的传输。

下面是一个简单的示例代码，演示如何使用 WebSocket 实现实时更新数据：

创建 WebSocket 处理器类：

import org.springframework.stereotype.Component;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.WebSocketMessage;
import org.springframework.web.socket.WebSocketSession;

import java.util.concurrent.CopyOnWriteArrayList;

@Component
public class MyWebSocketHandler implements WebSocketHandler {

    // 保存所有连接的 WebSocket 会话
    private static final CopyOnWriteArrayList<WebSocketSession> sessions = new CopyOnWriteArrayList<>();

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        // 建立连接时触发
        sessions.add(session);
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        // 接收消息时触发
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        // 传输错误时触发
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        // 连接关闭时触发
        sessions.remove(session);
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }

    // 通过 WebSocket 发送消息
    public static void sendMessage(String message) {
        TextMessage textMessage = new TextMessage(message);
        for (WebSocketSession session : sessions) {
            try {
                session.sendMessage(textMessage);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

在 Spring Boot 中配置 WebSocket：

import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new MyWebSocketHandler(), '/websocket').setAllowedOrigins('*');
    }
}

在需要实时更新数据的地方调用 MyWebSocketHandler.sendMessage() 方法发送消息：

public class CourseService {

    public void updateCourseStatus() {
        // 更新课程状态的逻辑

        // 发送消息给所有连接的客户端
        MyWebSocketHandler.sendMessage('课程状态已更新');
    }
}

前端页面中使用 JavaScript 代码建立 WebSocket 连接并接收消息：

var websocket = new WebSocket('ws://localhost:8080/websocket');

websocket.onmessage = function(event) {
    var message = event.data;
    // 处理接收到的消息
    console.log(message);
};

websocket.onclose = function(event) {
    // 连接关闭时触发
};

websocket.onerror = function(event) {
    // 传输错误时触发
};

// 发送消息
websocket.send('Hello, server!');

通过以上步骤，你可以实现一个基于 WebSocket 的实时更新数据的功能。当课程状态发生变化时，调用 MyWebSocketHandler.sendMessage() 方法发送消息给所有连接的客户端，客户端通过 WebSocket 接收到消息后，可以实时更新课程状态等信息。

注意：

实际应用中，需要根据具体需求进行调整，例如可以将课程状态信息封装成 JSON 格式，然后发送给客户端。
可以使用 Spring Data JPA 或其他持久层框架来管理课程数据，并在数据发生变化时触发 WebSocket 消息的发送。
为了提高性能，可以考虑使用消息队列来异步处理消息发送。
可以使用安全机制来保护 WebSocket 连接。
代码示例中使用了 CopyOnWriteArrayList 来存储所有连接的 WebSocket 会话，该类在添加或删除元素时会创建一个新的列表副本，可以避免并发问题。
可以使用其他 WebSocket 库，例如 SockJS 或 Spring WebSockets 来实现 WebSocket 连接。
为了更好地理解 WebSocket 的原理，可以参考相关文档或书籍。