// 建立連接
 var socket= io('http://localhost:80')
 // on表示接收
 // emit表示發(fā)送
 socket.on('connect', function () {
 console.log('連接上了')
 // 登錄，同步前后端信息
 // 請求后端login接口，寫入socketid
 socket.emit('login', {
  // 身份標(biāo)識，可以是時間戳或者唯一id，最要用來回去socketid進(jìn)行私聊
  id: username
 })
 })


 // 發(fā)送消息，這里可以用發(fā)送事件進(jìn)行消息發(fā)送
 socket.emit('sendMsg', {
 newAccount: 'xxxxxx'
 })
 
 // 接收消息
 socket.on('msg1', function (data) {
 // 可以對數(shù)據(jù)進(jìn)行渲染
 console.log(data)
 
 })
 socket.on('allmessage', function (data) {
 // 接收所有人消息
 console.log(data);

 })
 
 // 表示連接斷開了
 socket.on('disconnect', function () {
 console.log('聊天服務(wù)器斷開了')
 })

npm i koa2 koa-socket -S

 const IO = require('koa-socket')
 const Koa = require('koa2')
 const io = new IO()
 
 const app = new Koa()
 
 // 將socket和app關(guān)聯(lián)
 io.attach(app)
 // 和客服端進(jìn)行連接
 io.on('connection', (context) => {
 console.log('連接上了')
 })
 // 接收消息
 io.on('sendMsg', function (context) {
 //console.log(context.data)
 // 向客服端實時發(fā)送消息
 io.broadcast('msg1', '我是服務(wù)器來的')

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

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