2. 程式人生 > >WebSocket與消息推送

WebSocket與消息推送

阿新 • • 發佈：2018-01-10
加密 sin exp 安裝flash throwable tin pat 允許 被調用

轉自張果原文 WebSocket與消息推送

B/S結構的軟件項目中有時客戶端需要實時的獲得服務器消息，但默認HTTP協議只支持請求響應模式，這樣做可以簡化Web服務器，減少服務器的負擔，加快響應速度，因為服務器不需要與客戶端長時間建立一個通信鏈接，但不容易直接完成實時的消息推送功能，如聊天室、後臺信息提示、實時更新數據等功能，但通過polling、Long polling、長連接、Flash Socket以及HTML5中定義的WebSocket能完成該功能需要。

一、Socket簡介

Socket又稱"套接字"，應用程序通常通過"套接字"向網絡發出請求或者應答網絡請求。Socket的英文原義是“孔”或“插座”，作為UNIX的進程通信機制。Socket可以實現應用程序間網絡通信。

技術分享圖片

Socket可以使用TCP/IP協議或UDP協議。

TCP/IP協議

TCP/IP協議是目前應用最為廣泛的協議，是構成Internet國際互聯網協議的最為基礎的協議,由TCP和IP協議組成:
TCP協議:面向連接的、可靠的、基於字節流的傳輸層通信協議，負責數據的可靠性傳輸的問題。

IP協議:用於報文交換網絡的一種面向數據的協議，主要負責給每臺網絡設備一個網絡地址，保證數據傳輸到正確的目的地。

UDP協議

UDP特點：無連接、不可靠、基於報文的傳輸層協議，優點是發送後不用管，速度比TCP快。

二、WebSocket簡介與消息推送

B/S架構的系統多使用HTTP協議，HTTP協議的特點：

1 無狀態協議
2 用於通過 Internet 發送請求消息和響應消息
3 使用端口接收和發送消息，默認為80端口
底層通信還是使用Socket完成。

技術分享圖片

HTTP協議決定了服務器與客戶端之間的連接方式，無法直接實現消息推送（F5已壞）,一些變相的解決辦法：

雙向通信與消息推送

輪詢：客戶端定時向服務器發送Ajax請求，服務器接到請求後馬上返回響應信息並關閉連接。 優點：後端程序編寫比較容易。 缺點：請求中有大半是無用，浪費帶寬和服務器資源。 實例：適於小型應用。

長輪詢：客戶端向服務器發送Ajax請求，服務器接到請求後hold住連接，直到有新消息才返回響應信息並關閉連接，客戶端處理完響應信息後再向服務器發送新的請求。 優點：在無消息的情況下不會頻繁的請求，耗費資小。 缺點：服務器hold連接會消耗資源，返回數據順序無保證，難於管理維護。 Comet異步的ashx， 實例：WebQQ、Hi網頁版、Facebook IM。

長連接：在頁面裏嵌入一個隱蔵iframe，將這個隱蔵iframe的src屬性設為對一個長連接的請求或是采用xhr請求，服務器端就能源源不斷地往客戶端輸入數據。 優點：消息即時到達，不發無用請求；管理起來也相對便。 缺點：服務器維護一個長連接會增加開銷。 實例：Gmail聊天

Flash Socket：在頁面中內嵌入一個使用了Socket類的 Flash 程序JavaScript通過調用此Flash程序提供的Socket接口與服務器端的Socket接口進行通信，JavaScript在收到服務器端傳送的信息後控制頁面的顯示。 優點：實現真正的即時通信，而不是偽即時。 缺點：客戶端必須安裝Flash插件；非HTTP協議，無法自動穿越防火墻。 實例：網絡互動遊戲。

Websocket:
WebSocket是HTML5開始提供的一種瀏覽器與服務器間進行全雙工通訊的網絡技術。依靠這種技術可以實現客戶端和服務器端的長連接，雙向實時通信。
特點:
事件驅動
異步
使用ws或者wss協議的客戶端socket

能夠實現真正意義上的推送功能

缺點：

少部分瀏覽器不支持，瀏覽器支持的程度與方式有區別。

技術分享圖片

三、WebSocket客戶端

websocket允許通過JavaScript建立與遠程服務器的連接，從而實現客戶端與服務器間雙向的通信。在websocket中有兩個方法：　　
　　　　1、send() 向遠程服務器發送數據
　　　　2、close() 關閉該websocket鏈接
　　websocket同時還定義了幾個監聽函數　　　　
　　　　1、onopen 當網絡連接建立時觸發該事件
　　　　2、onerror 當網絡發生錯誤時觸發該事件
　　　　3、onclose 當websocket被關閉時觸發該事件
　　　　4、onmessage 當websocket接收到服務器發來的消息的時觸發的事件，也是通信中最重要的一個監聽事件。msg.data
　　websocket還定義了一個readyState屬性，這個屬性可以返回websocket所處的狀態：
　　　　1、CONNECTING(0) websocket正嘗試與服務器建立連接
　　　　2、OPEN(1) websocket與服務器已經建立連接
　　　　3、CLOSING(2) websocket正在關閉與服務器的連接
　　　　4、CLOSED(3) websocket已經關閉了與服務器的連接

