WebSocket實時消息推送

coolpail 發(fā)布于2019-07-25 14:11 / 3423人閱讀

摘要：軟件運行原理協(xié)議是一種全雙工的通訊方式并且支持跨域二消息推送服務(wù)器的搭建我們利用的模塊來實現(xiàn)消息推送服務(wù)。

一、消息推送的實現(xiàn)原理與方式 1.1 實時性較強的場景

在線聊天

監(jiān)控報警

視頻彈幕

1.2 基于HTTP的實時消息方案

AJAX輪詢(polling) //客戶端不斷發(fā)送請求到服務(wù)器

長輪詢(longplling) //一般30s超時

異步streaing

iframe數(shù)據(jù)量

全雙工：數(shù)據(jù)發(fā)送和接收可以同時進行。

HTTP協(xié)議是不具備全雙工的。

1.3 軟件運行原理

WebSocket協(xié)議是一種全雙工的通訊方式,并且支持跨域

二、消息推送服務(wù)器的搭建

我們利用nginx的nginx-push-stream-module模塊來實現(xiàn)消息推送服務(wù)。

2.1 環(huán)境搭建

首先需要下載模塊源碼，這里在git上直接克隆

git clone http://github.com/wandenberg/nginx-push-stream-module.git

將欲增加的模塊路徑定義為一個變量（此步驟非必要步驟，且定義的變量只能當前會話可用，只是為了后續(xù)操作方便）

NGINX_PUSH_STREAM_MODULE_PATH=$PWD/nginx-push-stream-module

以下是nginx已經(jīng)安裝過的情況下增加模塊，因為以前nginx安裝在/usr/local/nginx目錄下，所以下面的操作都是以此目錄為路徑進行操作，如果安裝到其他目錄有些命令需要做對應(yīng)的更改。

先查看原有nginx的配置參數(shù)并拷貝出來備用

/usr/local/nginx/sbin/nginx -V

解壓相同版本的nginx源碼包（以前安裝時的源碼包），如果已經(jīng)刪除了課重新下載，版本相同即可（這里以1.12.1版本為例）
nginx官網(wǎng)

wget  http://nginx.org/download/nginx-1.12.1.tar.gz

tar zxvf nginx-1.12.2.tar.gz
進入nginx的目錄

cd nginx-1.12.1

進行配置（其中***是前面記錄的nginx原始的配置，也就是剛才拷貝出來配置，這個務(wù)必加上）

./configure --add-module=$NGINX_PUSH_STREAM_MODULE_PATH ***

編譯：

make

不要執(zhí)行make install避免覆蓋，備份原來的nginx可執(zhí)行文件

備份：

mv /usr/local/nginx/sbin/nginx /usr/local/nginx/sbin/nginx_bak

將編譯好的nginx復(fù)制到原始nginx的sbin目錄

cp objs/nginx /usr/local/nginx/sbin/

到此為止已經(jīng)安裝完畢，可以再執(zhí)行/usr/local/nginx/sbin/nginx -V查看一下nginx的模塊情況。

2.3 nginx配置

安裝后需要在nginx的配置文件nginx.conf或者其他包含的配置文件中做如下配置:
1. 在http段加入：

#最大共享內(nèi)存
push_stream_shared_memory_size                100m;
#頻道最大長度
push_stream_max_channel_id_length             200;
#每個頻道緩存的最大消息數(shù)量
push_stream_max_messages_stored_per_channel   20;
#消息生命周期(分鐘)
push_stream_message_ttl                       5m;

2. 添加一個虛擬主機(server)配置如下：

