@PostConstruct
public void socketServer() {
log.info("SocketIOServer启动成功");
Configuration config = new Configuration();
config.setPort(19568);
config.setTransports(Transport.WEBSOCKET, Transport.POLLING);
config.setPingTimeout(11000);
config.setPingInterval(3000);
SocketIOServer server = new SocketIOServer(config);
//连接
server.addConnectListener(new ConnectListener() {
@Override
public void onConnect(SocketIOClient client) {
log.info("EventListener连接成功");
clientMap.put("1", client);
}
});
//log.info("大小"+clientMap.size());
//监听
server.addEventListener("tell", ImMessage.class, new DataListener<ImMessage>() {
public void onData(SocketIOClient client, ImMessage data, AckRequest ackRequest) {
//TODO
log.info("EventListener监听成功");
}
});
//断开
server.addDisconnectListener (new DisconnectListener() {
public void onDisconnect (SocketIOClient client) {
//TODO
log.info("DisconnectListener退出成功");
}
});
server.start();
log.info("SocketIO启动成功");
}![图片说明](https://img-ask.csdn.net/upload/201907/22/1563785480_420627.png)