這篇文章主要介紹nodejs如何結(jié)合socket.io實現(xiàn)websocket通信功能,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!
成都創(chuàng)新互聯(lián)公司專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于成都網(wǎng)站建設(shè)、網(wǎng)站制作、潁東網(wǎng)絡(luò)推廣、重慶小程序開發(fā)、潁東網(wǎng)絡(luò)營銷、潁東企業(yè)策劃、潁東品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等,從售前售中售后,我們都將竭誠為您服務(wù),您的肯定,是我們大的嘉獎;成都創(chuàng)新互聯(lián)公司為所有大學生創(chuàng)業(yè)者提供潁東建站搭建服務(wù),24小時服務(wù)熱線:13518219792,官方網(wǎng)址:muchs.cn具體如下:
因為項目中有需要實時獲取后臺數(shù)據(jù)的場景,之前一直是使用http心跳請求的方法。因為websocket與此模式相比有很大的性能提升,而且可以提高實時性,所以對websocket作了一些研究。這里是使用nodejs+socket.io來實現(xiàn)的。
達成目標
將原來心跳請求后臺數(shù)據(jù)的方式,修改為通過socket連接后臺統(tǒng)一推送的方式。后臺的數(shù)據(jù)由別的進程寫入文件或?qū)懭雛edis,這里實現(xiàn)的是讀取文件的方式。
前期準備
安裝nodejs(略)
服務(wù)器端
新建一個項目目錄,這里是sockettest
進入sockettest目錄,安裝express模塊和socketio模塊
npm install --save express@4.10.2 npm install --save socket.io
新建package.json文件,在其中寫入如下內(nèi)容:
{ "name": "socket-test", "version": "0.0.1", "description": "my first socket.io app", "dependencies": { "express": "^4.10.2", "socket.io": "^1.7.2" } }
新建index.html,用于作為默認的訪問顯示頁面,因為這里不會用到它,內(nèi)容隨意;
新建trends.js文件,在其中寫入內(nèi)容:
var app = require('express')(); var http = require('http').Server(app); var io = require('socket.io')(http); var fs = require('fs'); #默認打開文件 app.get('/', function(req, res){ res.sendfile('index.html'); }); #用于存儲所有socket以廣播數(shù)據(jù) var iolist = []; #定義socket on connection(連入)事件行為 io.on('connection', function(socket){ #將連入socket加入列表 iolist.push(socket); #記錄index,在disconnect(斷開連接)發(fā)生時將對應(yīng)的socket刪除 var sockex = iolist.indexOf(socket); #定義on disconnect事件行為 socket.on('disconnect', function(){ #將斷開連接的socket從廣播列表里刪除 iolist.splice(sockex, 1); }); }); # 數(shù)據(jù)廣播進程:每1秒鐘廣播一次 setInterval(function() { # 如果沒有正在連接的socket,直接返回; if (iolist.length <= 0) return; var trends = fs.readFileSync('./data/trends.json','utf-8');#trends數(shù)據(jù) var coins = fs.readFileSync('./data/coins.json','utf-8');#coins數(shù)據(jù) #向所有socket連接發(fā)送數(shù)據(jù) for (i in iolist) { # 向客戶端發(fā)送trends數(shù)據(jù) iolist[i].emit('trends', trends); # 向客戶端發(fā)送coins數(shù)據(jù) iolist[i].emit('coins', coins); } }, 1000); # 服務(wù)器偵聽在sockettest.com的3000端口上 http.listen(3000, function(){ # 輸出到標準輸出 console.log('listening on sockettest.com:3000'); });
新建data目錄,并在下面新建兩個文件trends與coins,用于存放socket服務(wù)器將要讀取的數(shù)據(jù)。
新建public目錄,在其中新建一個文件index.html,文件內(nèi)容如下:
<!--引入必要的js文件--> <script type="text/javascript" src="http://sockettest:3000/socket.io/socket.io.js"></script> <script type="text/javascript"> //新建socket var socket = io('http://sockettest.com:3000'); socketdata(socket); function socketdata() { #定義接收到coins類型數(shù)據(jù)時的行為 socket.on('coins', function(msg){ console.log(msg); } #定義接收到trends類型數(shù)據(jù)時的行為 socket.on('trends', function(msg){ console.log(msg); } } </script>
代碼部署
剛才之所以要建兩個index.html文件,是為了能夠方便地在既有的web項目中使用nodejs提供的socket服務(wù)。這樣我們把public/index.html可以部署在別的服務(wù)器中,比如nginx或tomcat之類,然后在根目下啟動socket的服務(wù)器,為其提供socket服務(wù)。
首先在剛才的項目根目錄下執(zhí)行
node ./trends.js
并保持終端運行,然后再把項目部署在nginx里,通過chrome下訪問nginx提供的web服務(wù):
http://hostname/public/index.html
打開開發(fā)者模式,就能在console里看到每隔一秒便會收到來自node服務(wù)器的socket推送消息了。通過修改data目錄下的兩個文件,可以看到寫入到文件的數(shù)據(jù)也會實時地推送到客戶端這里來。
以上是“nodejs如何結(jié)合socket.io實現(xiàn)websocket通信功能”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對大家有幫助,更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計公司行業(yè)資訊頻道!
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
當前名稱:nodejs如何結(jié)合socket.io實現(xiàn)websocket通信功能-創(chuàng)新互聯(lián)
文章分享:http://muchs.cn/article28/deggjp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供微信公眾號、App設(shè)計、服務(wù)器托管、虛擬主機、移動網(wǎng)站建設(shè)、做網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容