node.js + socket.io 實(shí)現(xiàn)點(diǎn)對(duì)點(diǎn)隨機(jī)匹配聊天
真心佩服那些可以經(jīng)常發(fā)布筆記的人,其實(shí)我也想經(jīng)常發(fā)來的,奈何技術(shù)不夠加上懶,要向大神們多多學(xué)習(xí)了,前段時(shí)間有用bomb平臺(tái)自帶的socket寫一個(gè)聊天室,其實(shí)基本就是改了改它的demo,這次想實(shí)現(xiàn)一個(gè)隨機(jī)私聊,所以自己基于node 和 socket.io 來搭服務(wù),當(dāng)然,第一次用node做東西玩,雖然做的不好,但是也蠻分享下哈。
先說說用到的東西, node 用來做后臺(tái)服務(wù),express 用來托管靜態(tài)資源,然后socket.io 用來傳送聊天數(shù)據(jù)。接下來說說思路,其實(shí)用socket.io來傳數(shù)據(jù)是很簡(jiǎn)單的一件事情,我們只需要再前端頁面引入 socket.io.js 然后再node端也require('socket.io'),把它在后端跑起來,那么前端就可以通過如下代碼來發(fā)送或者接收信息。
//前端
socket = io.connect('ws://'+'服務(wù)器ip');
socket.emit('msg',{msg:'前端要發(fā)送的信息'});//要發(fā)送的信息(以對(duì)象的形式發(fā)送)
socket.on('msg2',function(data){
...
//這里的data是后端傳過來的信息
})
//后端
socket.on('msg',function(data){
var data = data; //這里的data就是前端傳過來的數(shù)據(jù),即{msg:'前端要發(fā)送的信息'}
console.log(data.msg) // 打印出 “前端要發(fā)送的信息”
})
//同理,后端要傳信息給前端也是一樣
socket.emit('msg2',{msg:'后端要發(fā)送的信息'});
我們來看后端怎么把socket跑起來
var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
io.on('connection', function(socket){ //當(dāng)前端執(zhí)行 socket = io.connect('ws://'+host); 的時(shí)候,此處的io會(huì)監(jiān)聽到connection事件
socket.on('msg',function(data){
io.emit('onlineCount',freeList)
//如果直接用io.emit來發(fā)送數(shù)據(jù)的話,這代表廣播的形式,就是當(dāng)前所有打開服務(wù)的前端頁面都會(huì)收到這條消息。
socket.emit('welcome',{msg:'歡迎...'})//這里將給當(dāng)前連接的頁面發(fā)送一個(gè)歡迎的對(duì)象數(shù)據(jù)
})
socket.on('disconnect',function(){
//當(dāng)前端頁面關(guān)閉,或者失去連接時(shí),后端會(huì)接收到disconnect事件
})
})
http.listen(4000, function(){
console.log('listening on *:4000');
});
當(dāng)然不僅如此,因?yàn)閣ebsocket協(xié)議,是在瀏覽器和服務(wù)器之間建立了一個(gè)長(zhǎng)鏈接來相互傳輸數(shù)據(jù),對(duì)服務(wù)器而言,如果打開了好幾個(gè)頁面,那么就有好幾個(gè)socket實(shí)例,每個(gè)建立連接的前端頁面都會(huì)有一個(gè)socket實(shí)例,這樣就為接下來的點(diǎn)對(duì)點(diǎn)私聊提供了思路。當(dāng)然,我們也可以通過直接廣播來傳送信息,不過這適用于聊天室情景。
那如何實(shí)現(xiàn)點(diǎn)對(duì)點(diǎn)呢,之前說了,每個(gè)建立連接的頁面都會(huì)產(chǎn)生一個(gè)socket實(shí)例,那么我們只需要后端在接收消息的同時(shí),判斷該socket實(shí)例是和哪個(gè)個(gè)實(shí)例在聊天,只把消息發(fā)送給另一個(gè)匹配的socket實(shí)例就好了。簡(jiǎn)單來說就像寫信一樣,我把消息發(fā)送給后端,然后告訴后端,這個(gè)消息是給xxx的,然后后端找到xxx對(duì)應(yīng)的socket實(shí)例,將消息發(fā)給他就好了。
//前端
window.id = new Date().getTime()+""+Math.floor(Math.random()*899+100);
//每次登錄,獲取一個(gè)唯一的用戶id
socket = io.connect('ws://'+host);
socket.emit('newUser',{ user_name : name, user_id : id})
//建立連接后,將我的用戶名和id都傳給后端
//后端
socket.on('newUser',function(data){
var nickname = data.user_name,
user_id = data.user_id;
userServer[user_id] = socket;
//后端接收后,將該用戶socket保存在一個(gè)對(duì)象里,key值為id,value就是這個(gè)用戶的socket
})
通過上面的代碼,后端得到了一個(gè)userServer的對(duì)象,里面是每個(gè)連接socket和其id的對(duì)應(yīng)值,這樣,就可以通過每次發(fā)送信息時(shí),附帶要接收對(duì)象的id來達(dá)到點(diǎn)對(duì)點(diǎn)的數(shù)據(jù)傳輸。
接下來就是數(shù)據(jù)處理咯,如何取到對(duì)方的id啊等等,鑒于我表達(dá)能力有限,加上懶,就不啰嗦啦~~ 代碼我都托管在github歡迎自己下下來看咯~https://github.com/mikoshu/mychatroom.git
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
詳解如何實(shí)現(xiàn)一個(gè)簡(jiǎn)單的Node.js腳手架
本篇文章主要介紹了如何實(shí)現(xiàn)一個(gè)簡(jiǎn)單的Node.js腳手架,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-12-12
使用node-media-server搭建一個(gè)簡(jiǎn)易的流媒體服務(wù)器
這篇文章主要介紹了使用node-media-server搭建一個(gè)簡(jiǎn)易的流媒體服務(wù)器,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-01-01
基于Node.js實(shí)現(xiàn)nodemailer郵件發(fā)送
Nodemailer 是一個(gè)簡(jiǎn)單易用的 Node.JS 郵件發(fā)送模塊(通過 SMTP,sendmail,或者 Amazon SES),支持 unicode,你可以使用任何你喜歡的字符集。Nodemailer是一個(gè)簡(jiǎn)單易用的Node.js郵件發(fā)送組件,需要的朋友可以參考下2016-01-01
詳解使用抽象語法樹AST實(shí)現(xiàn)一個(gè)AOP切面邏輯
這篇文章主要為大家介紹了使用抽象語法樹AST實(shí)現(xiàn)一個(gè)AOP切面邏輯的簡(jiǎn)單方法,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-04-04
基于NodeJS的前后端分離的思考與實(shí)踐(四)安全問題解決方案
本文就在前后端分離模式的架構(gòu)下,針對(duì)前端在Web開發(fā)中,所遇到的安全問題以及應(yīng)對(duì)措施和注意事項(xiàng),并提出解決方案。2014-09-09