　　websocket的url開頭是ws，如果需要ssl加密可以使用wss，當我們調用websocket的構造方法構建一個websocket對象（new WebSocket(url)）的之後，就可以進行即時通信了。

<!DOCTYPE html>
<html>

    <head>
        <meta name="viewport" content="width=device-width" />
        <title>WebSocket 客戶端</title>
    </head>

    <body>
        <div>
            <input type="button" id="btnConnection" value="連接" />
            <input type="button" id="btnClose" value="關閉" />
            <input type="button" id="btnSend" value="發送" />
        </div>
        <script src="js/jquery-1.11.1.min.js" type="text/javascript" charset="utf-8"></script>
        <script type="text/javascript">
            var socket;
            if(typeof(WebSocket) == "undefined") {
                alert("您的瀏覽器不支持WebSocket");
                return;
            }

            $("#btnConnection").click(function() {
                //實現化WebSocket對象，指定要連接的服務器地址與端口
                socket = new WebSocket("ws://192.168.1.2:8888");
                //打開事件
                socket.onopen = function() {
                    alert("Socket 已打開");
                    //socket.send("這是來自客戶端的消息" + location.href + new Date());
                };
                //獲得消息事件
                socket.onmessage = function(msg) {
                    alert(msg.data);
                };
                //關閉事件
                socket.onclose = function() {
                    alert("Socket已關閉");
                };
                //發生了錯誤事件
                socket.onerror = function() {
                    alert("發生了錯誤");
                }
            });
            
            //發送消息
            $("#btnSend").click(function() {
                socket.send("這是來自客戶端的消息" + location.href + new Date());
            });
            
            //關閉
            $("#btnClose").click(function() {
                socket.close();
            });
        </script>
    </body>

</html>

四、WebSocket服務器端

JSR356定義了WebSocket的規範，Tomcat7中實現了該標準。JSR356 的 WebSocket 規範使用 javax.websocket.*的 API，可以將一個普通 Java 對象（POJO）使用 @ServerEndpoint 註釋作為 WebSocket 服務器的端點。

@ServerEndpoint("/push")
 public class EchoEndpoint {

 @OnOpen
 public void onOpen(Session session) throws IOException {
 //以下代碼省略...
 }
 
 @OnMessage
 public String onMessage(String message) {
 //以下代碼省略...
 }

 @Message(maxMessageSize=6)
 public void receiveMessage(String s) {
 //以下代碼省略...
 } 

 @OnError
 public void onError(Throwable t) {
 //以下代碼省略...
 }
 
 @OnClose
 public void onClose(Session session, CloseReason reason) {
 //以下代碼省略...
 } 
 
 }

上面簡潔代碼即建立了一個WebSocket的服務端，@ServerEndpoint("/push")的annotation註釋端點表示將WebSocket服務端運行在ws://[Server端IP或域名]:[Server端口]/項目/push的訪問端點，客戶端瀏覽器已經可以對WebSocket客戶端API發起HTTP長連接了。
使用ServerEndpoint註釋的類必須有一個公共的無參數構造函數，@onMessage註解的Java方法用於接收傳入的WebSocket信息，這個信息可以是文本格式，也可以是二進制格式。
OnOpen在這個端點一個新的連接建立時被調用。參數提供了連接的另一端的更多細節。Session表明兩個WebSocket端點對話連接的另一端，可以理解為類似HTTPSession的概念。
OnClose在連接被終止時調用。參數closeReason可封裝更多細節，如為什麽一個WebSocket連接關閉。
更高級的定制如@Message註釋，MaxMessageSize屬性可以被用來定義消息字節最大限制，在示例程序中，如果超過6個字節的信息被接收，就報告錯誤和連接關閉。

package action;

import javax.websocket.CloseReason;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;

//ws://127.0.0.1:8087/Demo1/ws/張三
@ServerEndpoint("/ws/{user}")
public class WSServer {
    private String currentUser;
    
    //連接打開時執行
    @OnOpen
    public void onOpen(@PathParam("user") String user, Session session) {
        currentUser = user;
        System.out.println("Connected ... " + session.getId());
    }

