當前位置:編程學習大全網 - 編程語言 - nodejs 怎麽把socket數據寫入數據庫

nodejs 怎麽把socket數據寫入數據庫

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

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

})

}

});

  • 上一篇:spss數據分析的方法都有哪些?
  • 下一篇:有沒有辦法做壹個初中物理教具
  • copyright 2024編程學習大全網