如何使用Java Websocket实现实时股票行情展示？

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;

@ServerEndpoint("/stock")
public class StockWebSocketServer {
    private static final Set<Session> sessions = new CopyOnWriteArraySet<>();

    @OnOpen
    public void onOpen(Session session) {
        sessions.add(session);
        // 在此处可以进行一些初始化操作，比如订阅股票行情数据
    }

    @OnClose
    public void onClose(Session session) {
        sessions.remove(session);
        // 在此处进行资源释放操作，比如取消订阅股票行情数据
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        // 在此处可以处理客户端发送的消息
    }

    @OnError
    public void onError(Throwable throwable) {
        // 在此处处理错误信息
    }

    public static void sendMessage(String message) {
        for (Session session : sessions) {
            try {
                session.getBasicRemote().sendText(message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

import java.util.Random;

public class StockSource {
    private static final String[] STOCKS = {"AAPL", "GOOGL", "AMZN", "MSFT"};
    private static final Random RANDOM = new Random();
    
    public static void start() {
        new Thread(() -> {
            while (true) {
                String stock = randomStock();
                double price = randomPrice();
                String message = stock + ": " + price;
                StockWebSocketServer.sendMessage(message);
                sleep(1000);
            }
        }).start();
    }
    
    private static String randomStock() {
        int index = RANDOM.nextInt(STOCKS.length);
        return STOCKS[index];
    }
    
    private static double randomPrice() {
        return RANDOM.nextDouble() * 1000;
    }
    
    private static void sleep(int milliseconds) {
        try {
            Thread.sleep(milliseconds);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class Main {
    public static void main(String[] args) {
        StockSource.start();

        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        try {
            container.connectToServer(StockWebSocketServer.class, new URI("ws://localhost:8080/stock"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}