JAVA實現webSocket網頁聊天室

本文轉載自查看原文 2018-09-19 10:39 6827 java

一、什么是webSocket

WebSocket 是一種網絡通信協議，是持久化協議。RFC6455 定義了它的通信標准。

WebSocket 是 HTML5 開始提供的一種在單個 TCP 連接上進行全雙工通訊的協議。

二、為什么要使用webSocket

傳統的web通信是使用的http技術，http協議是無狀態的、無連接的、單向的應用層協議。一次請求只能對應一個響應，通信請求只能由客戶端發出，服務端對請求做出響應。所以服務端發出響應是非常被動的，這種被動的響應注定了服務端無法及時的給客戶端主動推送響應，如果服務端有連續的狀態變化的時候，客戶端獲取是很困難的。通過頻繁使用了異步ajax去不斷地獲取請求去實現長輪詢，這樣做是特別消耗性能，而且效率低下。（不停的握手，或者長時間保持live)。

而webSocket允許服務器和客戶端之間建立全雙工通信，只要建立一次連接，就能一直保持連接狀態。一旦建立一次連接，就能雙方互相通信，不需要多次握手。

三、實現WEB聊天室

添加pom.xml，引入jar包

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

2.建立html和js文件

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>在線聊天室</title>
<script type="text/javascript" src="./static/jquery-3.2.0.min.js"></script>
<!-- 最新版本的 Bootstrap 核心 CSS 文件 -->
<link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css" integrity="sha384-BVYiiSIFeK1dGmJRAkycuHAHRg32OmUcww7on3RYdg4Va+PmSTsz/K68vbdEjh4u" crossorigin="anonymous">
<!-- 最新的 Bootstrap 核心 JavaScript 文件 -->
<script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></script>
</head>
<body>
  <div>
    <div><span>聊天室</span>
         <button class="btn btn-warning" onclick="doClose();">退出聊天</button>
    </div>
    <div><textarea class="form-control" style="width: 40%;" rows="3" id="contentInp"></textarea></div><hr/>
    <div><button class="btn btn-danger" onclick="doClear();">清空會話框</button></div>
    <div id="content">開始聊天<br/></div>
  </div>
</body>
<script type="text/javascript">
   var ws = new WebSocket("ws://localhost:8080/ws/websocket"); //controller層url
   $(function(){
       $("#contentInp").keyup(function(evt){
           if(evt.which == 13){ //enter鍵發送消息
               var htm = $("#contentInp").val();
               doSend(htm);
               $("textarea").empty();
           }
       });
   })
   
   ws.onopen = function(){
       appendHtm("連接成功！");
   }
   
   // 從服務端接收到消息，將消息回顯到聊天記錄區
   ws.onmessage = function(evt){
       appendHtm(evt.data);
   }
   
   ws.onerror = function(){
       appendHtm("連接失敗！");
   }
   
   ws.onclose = function(){
       appendHtm("連接關閉！");
   }
   
   function appendHtm(htm){
       ($("#content")[0]).innerHTML += htm +"<br/>" 
   }
   
   // 注銷登錄
   function doClose(){
       ws.close();
   }
   
   // 發送消息
   function doSend(htm){
      // ($("#content")[0]).innerHTML += htm +"<br/>" 
       ws.send(htm);
   }
   
   function doClear(){
       $("#content").empty();
   }
</script>
</html>

View Code

3.后台java代碼

package controller;

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

import javax.net.ssl.SSLSession;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")
public class WebScoketServer {

    private static Integer onlineNum = 0; //當前在線人數，線程必須設計成安全的
    private static CopyOnWriteArraySet<WebScoketServer> arraySet = new CopyOnWriteArraySet<WebScoketServer>(); //存放每一個客戶的的WebScoketServer對象，線程安全
    private Session session;
    
    /**
     * 連接成功
     * @param session 會話信息
     */
    @OnOpen
    public void onOpen(Session session) {
        this.session =session;
        arraySet.add(this);
        this.addOnlineNum();
        System.out.println("有一個新連接加入，當前在線 "+this.getOnLineNum()+" 人");
    }
    
    /**
     * 連接關閉
     */
    @OnClose
    public void onClose() {
        arraySet.remove(this);
        this.subOnlineNum();
        System.out.println("有一個連接斷開，當前在線 "+this.getOnLineNum()+" 人");
    }
    
    /**
     * 連接錯誤
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error) {
        System.err.println("發生錯誤！");
        error.printStackTrace();
    }
    
    /**
     * 發送消息,不加注解，自己選擇實現
     * @param msg
     * @throws IOException
     */
    public void onSend(String msg) throws IOException {
        this.session.getBasicRemote().sendText(msg);
    }
    
    /**
     * 收到客戶端消息回調方法
     * @param session
     * @param msg
     */
    @OnMessage
    public void onMessage(Session session, String msg) {
        System.out.println("消息監控："+msg);
        for (WebScoketServer webScoketServer : arraySet) {
            try {
                webScoketServer.onSend(msg);
            } catch (IOException e) {
                e.printStackTrace();
                continue;
            }
        }
    }
    /**
     * 增加一個在線人數
     */
    private synchronized void addOnlineNum() {
        onlineNum++;
    }
    
    /**
     * 減少一個在線人數
     */
    private synchronized void subOnlineNum() {
        onlineNum--;
    }
    
    private Integer getOnLineNum() {
        return onlineNum;
    }
}

View Code

4.完成后效果

免責聲明！

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

猜您在找 php+websocket 實現聊天室 websocket實現多房間聊天室實現一個簡單的WebSocket聊天室使用websocket實現聊天室功能 WebSocket實現簡易聊天室 Java聊天室的設計與實現純java實現簡易聊天室基於flask的網頁聊天室（二） ThinkPHP5+WebSocket+MySQL實現聊天室 nodejs+websocket實現聊天室功能