nodejs的socket.io學習筆記

socket.io學習筆記

1。服務器信息傳輸；
2。不分組，數據傳輸；
3。分組數據傳輸；
4。Socket.io難點大放送（暫時沒有搞定）；

服務器信息傳輸

1. // send to current request socket client
  2. socket.emit('message', "this is a test");
  3. // sending to all clients except sender
  4. socket.broadcast.emit('message', "this is a test");
  5. // sending to all clients in 'game' room(channel) except sender
  6. socket.broadcast.to('game').emit('message', 'nice game');
  7. // sending to all clients, include sender
  8. io.sockets.emit('message', "this is a test");
  9. // sending to all clients in 'game' room(channel), include sender
  10. io.sockets.in('game').emit('message', 'cool game');
  11. // sending to individual socketid
  12. io.sockets.socket(socketid).emit('message', 'for your eyes only');

上述集中方式爲socket.io經常使用的數據傳輸方式,

1. io.sockets.on('connection', function (socket) {
  2. });

回調函數的socket參數爲一個client與服務器的鏈接標示，不一樣的client會有不一樣的鏈接標示。

不分組，數據傳輸

● socket.emit
socket.emit信息傳輸對象爲當前socket對應的client，各個client socket相互不影響。

● socket.broadcast.emit
socket.broadcast.emit信息傳輸對象爲全部client，排除當前socket對應的client。

● io.sockets.emit
信息傳輸對象爲全部client。

分組數據傳輸

相似於以前提過的of方法生成命名空間來管理用戶，socket.io可使用分組方法,socket.join(),以及與之對應的socket.leave()。

1. io.sockets.on('connection', function (socket) {
  2.     socket.on('firefox', function (data) {
  3.         socket.join('firefox');
  4.     });
  5.     socket.on('chrome',function(data){
  6.         socket.join('chrome');
  7.     });
  8. });

假設有兩個聊天室，一個名爲firefox，另外一個爲chrome，客戶端操做
socket.emit('firefox')，就能夠加入firefox聊天室；
socket.emit('chrome')，就能夠加入chrome聊天室；

向一個分組傳輸消息，有兩種方式：

1. socket.broadcast.to('chrome').emit('event_name', data);
  2.   //emit to 'room' except this socket client
  3. io.sockets.in('chrome').emit('event_name', data)
  4.   //emit to all socket client in the room

broadcast方法容許當前socket client不在該分組內。
可能有一個疑問，一個socket是否能夠同時存在於幾個分組，等效於一個用戶會同時在幾個聊天室活躍，答案是」能夠「，socket.join()添加進去就能夠了。官方提供了訂閱模式的示例：

1. socket.on('subscribe', function(data) { 
  2.     socket.join(data.room);
  3. })
  4. socket.on('unsubscribe', function(data) { 
  5.     socket.leave(data.room);
  6.  })

後臺處理訂閱/退訂事件

1. socket = io.connect('http://127.0.0.1:1338/');
  2. socket.emit('subscribe',{"room" : "chrome"};
  3. socket.emit('unsubscribe',{"room" : "chrome"};

前端觸發訂閱/退訂事件，就能夠加入對應的聊天室。 經過of方法也能夠經過劃分命名空間的方式，實現聊天室功能，但不如分組管理來的方便。

Socket.io難點

● 受權驗證
socket鏈接須要添加權限驗證，讓已登陸的用戶socket鏈接到服務器，未登陸的用戶無條件拒絕。全局受權管理以下：

1. io.sockets.authorization(function (handshakeData, callback) {
  2.      callback(null, true);
  3. }).

callback函數有兩個參數，第一個爲error,第二個參數爲是否受權bool值，經過受權回調函數應爲callback(null,true),其它狀況下都爲拒絕創建鏈接。

按照web的開發方式，檢測是否登陸首選cookie-session來實現，問題也是出在這裏。websocket握手階段屬於HTTP協議，簡單來講是能夠讀到cookie，就能夠實現session。

精準單用戶推送

理論上來講

1. // sending to individual socketid
  2. io.sockets.socket(socketid).emit('message', 'for your eyes only');

就能夠向一個特定用戶推送消息，可是如何得到這個socketId，就是生成一個哈希數組，key爲username，值爲socket.id，這樣就能夠經過用戶名獲取對應的id，進而能夠向特定client推送消息。

因爲我將Express框架和socket.io庫兩個進程，並且沒有使用redis共享數據，因此暫時不能作到session讀取，後續補上。