统一消息系统

public class Message {

private String content;

private String type;

// Getters and Setters

}

import java.util.ArrayList;

import java.util.List;

public class MessageManager {

private List messages = new ArrayList<>();

public void addMessage(Message message) {

messages.add(message);

}

public List getMessages() {

return messages;

}

}

@ServerEndpoint("/websocket")

public class WebSocketServer {

@OnOpen

public void onOpen(Session session) {

System.out.println("New connection: " + session.getId());

}

@OnMessage

public void onMessage(String message, Session session) {

System.out.println("Received message: " + message);

}

@OnClose

public void onClose(Session session) {

System.out.println("Connection closed: " + session.getId());

师生网上服务大厅

}

}