詳細講解nodejs中使用socket的私聊的方式

在上一次我使用nodejs+express+socketio+mysql搭建聊天室，這基本上就是從socket.io的官網上的一份教程式復制學習，然后，根據國情，我又在其中加入了私聊點對點，然后共享畫圖的你畫我猜功能。

先上效果圖:

由於本人太窮，所以服務器和數據庫都是使用的國外免費的。域名是我的，它的訪問地址是：http://chat.lovewebgames.com

先說下我對socket.io的理解，websocket更像是開啟了一個端口服務，來監視過往的通訊。所以我們可以依賴於當前站點80端口啟socket服務，也可以放於其他端口上，比如：

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,如果是公聊，我們可以直接用

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
				})
			}
		});

好了，這樣就大功告成了。demo:http://chat.lovewebgames.com/  如果有任何的問題，可以加我的QQ群一起學習。QQ技術群：5678537,70210212,77813547