碼上歡樂
相關內容    簡體    繁體

Spring Boot SockJS應用例子

本文轉載自   查看原文   2019-09-24 22:38   331    SpringBoot

1.SockJS用javascript實現的socket連接，兼容各種瀏覽器的WebSocket支持庫
2.WebSocket是H5的，不支持H5的瀏覽器沒法使用。
3.SockJS它提供類似於websocket的編程模式但是可以適應不同的瀏覽器（包括不支持websocket的瀏覽器）。


后端代碼：

Java代碼   收藏代碼
  1. <dependency>  
  2.     <groupId>org.springframework.boot</groupId>  
  3.     <artifactId>spring-boot-starter-websocket</artifactId>  
  4. </dependency>  




Java代碼   收藏代碼
  1. package com.cesmart;  
  2.   
  3. import org.springframework.boot.SpringApplication;  
  4. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;  
  5. import org.springframework.context.ApplicationContext;  
  6. import org.springframework.context.annotation.ComponentScan;  
  7.   
  8. @EnableAutoConfiguration  
  9. @ComponentScan(basePackages = "com.cesmart") // 掃描那些包得到bean.@ComponentScan({"com.teradata.notification","com.teradata.dal"})  
  10. public class Application {  
  11.     public static void main(String[] args) {  
  12.         ApplicationContext applicationContext = SpringApplication.run(Application.class, args);  
  13.     }  
  14. }  




Java代碼   收藏代碼
  1. package com.cesmart.config;  
  2.   
  3. import org.springframework.web.socket.CloseStatus;  
  4. import org.springframework.web.socket.TextMessage;  
  5. import org.springframework.web.socket.WebSocketHandler;  
  6. import org.springframework.web.socket.WebSocketMessage;  
  7. import org.springframework.web.socket.WebSocketSession;  
  8.   
  9. public class MyHandler implements WebSocketHandler {  
  10.     // 連接繼開處理  
  11.     @Override  
  12.     public void afterConnectionClosed(WebSocketSession arg0, CloseStatus arg1) throws Exception {  
  13.         // TODO Auto-generated method stub  
  14.   
  15.         System.out.println("Connection closed..." + arg0.getRemoteAddress().toString());  
  16.   
  17.     }  
  18.   
  19.     // 連接建立處理  
  20.     @Override  
  21.     public void afterConnectionEstablished(WebSocketSession arg0) throws Exception {  
  22.         // TODO Auto-generated method stub  
  23.         System.out.println("Connection established..." + arg0.getRemoteAddress().toString());  
  24.     }  
  25.   
  26.     // 接收、發送信息處理  
  27.     @Override  
  28.     public void handleMessage(WebSocketSession arg0, WebSocketMessage<?> arg1) throws Exception {  
  29.         // TODO Auto-generated method stub  
  30.         try {  
  31.             System.out.println("Req: " + arg1.getPayload());  
  32.             // 發送信息  
  33.             TextMessage returnMessage = new TextMessage(arg1.getPayload() + " received at server");  
  34.             arg0.sendMessage(returnMessage);  
  35.         } catch (Exception e) {  
  36.             e.printStackTrace();  
  37.         }  
  38.     }  
  39.   
  40.     // 錯誤處理（客戶端突然關閉等接收到的錯誤）  
  41.     @Override  
  42.     public void handleTransportError(WebSocketSession arg0, Throwable arg1) throws Exception {  
  43.         // TODO Auto-generated method stub  
  44.         if (arg0.isOpen()) {  
  45.             arg0.close();  
  46.         }  
  47.         System.out.println(arg1.toString());  
  48.         System.out.println("WS connection error,close...");  
  49.     }  
  50.   
  51.     @Override  
  52.     public boolean supportsPartialMessages() {  
  53.         // TODO Auto-generated method stub  
  54.         return false;  
  55.     }  
  56. }  



Java代碼   收藏代碼
  1. package com.cesmart.config;  
  2.   
  3. import java.util.Map;  
  4.   
  5. import org.springframework.http.server.ServerHttpRequest;  
  6. import org.springframework.http.server.ServerHttpResponse;  
  7. import org.springframework.web.socket.WebSocketHandler;  
  8. import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;  
  9.   
  10. /** 
  11.  * 類描述：攔截器 
  12.  */  
  13. public class MyHandshakeInterceptor extends HttpSessionHandshakeInterceptor {  
  14.   
  15.     @Override  
  16.     public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,  
  17.             Exception ex) {  
  18.         // TODO Auto-generated method stub  
  19.         System.out.println("After handshake " + request.getRemoteAddress().toString());  
  20.         super.afterHandshake(request, response, wsHandler, ex);  
  21.     }  
  22.   
  23.     @Override  
  24.     public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler handler,  
  25.             Map<String, Object> map) throws Exception {  
  26.         // TODO Auto-generated method stub  
  27.         System.out.println("Before handshake " + request.getRemoteAddress().toString());  
  28.         return super.beforeHandshake(request, response, handler, map);  
  29.     }  
  30.   
  31. }  




