koa socket即時通訊的示例代碼

 // 建立連接
 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('聊天服務器斷開了')
 })

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關聯
 io.attach(app)
 // 和客服端進行連接
 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);
 });