webSocket 的demo

時間 2019-11-10

標籤 websocket demo 简体版

原文原文鏈接

這兩天在網上找了一個webSocket 的例子，據說公司後面的開發任務會設計到這方面的內容，因此先找些資料練練手:javascript

pom.xmlhtml

<dependency>
      <groupId>javax</groupId>
      <artifactId>javaee-api</artifactId>
      <version>7.0</version>
      <scope>provided</scope>
</dependency>

html頁面：java

<!DOCTYPE html>
 <html>
 <head>
     <title>Java後端WebSocket的Tomcat實現</title>
　　　　　<meta content='width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no' name='viewport' />
　　　　　<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />

 </head>
 <body>
     Welcome<br/><input id="text" type="text"/>
     <button onclick="send()">發送消息</button>
     <hr/>
     <button onclick="closeWebSocket()">關閉WebSocket鏈接</button>
     <hr/>
     <div id="message"></div>
 </body>
 
 <script type="text/javascript">
     var websocket = null;
     //判斷當前瀏覽器是否支持WebSocket
     if ('WebSocket' in window) {
         websocket = new WebSocket("ws://127.0.0.1:8080/wangWeb/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>

java代碼：web

package com.demo;

import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;

/**
 * 
 * 
 * @Description: TODO <p>WebSocketTest.java</p>
 * @做者: 王彥寶
 * @時間: 2018年9月17日上午11:01:32
 * @version V1.0
 * @see java.lang.Class
 * @since JDK{jdk1.7}
 */
@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爲與某個客戶端的鏈接會話，須要經過它來給客戶端發送數據
	      */
	     @OnOpen
	     public void onOpen(Session session){
	         this.session = session;
	         webSocketSet.add(this);     //加入set中
	         addOnlineCount();           //在線數加1
	         System.out.println("有新鏈接加入！當前在線人數爲" + getOnlineCount());
	     }
	 
	     /**
	      * 鏈接關閉調用的方法
	      */
	     @OnClose
	     public void onClose(){
	         webSocketSet.remove(this);  //從set中刪除
	         subOnlineCount();           //在線數減1
	         System.out.println("有一鏈接關閉！當前在線人數爲" + getOnlineCount());
	     }
	 
	     /**
	      * 收到客戶端消息後調用的方法
	      * @param message 客戶端發送過來的消息
	      * @param session 可選的參數
	      */
	     @OnMessage
	     public 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
	      */
	     @OnError
	     public 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--;
	     }
}

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。