server {
    listen 8080;
    server_name     127.0.0.1;
    location /pub {
        push_stream_publisher admin;
        push_stream_channels_path $arg_id;
        push_stream_store_messages on;
    }
    location ~ /sub/(.*) {
        push_stream_subscriber;
        push_stream_channels_path $1;
        push_stream_last_received_message_time      "$arg_time";
        push_stream_last_received_message_tag       "$arg_tag";
        push_stream_header_template "






";
            push_stream_message_template "";
        push_stream_footer_template "";
        default_type "text/html; charset=utf-8";
        push_stream_ping_message_interval 10s;
    }
    location ~ /ev/(.*) {
        push_stream_subscriber eventsource;
        push_stream_channels_path $1;
        push_stream_last_received_message_time      "$arg_time";
        push_stream_last_received_message_tag       "$arg_tag";
        push_stream_message_template "{"id":~id~,"channel":"~channel~","text":"~text~","tag":"~tag~","time":"~time~"}";
        push_stream_ping_message_interval 10s;
    }
    location ~ /ws/(.*) {
        push_stream_subscriber websocket;
        push_stream_channels_path $1;
        push_stream_last_received_message_time      "$arg_time";
        push_stream_last_received_message_tag       "$arg_tag";
        push_stream_message_template "{"id":~id~,"channel":"~channel~","text":"~text~","tag":"~tag~","time":"~time~"}";
        push_stream_ping_message_interval 10s;
    }
    location ~ /lp/(.*) {
        push_stream_subscriber long-polling;
        push_stream_channels_path $1;
        push_stream_last_received_message_time      "$arg_time";
        push_stream_last_received_message_tag       "$arg_tag";
        push_stream_message_template "{"id":~id~,"channel":"~channel~","text":"~text~","tag":"~tag~","time":"~time~"}";
        push_stream_longpolling_connection_ttl 30s;
    }

  }

3. 然后重新載入nginx的配置

檢查配置文件是否有語法錯誤：

/usr/local/nginx/sbin/nginx -t

出現(xiàn)以下提示表示正確：

nginx: the configuration file /usr/local/nginx/conf/nginx.conf syntax is ok
nginx: configuration file /usr/local/nginx/conf/nginx.conf test is successful

重新載入：

/usr/local/nginx/sbin/nginx -s reload 或 nginx -s reload

查看端口：netstat -tnl

2.3 測試訂閱/發(fā)布

在Linux命令下使用curl做如下測試（其中ch1代表頻道）

#發(fā)布信息:
curl http://localhost:8080/pub?id=ch1 -d "發(fā)布消息測試"
#訂閱信息:
curl http://localhost:8080/lp/ch1

參考學(xué)習(xí)視頻：消息推送服務(wù)器構(gòu)建實時聊天室視頻教程

GPU云服務(wù)器云服務(wù)器 websocket消息推送 java 實時消息推送框架 websocket推送 websocket實時語音通話

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/39804.html

發(fā)表評論

登陸后可評論

0條評論

coolpail

男|高級講師

我要關(guān)注我要私信

TA的文章

一文詳解 OpenGL ES 3.x 渲染管線

閱讀 3531·2021-11-24 09:39
L - 居中布局

閱讀 790·2019-08-30 14:22
前端性能優(yōu)化黃金法則

閱讀 3042·2019-08-30 13:13
JavaWEB開發(fā)05_Bootstrap

閱讀 2327·2019-08-29 17:06
前端每日實戰(zhàn)：105# 視頻演示如何用純 CSS 創(chuàng)作一只玉免

閱讀 2928·2019-08-29 16:22
樣式里的寬度為小數(shù)，js獲取其值

閱讀 1264·2019-08-29 10:58
總結(jié)異步編程的六種方式

閱讀 2440·2019-08-26 13:47
JavaScript中的函數(shù)

閱讀 1639·2019-08-26 11:39

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

WebSocket實時消息推送

相關(guān)文章

Web 實時推送技術(shù)的總結(jié)

WebSocket 前后端實時消息推送

WebSocket 前后端實時消息推送

利用 socket.io 實現(xiàn)消息實時推送

基于node+socket.io+redis的多房間多進程聊天室

發(fā)表評論

0條評論

coolpail

男|高級講師

TA的文章

一文詳解 OpenGL ES 3.x 渲染管線

L - 居中布局

前端性能優(yōu)化黃金法則

JavaWEB開發(fā)05_Bootstrap

前端每日實戰(zhàn)：105# 視頻演示如何用純 CSS 創(chuàng)作一只玉免

樣式里的寬度為小數(shù)，js獲取其值

總結(jié)異步編程的六種方式

JavaScript中的函數(shù)

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

WebSocket實時消息推送

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！