Node.js + Socket.io 实现点对点随机匹配聊天

项目背景与技术栈

经常看到有人发布技术笔记，我也希望能持续输出，但受限于技术水平和时间，目前只能边学边分享。此前曾利用 bomb 平台内置的 socket 功能编写过聊天室，主要基于其示例代码修改。此次目标升级为实现随机私聊功能，因此尝试基于 Node.js 和 Socket.io 搭建服务端。作为初次使用 Node.js 进行完整项目开发的实践，虽然成果尚显稚嫩，但仍希望分享相关经验供参考。

项目技术栈主要包括：Node.js 负责后台服务逻辑，Express 用于托管静态资源文件，Socket.io 负责实时聊天数据的传输。实现原理相对直接，前端页面引入 socket.io.js 客户端库，后端通过 require('socket.io') 加载模块并启动服务。建立连接后，前端即可通过特定代码逻辑发送或接收实时消息。

//前端
socket = io.connect('ws://'+'服务器ip');
socket.emit('msg',{msg:'前端要发送的信息'});//要发送的信息（以对象的形式发送）
socket.on('msg2',function(data){
  ...
  //这里的data是后端传过来的信息
})
//后端
socket.on('msg',function(data){
  var data = data; //这里的data就是前端传过来的数据，即{msg:'前端要发送的信息'}
  console.log(data.msg) // 打印出 “前端要发送的信息”
})
//同理，后端要传信息给前端也是一样
socket.emit('msg2',{msg:'后端要发送的信息'});

接下来展示后端如何初始化并运行 Socket.io 服务。

 var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
io.on('connection', function(socket){ //当前端执行 socket = io.connect('ws://'+host); 的时候，此处的io会监听到connection事件
 socket.on('msg',function(data){ 
 io.emit('onlineCount',freeList)
 //如果直接用io.emit来发送数据的话，这代表广播的形式，就是当前所有打开服务的前端页面都会收到这条消息。
 
   socket.emit('welcome',{msg:'欢迎...'})//这里将给当前连接的页面发送一个欢迎的对象数据
 })
 socket.on('disconnect',function(){
 //当前端页面关闭，或者失去连接时,后端会接收到disconnect事件
   
 })

})
http.listen(4000, function(){
 console.log('listening on *:4000');
});

基于 WebSocket 协议，浏览器与服务器之间会建立长连接以进行双向数据传输。对于服务器而言，每个打开的前端页面都会创建一个独立的 Socket 实例。这种一对一的连接机制为后续实现点对点私聊提供了基础。若需实现群聊广播，可直接使用广播功能，但这并非本文重点。

实现点对点通信的核心在于区分不同的 Socket 实例。后端在接收消息时，需判断当前消息的发送者与接收者身份，仅将消息转发至目标对应的 Socket 实例。这一过程类似于传统信件投递：用户将消息发送给后端，并指定接收者 ID，后端根据 ID 查找对应的 Socket 实例并完成转发。

//前端
window.id = new Date().getTime()+""+Math.floor(Math.random()*899+100);
//每次登录，获取一个唯一的用户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保存在一个对象里，key值为id，value就是这个用户的socket
  
})

通过上述逻辑，后端维护了一个名为 userServer 的对象，用于存储每个连接 Socket 与其对应 ID 的映射关系。在每次发送信息时，前端需附带目标接收者的 ID，后端据此解析并实现点对点的数据传输。

关于如何获取对方 ID 及具体数据处理逻辑，由于篇幅和表达限制，此处不再赘述。完整代码已托管至 GitHub，欢迎下载查阅：https://github.com/mikoshu/mychatroom.git

以上内容为本文的全部分享，希望能对读者的学习有所帮助，也欢迎大家继续支持本站。