快捷導(dǎo)航

Node.js中使用socket創(chuàng)建私聊和公聊聊天室

更新時(shí)間：2015年11月19日 14:13:41 作者：想兵

這篇文章主要介紹了Node.js中使用socket創(chuàng)建私聊和公聊聊天室的相關(guān)資料,需要的朋友可以參考下

先給大家展示效果圖：

在上篇文章給大家介紹使用Angular和Nodejs、socket.io搭建聊天室及多人聊天室，本文繼續(xù)介紹Node.js中使用socket創(chuàng)建私聊和公聊聊天室，具體詳情請(qǐng)看下文吧。

nodejs的應(yīng)用中，關(guān)于socket應(yīng)該是比較出彩的了，socket.io在github上有幾萬(wàn)人的star，它的成功應(yīng)該是不輸于express的，為了方便了解整個(gè)socket.io的使用.

例子請(qǐng)點(diǎn)擊http://chat.lovewebgames.com/

源碼下載https://github.com/tianxiangbing/chat

由于本人太窮，所以服務(wù)器和數(shù)據(jù)庫(kù)都是使用的國(guó)外免費(fèi)的，訪問(wèn)速度上可以會(huì)稍慢。

先說(shuō)下我對(duì)socket.io的理解，websocket更像是開(kāi)啟了一個(gè)端口服務(wù)，來(lái)監(jiān)視過(guò)往的通訊。所以我們可以依賴于當(dāng)前站點(diǎn)80端口啟socket服務(wù)，也可以放于其他端口上，比如：

復(fù)制代碼代碼如下:

require('socket.io').listen(3000);

這樣就是監(jiān)視3000端口了，由于我用的免費(fèi)服務(wù)器，沒(méi)有權(quán)限打開(kāi)其他端口，所以，我還是使用80了，由于80已經(jīng)被express使用了，所以我只好在express使用的時(shí)候傳進(jìn)來(lái)了。

復(fù)制代碼代碼如下:

 var server = http.createServer(app);

 var socket = require(‘./socket/msg')(server);

然后我在msg.js里是這樣寫(xiě)的

復(fù)制代碼代碼如下:

var db = require('../db/mysql');

var sio = require('socket.io');

var IO = function(server) {

var io = sio.listen(server)

這樣就和諧了，db是創(chuàng)建mysql連接的方法，不在本節(jié)內(nèi)容里，略。

在socket.io里是這樣的，首先創(chuàng)建一個(gè)io通道的連接，然后監(jiān)視里面的socket的事件，nodejs是事件驅(qū)動(dòng)嘛。代碼如下：

復(fù)制代碼代碼如下:

io.on('connection', function(socket) {

        console.log('a user connected.');

        socket.on('disconnect', function() {

            console.log('user disconnected.');

        });

})

這時(shí)只要有用戶連接上，就會(huì)進(jìn)入connection中了，然后它的參數(shù)是個(gè)socket,如果是公聊，我們可以直接用

復(fù)制代碼代碼如下:

io.emit('chat message', {});

這種形式了。但我們這里是私聊，所以我們要臨時(shí)的把這個(gè)socket對(duì)象保存在全局里，供與你私聊的對(duì)象使用找到你的socket,很繞口，其實(shí)這里的私聊，不算完全的點(diǎn)對(duì)點(diǎn)，它還是經(jīng)過(guò)了服務(wù)器的，消息傳給服務(wù)器，服務(wù)器再找到你要傳達(dá)給的那個(gè)人的socket對(duì)象，發(fā)給他。這就是整個(gè)的過(guò)程了。這里我使用的是一個(gè)類數(shù)組對(duì)象來(lái)存儲(chǔ)的.

復(fù)制代碼代碼如下:

var users = {},

usocket = {};

socket.on('user join', function(data) {

    users[username] = username;

    usocket[username] = socket;

})

由于我這里需要用戶名登錄，所以我就把用戶名作為了唯一的標(biāo)識(shí)（這只是一個(gè)例子，不要跟我談?dòng)脩裘貜?fù)的情況），這里用類數(shù)組的形式的好處就是我不用循環(huán)也能夠很快的找到它。再我給A發(fā)送私聊時(shí)，我會(huì)先在這個(gè)uscoket里面找到它，然后調(diào)用它的emit。

function sendUserMsg(data) {
 if (data.to in usocket) {
 console.log('================')
 console.log('to' + data.to, data);
 usocket[data.to].emit('to' + data.to, data);
 usocket[data.user].emit('to' + data.user, data);
 console.log('================')
 }
}

這里我emit了兩次的原因是，我發(fā)給對(duì)方消息的同時(shí)，我自己也要收到這個(gè)消息，然后把它顯示出來(lái)，為什么這樣？其一，接口統(tǒng)一了，聊天里的內(nèi)容全是服務(wù)器過(guò)來(lái)的，其二，證明我發(fā)送成功了。

然后我在客戶端監(jiān)聽(tīng)時(shí)，也用我自己的用戶名起了一個(gè)to+用戶名的事件監(jiān)聽(tīng)。

socket.on('to' + user, function(data) {
 //console.log(data);
 formatMsg(data);
})

這樣，不管是我發(fā)的消息，還是我收到消息，都會(huì)進(jìn)入這個(gè)事件了。最后，在用戶離開(kāi)的時(shí)候別忘記delete掉這個(gè)對(duì)象。

socket.on('disconnect', function() {
 console.log('disconnect')
 if (username) {
 counter--;
 delete users[username];
 delete usocket[username];
 if (home.name == username) {
  homeLeave(username);
 }
 sendmsg({
  type: 0,
  msg: "用戶<b>" + username + "</b>離開(kāi)聊天室",
  counter: counter,
  users: users
 })
 }
});

好了，這樣就大功告成了。

您可能感興趣的文章: