|
|
|
package com.sunyo.wlpt.cgonms.provide.websocket;
|
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.json.JSON;
|
|
|
|
import cn.hutool.json.JSONObject;
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
|
import cn.hutool.log.Log;
|
|
|
|
import cn.hutool.log.LogFactory;
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
import com.sunyo.wlpt.cgonms.provide.controller.NmsController;
|
|
|
|
import com.sunyo.wlpt.cgonms.provide.response.ResultJson;
|
|
|
|
import com.sunyo.wlpt.cgonms.provide.response.ResultWs;
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
...
|
...
|
@@ -53,13 +54,8 @@ public class WebSocketServer { |
|
|
|
log.info("有新窗口开始监听:" + sid + ",当前在线人数为" + getOnlineCount());
|
|
|
|
this.sid = sid;
|
|
|
|
try {
|
|
|
|
String openMessage = "{\n" +
|
|
|
|
" \"sid\":\"" + sid + "\",\n" +
|
|
|
|
" \"session\":\"" + session + "\",\n" +
|
|
|
|
" \"message\": \"连接成功\",\n" +
|
|
|
|
" \"data\":{\"flightdate\":\"2015-02-05\",\"flightNo\":\"CV987\"}\n" +
|
|
|
|
"}";
|
|
|
|
sendMessage(openMessage);
|
|
|
|
String resultStart = JSON.toJSONString(new ResultWs("连接成功，可以开始查询！" ));
|
|
|
|
sendMessage(resultStart);
|
|
|
|
} catch (IOException e) {
|
|
|
|
log.error("websocket IO异常");
|
|
|
|
}
|
...
|
...
|
|
