自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

Springboot整合Websocket實(shí)現(xiàn)后端向前端主動(dòng)推送消息案例

作者：馮冬冬
開發(fā) 架構(gòu)
在手機(jī)上相信都有來自服務(wù)器的推送消息，比如一些及時(shí)的新聞信息，這篇文章主要就是實(shí)現(xiàn)這個(gè)功能，只演示一個(gè)基本的案例。使用的是websocket技術(shù)。

[[389702]]

在手機(jī)上相信都有來自服務(wù)器的推送消息，比如一些及時(shí)的新聞信息，這篇文章主要就是實(shí)現(xiàn)這個(gè)功能，只演示一個(gè)基本的案例。使用的是websocket技術(shù)。

一、什么是websocke

tWebSocket協(xié)議是基于TCP的一種新的網(wǎng)絡(luò)協(xié)議。它實(shí)現(xiàn)了客戶端與服務(wù)器全雙工通信，學(xué)過計(jì)算機(jī)網(wǎng)絡(luò)都知道，既然是全雙工，就說明了服務(wù)器可以主動(dòng)發(fā)送信息給客戶端。這與我們的推送技術(shù)或者是多人在線聊天的功能不謀而合。

為什么不使用HTTP 協(xié)議呢?這是因?yàn)镠TTP是單工通信，通信只能由客戶端發(fā)起，客戶端請(qǐng)求一下，服務(wù)器處理一下，這就太麻煩了。于是websocket應(yīng)運(yùn)而生。

下面我們就直接開始使用Springboot開始整合。以下案例都在我自己的電腦上測(cè)試成功，你可以根據(jù)自己的功能進(jìn)行修改即可。

二、整合websocket

1、環(huán)境配置

Idea 2018專業(yè)版(已破解)

Maven 4.0.0

SpringBoot 2.2.2

websocket 2.1.3

jdk 1.8

下面我們新建一個(gè)普通的Springboot項(xiàng)目。

2、添加依賴

  1. <dependencies> 
  2.      <dependency> 
  3.          <groupId>org.springframework.boot</groupId> 
  4.          <artifactId>spring-boot-starter-web</artifactId> 
  5.      </dependency> 
  6.      <dependency> 
  7.          <groupId>org.springframework.boot</groupId> 
  8.          <artifactId>spring-boot-starter-test</artifactId> 
  9.          <scope>test</scope> 
  10.      </dependency> 
  11.      <dependency> 
  12.          <groupId>org.springframework.boot</groupId> 
  13.          <artifactId>spring-boot-starter-websocket</artifactId> 
  14.          <version>2.1.3.RELEASE</version> 
  15.      </dependency> 
  16.  </dependencies> 

3、在application.properties文件修改端口號(hào)

一句話：server.port=8081

4、新建config包，創(chuàng)建WebSocketConfig類

  1. 1@Configuration 
  2. 2public class WebSocketConfig { 
  3. 3    @Bean 
  4. 4    public ServerEndpointExporter serverEndpointExporter() { 
  5. 5        return new ServerEndpointExporter(); 
  6. 6    } 
  7. 7} 

5、新建service包，創(chuàng)建WebSocketServer類

  1. @ServerEndpoint("/websocket/{sid}") 
  2. @Component 
  3. public class WebSocketServer { 
  4.     static Log log= LogFactory.getLog(WebSocketServer.class); 
  5.     //靜態(tài)變量，用來記錄當(dāng)前在線連接數(shù)。應(yīng)該把它設(shè)計(jì)成線程安全的。 
  6.     private static int onlineCount = 0; 
  7.     //concurrent包的線程安全Set，用來存放每個(gè)客戶端對(duì)應(yīng)的MyWebSocket對(duì)象。 
  8.     private static CopyOnWriteArraySet<WebSocketServer> webSocketSet 
  9.             = new CopyOnWriteArraySet<WebSocketServer>(); 
  10.     //與某個(gè)客戶端的連接會(huì)話，需要通過它來給客戶端發(fā)送數(shù)據(jù) 
  11.     private Session session; 
  12.     //接收sid 
  13.     private String sid=""; 
  14.     /** 
  15.      * 連接建立成功調(diào)用的方法 
  16.      */ 
  17.     @OnOpen 
  18.     public void onOpen(Session session,@PathParam("sid") String sid) { 
  19.         this.session = session; 
  20.         webSocketSet.add(this);     //加入set中 
  21.         addOnlineCount();           //在線數(shù)加1 
  22.         log.info("有新窗口開始監(jiān)聽:"+sid+",當(dāng)前在線人數(shù)為" + getOnlineCount()); 
  23.         this.sid=sid; 
  24.         try { 
  25.             sendMessage("連接成功"); 
  26.         } catch (IOException e) { 
  27.             log.error("websocket IO異常"); 
  28.         } 
  29.     } 
  30.     /** 
  31.      * 連接關(guān)閉調(diào)用的方法 
  32.      */ 
  33.     @OnClose 
  34.     public void onClose() { 
  35.         webSocketSet.remove(this);  //從set中刪除 
  36.         subOnlineCount();           //在線數(shù)減1 
  37.         log.info("有一連接關(guān)閉！當(dāng)前在線人數(shù)為" + getOnlineCount()); 
  38.     } 
  39.     /** 
  40.      * 收到客戶端消息后調(diào)用的方法 
  41.      * @param message 客戶端發(fā)送過來的消息 
  42.      */ 
  43.     @OnMessage 
  44.     public void onMessage(String message, Session session) { 
  45.         log.info("收到來自窗口"+sid+"的信息:"+message); 
  46.         //群發(fā)消息 
  47.         for (WebSocketServer item : webSocketSet) { 
  48.             try { 
  49.                 item.sendMessage(message); 
  50.             } catch (IOException e) { 
  51.                 e.printStackTrace(); 
  52.             } 
  53.         } 
  54.     } 
  55.     @OnError 
  56.     public void onError(Session session, Throwable error) { 
  57.         log.error("發(fā)生錯(cuò)誤"); 
  58.         error.printStackTrace(); 
  59.     } 
  60.     //實(shí)現(xiàn)服務(wù)器主動(dòng)推送 
  61.     public void sendMessage(String message) throws IOException { 
  62.         this.session.getBasicRemote().sendText(message); 
  63.     } 
  64.     //群發(fā)自定義消息 
  65.     public static void sendInfo(String message,@PathParam("sid") String sid)  
  66.         throws IOException { 
  67.         log.info("推送消息到窗口"+sid+"，推送內(nèi)容:"+message); 
  68.         for (WebSocketServer item : webSocketSet) { 
  69.             try { 
  70.                 //這里可以設(shè)定只推送給這個(gè)sid的，為null則全部推送 
  71.                 if(sid==null) { 
  72.                     item.sendMessage(message); 
  73.                 }else if(item.sid.equals(sid)){ 
  74.                     item.sendMessage(message); 
  75.                 } 
  76.             } catch (IOException e) { 
  77.                 continue; 
  78.             } 
  79.         } 
  80.     } 
  81.     public static synchronized int getOnlineCount() { 
  82.         return onlineCount; 
  83.     } 
  84.     public static synchronized void addOnlineCount() { 
  85.         WebSocketServer.onlineCount++; 
  86.     } 
  87.     public static synchronized void subOnlineCount() { 
  88.         WebSocketServer.onlineCount--; 
  89.     } 

6、新建controller包，創(chuàng)建Mycontroller類

  1. @Controller 
  2. public class MyController { 
  3.     //頁面請(qǐng)求 
  4.     @GetMapping("/socket/{cid}") 
  5.     public ModelAndView socket(@PathVariable String cid) { 
  6.         ModelAndView mav=new ModelAndView("/socket"); 
  7.         mav.addObject("cid", cid); 
  8.         return mav; 
  9.     } 
  10.     //推送數(shù)據(jù)接口 
  11.     @ResponseBody 
  12.     @RequestMapping("/socket/push/{cid}") 
  13.     public String pushToWeb(@PathVariable String cid,String message) { 
  14.         try { 
  15.             WebSocketServer.sendInfo(message,cid); 
  16.         } catch (IOException e) { 
  17.             e.printStackTrace(); 
  18.             return "推送失敗"; 
  19.         } 
  20.         return "發(fā)送成功"; 
  21.     } 
  22. }} 

7、新建一個(gè)websocket.html頁面

  1. <html> 
  2. <head> 
  3.     <meta name="viewport" content="initial-scale=1.0, user-scalable=no" /> 
  4.     <script type="text/javascript"> 
  5.         var socket; 
  6.         if (typeof (WebSocket) == "undefined") { 
  7.             console.log("您的瀏覽器不支持WebSocket"); 
  8.         } else { 
  9.             console.log("您的瀏覽器支持WebSocket"); 
  10.             //實(shí)現(xiàn)化WebSocket對(duì)象，指定要連接的服務(wù)器地址與端口  建立連接   
  11.             socket = new WebSocket("ws://localhost:8081/websocket/1"); 
  12.             //打開事件   
  13.             socket.onopen = function () { 
  14.                 console.log("Socket 已打開"); 
  15.                 socket.send("這是來自客戶端的消息" + location.href + new Date()); 
  16.             }; 
  17.             //獲得消息事件   
  18.             socket.onmessage = function (msg) { 
  19.                 console.log(msg.data); 
  20.             }; 
  21.             //關(guān)閉事件   
  22.             socket.onclose = function () { 
  23.                 console.log("Socket已關(guān)閉"); 
  24.             }; 
  25.             //發(fā)生了錯(cuò)誤事件   
  26.             socket.onerror = function () { 
  27.                 alert("Socket發(fā)生了錯(cuò)誤"); 
  28.             } 
  29.         } 
  30.     </script> 
  31. </head> 
  32. </html> 

 

現(xiàn)在開發(fā)服務(wù)器和網(wǎng)頁就可以看到效果了。一般情況下Springboot2+Netty+Websocket的組合方式更加的常用一下。這個(gè)只是給出了一個(gè)基本的案例，你可以根據(jù)自己的需求進(jìn)行更改。

本文轉(zhuǎn)載自微信公眾號(hào)「愚公要移山」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請(qǐng)聯(lián)系愚公要移山公眾號(hào)。

 

責(zé)任編輯：武曉燕 來源： 愚公要移山
SpringbootWebsocket前端
相關(guān)推薦

2021-02-05 07:28:11

SpringbootNettyWebsocke

2023-08-09 08:01:00

WebSockett服務(wù)器web

2021-03-25 08:29:33

SpringBootWebSocket即時(shí)消息

2023-08-14 08:01:12

websocket8g用戶

2024-09-11 08:35:54

2024-09-02 09:31:19

2024-08-02 09:00:17

NettyWebSocketNIO

2023-01-13 00:02:41

2023-01-05 09:17:58

2023-09-04 08:00:53

提交事務(wù)消息

2023-10-12 08:00:48

2024-11-14 12:22:37

SpringMail郵件

2021-04-15 09:17:01

SpringBootRocketMQ

2017-05-09 10:07:34

SpringbootDubboZooKeeper

2024-09-12 14:50:08

2022-06-28 08:37:07

分布式服務(wù)器WebSocket

2024-11-14 11:56:45

2022-01-10 11:58:51

SpringBootPulsar分布式

2013-05-17 15:34:45

2023-07-26 07:28:55

WebSocket服務(wù)器方案
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)