    //收到消息時執行
    @OnMessage
    public String onMessage(String message, Session session) {
        System.out.println(currentUser + "：" + message);
        return currentUser + "：" + message;
    }

    //連接關閉時執行
    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        System.out.println(String.format("Session %s closed because of %s", session.getId(), closeReason));
    }

    //連接錯誤時執行
    @OnError
    public void onError(Throwable t) {
        t.printStackTrace();
    }
}

url中的字符張三是的路徑參數，響應請求的方法將自動映射。

五、測試運行

技術分享圖片

技術分享圖片

六、小結與消息推送框架

Socket在應用程序間通信被廣泛使用，如果需要兼容低版本的瀏覽器，建議使用反向ajax或長鏈接實現；如果純移動端或不需考慮非現代瀏覽器則可以直接使用websocket。Flash實現推送消息的方法不建議使用，因為依賴插件且手機端支持不好。關於反向ajax也有一些封裝好的插件如“Pushlet”

6.1、開源Java消息推送框架 Pushlet

Pushlet 是一個開源的 Comet 框架,Pushlet 使用了觀察者模型：客戶端發送請求，訂閱感興趣的事件；服務器端為每個客戶端分配一個會話 ID 作為標記，事件源會把新產生的事件以多播的方式發送到訂閱者的事件隊列裏。

源碼地址：https://github.com/wjw465150/Pushlet

Pushlet是一種comet實現：在Servlet機制下，數據從server端的Java對象直接推送（push）到（動態）HTML頁面，而無需任何Javaapplet或者插件的幫助。它使server端可以周期性地更新client的web頁面，這與傳統的request/response方式相悖。瀏覽器client為兼容JavaScript1.4版本以上的瀏覽器（如InternetExplorer、FireFox），並使用JavaScript/DynamicHTML特性。而底層實現使用一個servlet通過Http連接到JavaScript所在的瀏覽器，並將數據推送到後者。

6.2、開源DotNet消息推送框架SignalR

SignalR是一個ASP .NET下的類庫，可以在ASP .NET的Web項目中實現實時通信。在Web網頁與服務器端間建立Socket連接，當WebSockets可用時（即瀏覽器支持Html5）SignalR使用WebSockets，當不支持時SignalR將使用長輪詢來保證達到相同效果。

官網：http://signalr.net/

源碼：https://github.com/SignalR/SignalR

技術分享圖片

七、代碼下載

7.1、Java實現的服務器端代碼與客戶端代碼下載

點擊下載服務器端代碼

點擊下載客戶端代碼

7.2、DotNet服務器端手動連接實現代碼下載

點擊下載DotNet服務器端手動連接實現代碼

7.3、DotNet下使用SuperWebSocket三方庫實現代碼下載

點擊下載DotNet下使用SuperWebSocket三方庫實現代碼

WebSocket與消息推送

相關推薦

WebSocket與消息推送

加密 sin exp 安裝flash throwable tin pat 允許 被調用 轉自張果原文 WebSocket與消息推送 B/S結構的軟件項目中有時客戶端需要實時的獲得服務器消息，但默認HTTP協議只支持請求響應模式，這樣做可以簡化Web服務器，減少服

消息推送二 之webSocket

還需 由於 else har 頁面 try window class logs 友情提示： 消息推送的介紹可以參考http://www.cnblogs.com/dahuandan/p/6816173.html 什麽是webSocket webSocket是為解決客

apollo實現c#與android消息推送(三)

class net names oid urn 服務 mbo target parse 3 實現c#消息推送服務 c#實現消息推送必須引入M2Mqtt.dll，源碼 a 連接apache apollo代理服務器的代碼。需要引入using uPLibrar

WebSocket消息推送

parse 才會 拆分 創建 max win event its 數據 WebSocket協議是基於TCP的一種新的網絡協議，應用層，是TCP/IP協議的子集。 它實現了瀏覽器與服務器全雙工（full-duplex）通信，客戶端和服務器都可以向對方主動發送和接收數據。在JS

springboot實現服務器端消息推送（websocket + sockjs + stomp）

client rem queue rip rsa socket gin enabled lis 　　服務器端推送技術在web開發中比較常用，可能早期很多人的解決方案是采用ajax向服務器輪詢消息，這種方式的輪詢頻率不好控制，所以大大增加了服務器的壓力，後來有了下面的方案

全終端消息推送解決方案--調研與可行性分析報告

過程 AD 小型企業 工作模式 優先級 終端 華為 直接 item 題目要求 請確定本團隊項目的所有利益相關者，把調研結果發布到團隊博客中 請團隊所有成員針對目標用戶確定需求調查提綱，並進行需求調研，可以采取各種你認為可行的方法，並把調研過程和結果發布到團隊博客中 請確定

