Node.js------koa-socket

koa-socket

1.起步

引入

var IO=require('koa-socket');
var io=new IO();
io.attach(app);//将socket和app关联

2.使用

客户端：
首先引入包：

<script src="/socket.io/socket.io.js"></script>

服务端和客服端通过on和emit进行交互
emit表示发送，事件名自定义，另一端用on进行接收
on表示接受，类似jq绑定事件，事件名对应emit事件名
connect，disconnect是连接和断开事件

 // 建立连接
   var socket= io('http://localhost:80')
   // on表示接收
   // emit表示发送
   socket.on('connect', function () {
       console.log('连接上了')
       // 登录，同步前后端信息
       // 请求后端login接口，写入socketid
       socket.emit('login', {
           // 身份标识，可以是时间戳或者唯一id，最要用来回去socketid进行私聊
           id: username
       })
   })


   // 发送消息，这里可以用发送事件进行消息发送
   socket.emit('sendMsg', {
       newAccount: 'xxxxxx'
   })
   
   // 接收消息
   socket.on('msg1', function (data) {
       // 可以对数据进行渲染
       console.log(data)
      
   })
   socket.on('allmessage', function (data) {
       // 接收所有人消息
       console.log(data);

   })
   
   // 表示连接断开了
   socket.on('disconnect', function () {
       console.log('聊天服务器断开了')
   })

服务端：

    // 和客服端进行连接
    io.on('connection', (context) => {
        console.log('连接上了')
    })
    // 接收消息
    io.on('sendMsg', function (context) {
        //console.log(context.data)
        // 向客服端实时发送消息
        io.broadcast('msg1', '我是服务器来的')

        // 广播，所有人消息
        io.broadcast('allmessage', context.data.newAccount)
    })

    // 处理登陆同步信息
    io.on('login', context => {
        let id = context.data.id;
        console.log(context);
    });