Java代碼   收藏代碼
  1. package com.cesmart.config;  
  2.   
  3. import org.springframework.context.annotation.Bean;  
  4. import org.springframework.context.annotation.Configuration;  
  5. import org.springframework.web.socket.config.annotation.EnableWebSocket;  
  6. import org.springframework.web.socket.config.annotation.WebSocketConfigurer;  
  7. import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;  
  8.   
  9. @Configuration // 配置類  
  10. @EnableWebSocket // 聲明支持websocket  
  11. public class WebSocketConfig implements WebSocketConfigurer {  
  12.   
  13.     @Override  
  14.     public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {  
  15.         // 注冊websocket實現類，指定參數訪問地址;allowed-origins="*" 允許跨域  
  16.         // addHandler是增加處理接口和設定URL  
  17.         // addInterceptors是增加攔截器處理（可以不用）  
  18.         registry.addHandler(myHandler(), "/ws").addInterceptors(myHandshake()).setAllowedOrigins("*");  
  19.         registry.addHandler(myHandler(), "/sockjs/ws").addInterceptors(myHandshake()).withSockJS();  
  20.   
  21.         registry.addHandler(myHandler(), "/ws2").setAllowedOrigins("*");  
  22.         registry.addHandler(myHandler(), "/sockjs/ws2").setAllowedOrigins("*").withSockJS();  
  23.     }  
  24.   
  25.     @Bean  
  26.     public MyHandler myHandler() {  
  27.         return new MyHandler();  
  28.     }  
  29.   
  30.     @Bean  
  31.     public MyHandshakeInterceptor myHandshake() {  
  32.         return new MyHandshakeInterceptor();  
  33.     }  
  34. }  




前端代碼：

Java代碼   收藏代碼
  1. <!DOCTYPE html>  
  2. <html>  
  3. <head>  
  4.     <meta charset="UTF-8">  
  5.     <title>Insert title here</title>  
  6.     <script type="text/javascript" src="//cdn.bootcss.com/sockjs-client/1.1.1/sockjs.min.js"></script>  
  7.     <script type="text/javascript">  
  8.         var url = "127.0.0.1:8090/";  
  9.         var websocket = null;  
  10.         if ('WebSocket' in window) {  
  11.             websocket = new WebSocket("ws://" + url + "/ws");//建立連接  
  12.         } else {  
  13.             websocket = new SockJS("http://" + url + "/sockjs/ws");//建立連接  
  14.         }  
  15.         //建立連接處理  
  16.         websocket.onopen = onOpen;  
  17.         //接收處理  
  18.         websocket.onmessage = onMessage;  
  19.         //錯誤處理  
  20.         websocket.onerror = onError;  
  21.         //斷開連接處理  
  22.         websocket.onclose = onClose;  
  23.   
  24.         function onOpen(openEvent) {  
  25.             document.getElementById("console").innerHTML = document.getElementById("console").innerHTML+ "OPEN<br/>";  
  26.         }  
  27.   
  28.         function onMessage(event) {  
  29.             document.getElementById("console").innerHTML = document.getElementById("console").innerHTML+ event.data+"<br/>";  
  30.         }  
  31.         function onError() {  
  32.         }  
  33.         function onClose() {  
  34.             document.getElementById("console").innerHTML = document.getElementById("console").innerHTML+ "CLOSE<br/>";  
  35.         }  
  36.   
  37.         function doSend() {  
  38.             console.log(websocket.readyState);  
  39.             if (websocket.readyState == SockJS.OPEN) {  
  40.                 var msg = document.getElementById("message").value;  
  41.                 //發送消息  
  42.                 websocket.send(msg);  
  43.             } else {  
  44.                 alert("連接失敗!");  
  45.             }  
  46.         }  
  47.   
  48.   
  49.         function disconnect(){  
  50.             if (websocket != null) {  
  51.                 websocket.close();  
  52.                 websocket = null;  
  53.             }  
  54.         }  
  55.   
  56.         function reconnect(){  
  57.             if (websocket != null) {  
  58.                 websocket.close();  
  59.                 websocket = null;  
  60.             }  
  61.             if ('WebSocket' in window) {  
  62.                websocket = new WebSocket("ws://" + url + "/ws");  
  63.             } else {  
  64.                 websocket = new SockJS("http://" + url + "/sockjs/ws");  
  65.             }  
  66.             websocket.onopen = onOpen;  
  67.             websocket.onmessage = onMessage;  
  68.             websocket.onerror = onError;  
  69.             websocket.onclose = onClose;  
  70.         }  
  71.     </script>  
  72. </head>  
  73. <body>  
  74. <div>  
  75.     <button id="disconnect" onclick="disconnect()">斷開連接</button>  
  76.     <button id="send" onclick="doSend()">發送消息</button>  
  77.     <button id="reconnect" onclick="reconnect()">重新連接</button>  
  78. </div>  
  79. <div>  
  80.     <textarea id="message" style="width: 350px">Here is a message!</textarea>  
  81. </div>  
  82. <div>日志信息：</div>  
  83. <p id="console" width="600px"></p>  
  84. </body>  
  85. </html>  




參考（websocket簡單應用）：http://wiselyman.iteye.com/blog/2003336
參考（應用例子）：http://768992698.iteye.com/blog/2338250
參考（應用例子（TextWebSocketHandler ））：http://www.cnblogs.com/likun10579/p/5594828.html


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 spring boot入門例子 spring boot rest例子 Spring Boot 2 + jpa + mysql例子 spring boot整合JWT例子 Spring Boot SOAP Webservice例子 Spring Data JPA例子[基於Spring Boot、Mysql] Spring Boot SSL [https]配置例子 Spring boot @EnableScheduling 和 @Scheduled 注解使用例子 Spring Boot Hello World (restful接口)例子 【Spring Boot】關於上傳文件例子的剖析
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM