websocket在web项目中的使用
生活随笔
收集整理的這篇文章主要介紹了
websocket在web项目中的使用
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
websocket可以和服務器建立持久的連接，依靠事件去推動
客戶端代碼：
<%@ page language="java" pageEncoding="UTF-8" %> <!DOCTYPE html> <html> <head><title>Java后端WebSocket的Tomcat實現</title> </head> <body>Welcome<br/><input id="text" type="text"/><button οnclick="send()">發送消息</button><hr/><button οnclick="closeWebSocket()">關閉WebSocket連接</button><hr/><div id="message"></div> </body><script type="text/javascript">var websocket = null;//判斷當前瀏覽器是否支持WebSocketif ('WebSocket' in window) {websocket = new WebSocket("ws://localhost:8080/test/websocket");}else {alert('當前瀏覽器 Not support websocket')}//連接發生錯誤的回調方法websocket.onerror = function () {setMessageInnerHTML("WebSocket連接發生錯誤");};//連接成功建立的回調方法websocket.onopen = function () {setMessageInnerHTML("WebSocket連接成功");}//接收到消息的回調方法websocket.onmessage = function (event) {setMessageInnerHTML(event.data);}//連接關閉的回調方法websocket.onclose = function () {setMessageInnerHTML("WebSocket連接關閉");}//監聽窗口關閉事件，當窗口關閉時，主動去關閉websocket連接，防止連接還沒斷開就關閉窗口，server端會拋異常。window.onbeforeunload = function () {closeWebSocket();}//將消息顯示在網頁上function setMessageInnerHTML(innerHTML) {document.getElementById('message').innerHTML += innerHTML + '<br/>';}//關閉WebSocket連接function closeWebSocket() {websocket.close();}//發送消息function send() {var message = document.getElementById('text').value;websocket.send(message);} </script> </html>
服務器端代碼：
package test;import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet;import javax.websocket.*; import javax.websocket.server.ServerEndpoint;/*** @ServerEndpoint 注解是一個類層次的注解，它的功能主要是將目前的類定義成一個websocket服務器端,* 注解的值將被用于監聽用戶連接的終端訪問URL地址,客戶端可以通過這個URL來連接到WebSocket服務器端*/ @ServerEndpoint("/websocket") public class WebSocketTest {//靜態變量，用來記錄當前在線連接數。應該把它設計成線程安全的。private static int onlineCount = 0;//concurrent包的線程安全Set，用來存放每個客戶端對應的MyWebSocket對象。若要實現服務端與單一客戶端通信的話，可以使用Map來存放，其中Key可以為用戶標識private static CopyOnWriteArraySet<WebSocketTest> webSocketSet = new CopyOnWriteArraySet<WebSocketTest>();//與某個客戶端的連接會話，需要通過它來給客戶端發送數據private Session session;/*** 連接建立成功調用的方法* @param session 可選的參數。session為與某個客戶端的連接會話，需要通過它來給客戶端發送數據*/@OnOpenpublic void onOpen(Session session){this.session = session;webSocketSet.add(this); //加入set中addOnlineCount(); //在線數加1System.out.println("有新連接加入！當前在線人數為" + getOnlineCount());}/*** 連接關閉調用的方法*/@OnClosepublic void onClose(){webSocketSet.remove(this); //從set中刪除subOnlineCount(); //在線數減1System.out.println("有一連接關閉！當前在線人數為" + getOnlineCount());}/*** 收到客戶端消息后調用的方法* @param message 客戶端發送過來的消息* @param session 可選的參數*/@OnMessagepublic void onMessage(String message, Session session) {System.out.println("來自客戶端的消息:" + message);//群發消息for(WebSocketTest item: webSocketSet){try {item.sendMessage(message);} catch (IOException e) {e.printStackTrace();continue;}}}/*** 發生錯誤時調用* @param session* @param error*/@OnErrorpublic void onError(Session session, Throwable error){System.out.println("發生錯誤");error.printStackTrace();}/*** 這個方法與上面幾個方法不一樣。沒有用注解，是根據自己需要添加的方法。* @param message* @throws IOException*/public void sendMessage(String message) throws IOException{this.session.getBasicRemote().sendText(message);//this.session.getAsyncRemote().sendText(message); }public static synchronized int getOnlineCount() {return onlineCount;}public static synchronized void addOnlineCount() {WebSocketTest.onlineCount++;}public static synchronized void subOnlineCount() {WebSocketTest.onlineCount--;} }依賴包：
<dependency><groupId>javax.websocket</groupId><artifactId>javax.websocket-api</artifactId><version>1.1</version><scope>provided</scope></dependency>
?
轉載于:https://www.cnblogs.com/jiang--nan/p/7794580.html
總結
以上是生活随笔為你收集整理的websocket在web项目中的使用的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 鸿星尔克总部变网红打卡地 公司希望能“
- 下一篇： zabbix客户端一键安装脚本(主动模式