58 lines
1.3 KiB
Java
58 lines
1.3 KiB
Java
import java.io.IOException;
|
|
import java.nio.ByteBuffer;
|
|
|
|
import javax.websocket.OnMessage;
|
|
import javax.websocket.OnOpen;
|
|
import javax.websocket.PongMessage;
|
|
import javax.websocket.Session;
|
|
import javax.websocket.server.ServerEndpoint;
|
|
|
|
@ServerEndpoint("/")
|
|
public class app {
|
|
|
|
@OnOpen
|
|
public void onOpen(Session session) {
|
|
session.setMaxTextMessageBufferSize(8388608);
|
|
}
|
|
|
|
@OnMessage
|
|
public void echoTextMessage(Session session, String msg) {
|
|
try {
|
|
if (session.isOpen()) {
|
|
session.getBasicRemote().sendText(msg, true);
|
|
}
|
|
} catch (IOException e) {
|
|
try {
|
|
session.close();
|
|
} catch (IOException e1) {
|
|
// Ignore
|
|
}
|
|
}
|
|
}
|
|
|
|
@OnMessage
|
|
public void echoBinaryMessage(Session session, ByteBuffer bb) {
|
|
try {
|
|
if (session.isOpen()) {
|
|
session.getBasicRemote().sendBinary(bb, true);
|
|
}
|
|
} catch (IOException e) {
|
|
try {
|
|
session.close();
|
|
} catch (IOException e1) {
|
|
// Ignore
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Process a received pong. This is a NO-OP.
|
|
*
|
|
* @param pm Ignored.
|
|
*/
|
|
@OnMessage
|
|
public void echoPongMessage(PongMessage pm) {
|
|
// NO-OP
|
|
}
|
|
}
|