import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/websocket")
public class MyWebSocketEndpoint {
@OnOpen
public void onOpen(Session session) {
}
@OnMessage
public void onMessage(String message, Session session) {
}
@OnClose
public void onClose(Session session) {
}
@OnError
public void onError(Throwable error) {
}
}
@ServerEndpoint("/websocket")
public class MyWebSocketEndpoint {
@OnMessage
public void onMessage(String message, Session session) {
String response = "Hello, " + message + "!";
}
}
@ServerEndpoint("/websocket")
public class MyWebSocketEndpoint {
private static Set<Session> sessions = Collections.synchronizedSet(new HashSet<>());
@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) {
for (Session s : sessions) {
s.getBasicRemote().sendText(message);
}
}
}
@ServerEndpoint("/websocket")
public class MyWebSocketEndpoint {
@OnError
public void onError(Throwable error) {
System.out.println("WebSocket Error: " + error.getMessage());
}
}
