1
require('socket.io').listen(3000);
這樣就是監視3000端口了,由於我用的免費服務器,沒有權限打開其他端口,所以,我還是使用80了,由於80已經被express使用了,所以我只好在express使用的時候傳進來了。
var server = http.createServer(app);
var socket = require('./socket/msg')(server);
然後 我在msg.js裏是這樣寫的
var db = require('../db/mysql');
var sio = require('socket.io');
var IO = function(server) {
var io = sio.listen(server)
這樣就和諧了,db是創建mysql連接的方法,不在本節內容裏,略。
在socket.io裏是這樣的,首先創建壹個io通道的連接,然後監視裏面的socket的事件,nodejs是事件驅動嘛。代碼如下:
io.on('connection', function(socket) {
console.log('a user connected.');
socket.on('disconnect', function() {
console.log('user disconnected.');
});
})
這時只要有用戶連接上,就會進入connection中了,然後它的參數是個socket,如果是公聊,我們可以直接用
1
io.emit('chat message', {});
這種形式了。但我們這裏是私聊,所以我們要臨時的把這個socket對象保存在全局裏,供與妳私聊的對象使用找到妳的socket,很繞口,其實這裏的私聊,不算完全的點對點,它還是經過了服務器的,消息傳給服務器,服務器再找到妳要傳達給的那個人的socket對象,發給他。這就是整個的過程了。這裏我使用的是壹個類數組對象來存儲的.
var users = {},
usocket = {};
socket.on('user join', function(data) {
users[username] = username;
usocket[username] = socket;
})
由於我這裏需要用戶名登錄,所以我就把用戶名作為了唯壹的標識,這裏用類數組的形式的好處就是我不用循環也能夠很快的找到它。再我給A發送私聊時,我會先在這個uscoket裏面找到它,然後調用它的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了兩次的原因是,我發給對方消息的同時,我自己也要收到這個消息,然後把它顯示出來,為什麽這樣?其壹,接口統壹了,聊天裏的內容全是服務器過來的,其二,證明我發送成功了。
然後我在客戶端監聽時,也用我自己的用戶名起了壹個to+用戶名的事件監聽。
socket.on('to' + user, function(data) {
//console.log(data);
formatMsg(data);
})
這樣,不管是我發的消息,還是我收到消息,都會進入這個事件了。最後,在用戶離開的時候別忘記delete掉這個對象。
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>離開聊天室",
counter: counter,
users: users
})
}
});