spring websocket 和socketjs實現單聊群聊,廣播的消息推送詳解

退出 rec oid -name 返回 classes sockets 們的 tomcat7.0 spring websocket 和socketjs實現單聊群聊,廣播的消息推送詳解 WebSocket簡單介紹 　　隨著互聯網的發展，傳統的HTTP協議已經很難滿足Web應用

apicloud 消息推送與接收

odin community 記得 參考 ppk 用戶登錄 androi 發送通知 apk 待解決的問題，如下： 　　在使用apicloud 的時候我們，在開發用戶登錄的時候可能會遇到這樣的問題，當有2個設備a，b同事使用的app的時候並且是同一個人登錄，我們需要去做判斷，

GoBelieve IM 消息推送的方案

apn dem 所有 消息 做的 pan 切換 賬戶 mic 消息推送設計方案如下： 所有接入im SDK的deviceTOken都會存儲到IM服務器。就可以 IM服務器來根據你們服務器指定的useId來下發消息。判斷客戶端在線，並且APP在前臺。就是socket下發，IM

iOS開發——遠程消息推送的實現

ice 分享 mit load con targe you 取消 tex 在我們使用App的過程中。總是會收到非常多的消息推送。今天我們就要來實現這個功能。首先消息推送分為本地消息推送和遠程消息推送。而當中又以遠程消息最為經常使用。可是在推送遠程消息之前。

Android 基於Netty的消息推送方案之概念和工作原理(二)

img b2c 決定 watermark net nios 通道 感覺 art 上一篇文章中我講述了關於消息推送的方案以及一個基於Netty實現的一個簡單的Hello World。為了更好的理解Hello World中的代碼，今天我來解說一下關於Netty中一些概念和工

細說 iOS 消息推送

not 個數 text payload 自己 是否 coffee reserve use APNS的推送機制 與Android上我們自己實現的推送服務不一樣，Apple對設備的控制很嚴格。消息推送的流程必需要經過APNs： 這裏 Provider 是指某個應用的

asp.net web 通過IHttpAsyncHandler接口進行消息推送

authent div reg ret back sig sts content validate 1.創建Comet_by_ASP.NET web項目 2.handler類和result類 namespace Handle { /// <summary&g

SignalR Self Host+MVC等多端消息推送服務(2)

寫到 後端 local -1 顯示 rgs 代碼 發送 登錄 一、概述 上次的文章中我們簡單的實現了SignalR自托管的服務端，今天我們來實現控制臺程序調用SignalR服務端來實現推送信息，由於之前我們是打算做審批消息推送，所以我們的demo方向是做指定人發送信息，至

vue js 和signalr 結合實現消息推送1

ack all client aspnet 由於 user startup man logs 由於signalr2.2.0 依賴於jQuery,雖然在vuejs 略顯臃腫， 但是對於目前剛接觸 vuejs 和想實現 前後分離的我來說 這已經很好了。目前先實現功能， 然後如果

MQTT是IBM開發的一個即時通訊協議，構建於TCP/IP協議上，是物聯網IoT的訂閱協議，借助消息推送功能，可以更好地實現遠程控制

集合 cap 消息處理 簡易 遠程控制 mes ogr 設計思想 成本 最近一直做物聯網方面的開發，以下內容關於使用MQTT過程中遇到問題的記錄以及需要掌握的機制原理,主要講解理論。 背景 MQTT是IBM開發的一個即時通訊協議。MQTT構建於TCP/IP協議上

互聯網產品消息推送設計策略（轉）

做出 可能 依然 應用 存在 第一次 時間段 時間 保持 在移動互聯時代，消息推送越來越受到各個APP的重視，本文就以互金產品為例闡述消息推送的幾個類別以及應用的場景方式、運營策略，希望對你有益。 在之前一文中，筆者概括性的介紹了通知功能是互金理財平臺的一個基礎但重要

errcode 4103 invalid page hint 小程序模板消息推送遇到的坑

val 推送 技術 pid 遇到 小程序 微信 err 成功 invalid page hint一直提示這個坑爹的就是，我的小程序沒發布之前，也就是測試版本用這個格式是可以的 /pages/myGroup/myGroup?groupid=22***但是發布成功以後，線上

IM系統：消息推送及離線存儲

target 做到 targe 用戶 mda fontsize 部分 watermark 維護 一、服務端維護每條消息對用戶的送達狀態 二、利用標號標記最新已讀消息 說明： 1、消息離線存儲與拉取部分，有贊客服系統現有實現采用第二種方式 2、文章參考了沈

微信消息推送中換行和超鏈接的使用

中心 time div user www. echo type name create if($postObj->Event == ‘CLICK‘ && $postObj->EventKey == ‘tel‘){