基于websocket实现简单聊天室对话

npm install socket.io-client

npm install http-server

npm install koa

// 引入依赖
const koa = require("koa")
// 初始化koa
const app = new koa()
// 开启 http 
var server = require("http").createServer(app.callback())
// 初始化 socket
const io = require("socket.io")(server, { cors: true })
// 监听
io.on('connection', (socket) => {
  // 主动向客户端发消息

  setTimeout(() => {
    // 通过io对象方法emit 触发一个自定义事件  并且向客户端发送消息
    io.emit('chat message', '想说点什么？')
  }, 1000)

  socket.on('disconnect', () => {
    console.log('user disconnected')
  })

  // 在服务器收到客户端的消息
  // 通过on方法监听事件  当客户端发送消息时会触发该事件 并且可以接受客户端发来的消息
  socket.on('chat message', (msg) => {
    console.log(msg)
    // msg为客户端发来的消息
    // 发消息给客户端是emit
    setTimeout(() => {
      msg = msg.replace("你", "我").replace("吗", "").replace("？", "!")
      // 触发事件 将处理之后的消息信息发送给客户端
      io.emit('chat message', msg)
    }, 500)
  })
})
server.listen(5522,()=>{
  console.log('socket服务已开启,端口号为5522')
});

import { io } from 'socket.io-client'
cteated(){
    // 1.创建连接 可以自定义
    this.socket = io('ws://localhost:5522')
     // 2. 建立连接
    this.socket.on('connect', () => {
        console.log('建立连接成功了')
    })
    // 3.监听消息返回
    this.socket.on('chat message', msg => {
        console.log('服务回来的消息', msg)
    })
}