這篇文章主要介紹了nodejs結合socket.io實現websocket通信功能的方法,結合實例形式分析了nodejs結合socket.io實現websocket通信的具體步驟與相關操作技巧,需要的朋友可以參考下
本文實例講述了nodejs結合socket.io實作websocket通訊功能的方法。分享給大家供大家參考，具體如下：
因為專案中有需要即時取得後台資料的場景，之前一直是使用http心跳請求的方法。因為websocket與此模式相比有很大的效能提升，而且可以提高即時性，所以對websocket作了一些研究。這裡是使用nodejs socket.io來實現的。
達成目標
將原心跳請求後台資料的方式，修改為透過socket連接後台統一推送的方式。後台的資料由別的程序寫入檔案或寫入redis，這裡實作的是讀取檔案的方式。
前期準備
安裝nodejs(略)
伺服器端
新建一個專案目錄，這裡是sockettest
進入sockettest目錄，安裝express模組和socketio模組
npm install --save express@4.10.2 npm install --save socket.io
新package.json文件，其中寫入如下內容：
{
"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，用於作為預設的存取顯示頁面，因為這裡不會用到它，內容隨意；
新建trends.js文件，在其中寫入內容：
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以广播数据
var iolist = [];
#定义socket on connection（连入）事件行为
io.on('connection', function(socket){
#将连入socket加入列表
iolist.push(socket);
#记录index，在disconnect（断开连接）发生时将对应的socket删除
var sockex = iolist.indexOf(socket);
#定义on disconnect事件行为
socket.on('disconnect', function(){
#将断开连接的socket从广播列表里删除
iolist.splice(sockex, 1);
});
});
# 数据广播进程:每1秒钟广播一次
setInterval(function() {
# 如果没有正在连接的socket，直接返回；
if (iolist.length <= 0) return;
var trends = fs.readFileSync('./data/trends.json','utf-8');#trends数据
var coins = fs.readFileSync('./data/coins.json','utf-8');#coins数据
#向所有socket连接发送数据
for (i in iolist) {
# 向客户端发送trends数据
iolist[i].emit('trends', trends);
# 向客户端发送coins数据
iolist[i].emit('coins', coins);
}
}, 1000);
# 服务器侦听在sockettest.com的3000端口上
http.listen(3000, function(){
# 输出到标准输出
console.log('listening on sockettest.com:3000');
});新建data目錄，並在下方新建兩個檔案trends與coins，用來存放socket伺服器將要讀取的資料。
新建public目錄，在其中新建一個檔案index.html，檔案內容如下：
<!--引入必要的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类型数据时的行为
socket.on('coins', function(msg){
console.log(msg);
}
#定义接收到trends类型数据时的行为
socket.on('trends', function(msg){
console.log(msg);
}
}
</script>#程式碼部署
剛才之所以要建造兩個index.html文件，是為了能夠方便地在現有的web專案中使用nodejs提供的socket服務。這樣我們把public/index.html可以部署在別的伺服器中，像是nginx或tomcat之類，然後在根目下啟動socket的伺服器，為其提供socket服務。
先在剛才的專案根目錄下執行
node ./trends.js
並且保持終端運行，然後再把專案部署在nginx裡，透過chrome下存取nginx提供的web服務：
#http://hostname/public/index.html
開啟開發者模式，就能在console裡看到每隔一秒便會收到來自node伺服器的socket推播訊息了。透過修改data目錄下的兩個文件，可以看到寫入到文件的資料也會即時地推送到客戶端這裡來。
上面是我整理給大家的，希望今後對大家有幫助。
相關文章：
以上是在nodejs中如何實作websocket通訊功能的詳細內容。更多資訊請關注PHP中文網其他相關文章！
