更新websocket，非Stomp协议的原生WebSocket协议。

Xiong Neng · Xiong Neng · commit 66c4d7ae39ff · 2018-03-22T11:09:56.000+08:00
diff --git a/springboot-websocket/src/main/java/com/xncoding/jwt/handler/SocketHandler.java b/springboot-websocket/src/main/java/com/xncoding/jwt/handler/SocketHandler.java
@@ -38,10 +38,10 @@ public void handleTextMessage(WebSocketSession session, TextMessage message) thr
         // 我这儿并没有做处理，消息的封装格式一般有{from:xxxx,to:xxxxx,msg:xxxxx}，来自哪里，发送给谁，什么消息等等
         String msg = message.getPayload();
         logger.info("msg = " + msg);
-        WsParam wsParam = JacksonUtil.json2Bean(msg, new TypeReference<WsParam>(){});
+        WsParam<String> wsParam = JacksonUtil.json2Bean(msg, new TypeReference<WsParam<String>>(){});
         if ("list".equals(wsParam.getMethod())) {
             logger.info("call list method...");
-            WsResponse response = new WsResponse();
+            WsResponse<String> response = new WsResponse<>();
             response.setResult("hello list");
             sendMessageToUser(session, new TextMessage(JacksonUtil.bean2Json(response)));
         }
diff --git a/springboot-websocket/src/main/java/com/xncoding/jwt/model/WsParam.java b/springboot-websocket/src/main/java/com/xncoding/jwt/model/WsParam.java
@@ -7,9 +7,9 @@
  * @version 1.0
  * @since 2018/3/22
  */
-public class WsParam {
+public class WsParam<T> {
     private String method;
-    private Object param;
+    private T param;
 
     public String getMethod() {
         return method;
@@ -19,11 +19,11 @@ public void setMethod(String method) {
         this.method = method;
     }
 
-    public Object getParam() {
+    public T getParam() {
         return param;
     }
 
-    public void setParam(Object param) {
+    public void setParam(T param) {
         this.param = param;
     }
 }
diff --git a/springboot-websocket/src/main/java/com/xncoding/jwt/model/WsResponse.java b/springboot-websocket/src/main/java/com/xncoding/jwt/model/WsResponse.java
@@ -7,14 +7,14 @@
  * @version 1.0
  * @since 2018/3/22
  */
-public class WsResponse {
-    private Object result;
+public class WsResponse<T> {
+    private T result;
 
-    public Object getResult() {
+    public T getResult() {
         return result;
     }
 
-    public void setResult(Object result) {
+    public void setResult(T result) {
         this.result = result;
     }
 }
diff --git a/springboot-websocket/src/test/java/com/xncoding/jwt/socket/client/html/index1.html b/springboot-websocket/src/test/java/com/xncoding/jwt/socket/client/html/index1.html
@@ -3,10 +3,9 @@
     <meta charset="UTF-8"/>
     <title>广播式WebSocket</title>
     <script src="js/sockjs.min.js"></script>
-    <script src="js/stomp.js"></script>
     <script src="js/jquery-3.1.1.js"></script>
 </head>
-<body onload="disconnect()">
+<body>
 <noscript><h2 style="color: #e80b0a;">Sorry，浏览器不支持WebSocket</h2></noscript>
 <div>
     <div>
@@ -22,12 +21,50 @@
     </div>
 </div>
 <script type="text/javascript">
+    var curTryNum = 0;
+    var url = 'ws://localhost:8282/app';
     var ws;
     function connect() {
-        ws = new WebSocket('ws://localhost:8092/app');
-        ws.onmessage = function(data){
-            console.log("msg = " + JSON.stringify(data.data));
-            showResponse(data.data);
+        ws = new WebSocket(url);
+        /**
+         * 因为服务端在 300s 未传输数据时会主动关闭连接，所以，客户端需要定时发送数据保持连接。
+         */
+        var heartCheck = {
+            timeout: 50000, //50s
+            timeoutObj: null,
+            reset: function(){
+                clearInterval(this.timeoutObj);
+                this.start();
+            },
+            start: function(){
+                this.timeoutObj = setInterval(function(){
+                    if(ws.readyState === 1){
+                        ws.send("hb");
+                    }
+                }, this.timeout)
+            }
+        };
+        ws.onopen = function (evnt) {
+            console.log("onopen: ", evnt);
+            heartCheck.start();
+        };
+        ws.onmessage = function(message){
+            // 无论收到什么信息，说明当前连接正常，将心跳检测的计时器重置
+            heartCheck.reset();
+            console.log("client received a message.data: " + message.data);
+            if (message.data !== "hb_ok") {
+                // 不要将ping的答复信息输出
+                console.log("msg = " + JSON.stringify(message.data));
+                var response = JSON.parse(message.data);
+                console.log("message.data.method = " + response.method);
+                showResponse(JSON.stringify(response.result));
+            }
+        };
+        ws.onclose  = function (event) {
+            if (event.code !== 4500) {
+                //4500为服务端在打开多tab时主动关闭返回的编码
+                connect();
+            }
         };
         setConnected(true);
     }

Original file line number	Diff line number	Diff line change
`@@ -7,9 +7,9 @@`
`7`	`7`	`* @version 1.0`
`8`	`8`	`* @since 2018/3/22`
`9`	`9`	`*/`
`10`		`-public class WsParam {`
	`10`	`+public class WsParam<T> {`
`11`	`11`	`private String method;`
`12`		`- private Object param;`
	`12`	`+ private T param;`
`13`	`13`
`14`	`14`	`public String getMethod() {`
`15`	`15`	`return method;`
`@@ -19,11 +19,11 @@ public void setMethod(String method) {`
`19`	`19`	`this.method = method;`
`20`	`20`	`}`
`21`	`21`
`22`		`- public Object getParam() {`
	`22`	`+ public T getParam() {`
`23`	`23`	`return param;`
`24`	`24`	`}`
`25`	`25`
`26`		`- public void setParam(Object param) {`
	`26`	`+ public void setParam(T param) {`
`27`	`27`	`this.param = param;`
`28`	`28`	`}`
`29`	`29`	`}`
Original file line number	Diff line number	Diff line change
`@@ -7,14 +7,14 @@`
`7`	`7`	`* @version 1.0`
`8`	`8`	`* @since 2018/3/22`
`9`	`9`	`*/`
`10`		`-public class WsResponse {`
`11`		`- private Object result;`
	`10`	`+public class WsResponse<T> {`
	`11`	`+ private T result;`
`12`	`12`
`13`		`- public Object getResult() {`
	`13`	`+ public T getResult() {`
`14`	`14`	`return result;`
`15`	`15`	`}`
`16`	`16`
`17`		`- public void setResult(Object result) {`
	`17`	`+ public void setResult(T result) {`
`18`	`18`	`this.result = result;`
`19`	`19`	`}`
`20`	`20`	`}`