黑马程序员技术交流社区

标题: 【前端技术分享】如何实现点对点随机匹配聊天 [打印本页]

---

作者: 月亮是我掰弯的    时间: 2016-10-7 11:53
标题: 【前端技术分享】如何实现点对点随机匹配聊天



真心佩服那些可以经常发布笔记的人，其实我也想经常发来的，奈何技术不够加上懒，要向大神们多多学习了，前段时间有用bomb平台自带的socket写一个聊天室，其实基本就是改了改它的demo，这次想实现一个随机私聊，所以自己基于node 和 socket.io 来搭服务，当然，第一次用node做东西玩，虽然做的不好，但是也蛮分享下哈。
    下面是demo地址，可以自己开两个网页和自己聊天看效果哦~

    基于node和socket的随机匹配聊天
    先说说用到的东西， node 用来做后台服务，express 用来托管静态资源，然后socket.io 用来传送聊天数据。接下来说说思路，其实用socket.io来传数据是很简单的一件事情，我们只需要再前端页面引入 socket.io.js  然后再node端也require('socket.io')，把它在后端跑起来，那么前端就可以通过如下代码来发送或者接收信息。//前端

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

复制代码

    我们来看后端怎么把socket跑起来

1. var express = require('express');
   
2. var app = express();
   
3. var http = require('http').Server(app);
   
4. var io = require('socket.io')(http);
   
5. io.on('connection', function(socket){ //当前端执行 socket = io.connect('ws://'+host); 的时候，此处的io会监听到connection事件
   
6.         socket.on('msg',function(data){
   
7.                 io.emit('onlineCount',freeList)
   
8.                 //如果直接用io.emit来发送数据的话，这代表广播的形式，就是当前所有打开服务的前端页面都会收到这条消息。
   
9.         
   
10.             socket.emit('welcome',{msg:'欢迎...'})//这里将给当前连接的页面发送一个欢迎的对象数据
    
11.         })
    
12.         socket.on('disconnect',function(){
    
13.                 //当前端页面关闭，或者失去连接时,后端会接收到disconnect事件
    
14.             
    
15.         })
    
16. 
    
17. })
    
18. http.listen(4000, function(){
    
19.         console.log('listening on *:4000');
    
20. });

复制代码

    当然不仅如此，因为websocket协议，是在浏览器和服务器之间建立了一个长链接来相互传输数据，对服务器而言，如果打开了好几个页面，那么就有好几个socket实例，每个建立连接的前端页面都会有一个socket实例，这样就为接下来的点对点私聊提供了思路。当然，我们也可以通过直接广播来传送信息，不过这适用于聊天室情景。
    那如何实现点对点呢，之前说了，每个建立连接的页面都会产生一个socket实例，那么我们只需要后端在接收消息的同时，判断该socket实例是和哪个个实例在聊天，只把消息发送给另一个匹配的socket实例就好了。简单来说就像写信一样，我把消息发送给后端，然后告诉后端，这个消息是给xxx的，然后后端找到xxx对应的socket实例，将消息发给他就好了。

1. //前端
   
2. window.id = new Date().getTime()+""+Math.floor(Math.random()*899+100);
   
3. //每次登录，获取一个唯一的用户id
   
4. socket = io.connect('ws://'+host);
   
5. socket.emit('newUser',{ user_name : name, user_id : id})
   
6. //建立连接后，将我的用户名和id都传给后端
   
7. 
   
8. //后端
   
9. socket.on('newUser',function(data){
   
10.                 var nickname = data.user_name,
    
11.                         user_id = data.user_id;
    
12.                 userServer[user_id] = socket;
    
13.                 //后端接收后，将该用户socket保存在一个对象里，key值为id，value就是这个用户的socket
    
14.    
    
15. })

复制代码

    通过上面的代码，后端得到了一个userServer的对象，里面是每个连接socket和其id的对应值，这样，就可以通过每次发送信息时，附带要接收对象的id来达到点对点的数据传输。
    接下来就是数据处理咯，如何取到对方的id啊等等，鉴于我表达能力有限，加上懒，就不啰嗦啦~~ 代码我都托管在github欢迎自己下下来看咯~

精华推荐：1
【前端】2016最全最新视频+源码+技巧+软件+面试汇总

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2