提到聊天服务器，首先想到的都是qq，微信这样重型的聊天工具，或者网易云信这样的服务，所以自己基本没有从零开发的欲望，但是使用node.js，发现原来如此简单！

首先，要对聊天这件事情进行分解，有些事情看起来很复杂，仔细一想特别简单，什么注册登录，个人信息展示，添加好友，好友管理等一系列问题，都交给http的post请求吧，那剩下啥，就剩下两件事情，一，发信息给服务器告诉它我要把什么信息发给谁，二，接收服务器推送过来的信息，告诉我谁给我发了什么。so。

先来个思维导图：

我希望你评价这个设计太low

1， 构造一个websocket服务器，就好像收发快递一样，只需要实现取货发到目的地即可，内容不用管，最简代码如下：

// 导入 express 模块
const express = require('express')
// 创建 express 的服务器实例
const app = express()
// 使用express的 websocket模块
var expressWs = require('express-ws');
expressWs(app);
// 在线连接对象的管理池
var pool = {};
// 注意这里id为请求地址里面的参数
app.ws('/ws/:id', (ws, req)=>{
    //用户上线
    let fromId = req.params.id;
    console.log(fromId, 'go online')
    
    // 存储到连接对象池中
    pool[fromId] = ws;
    // 发送欢迎消息
    send({'type':110,'to':fromId, 'from':'server', 'body':{'text':'连接成功,欢迎欢迎'}})
  
  // 监听 message 事件，拿到客户端通过 websocket 发送过来的数据
    ws.on('message', (msg)=> {
      try {
        console.log(fromId, ' receive:', msg);
        let obj = JSON.parse(msg)
        obj.from = fromId;
        //正常消息处理
        handle(ws, obj); 
      } catch (error) {
        console.error(error);
        ws.send(JSON.stringify({'type':400,'to':fromId, 'from':'server', 'body':{'text':'异常:'+error}}))
      }
    })

    ws.on('close', async (e)=>{
      delete pool[fromId]
      console.log('close, ', fromId, ' up line', e)
    })
})

// 消息处理函数
function handle(ws, msgObj){
  let type = parseInt(msgObj.type)
  switch (type) {
    case 300:   //聊天信息
    case 310:   //聊天确认收到信息
    case 320:   //聊天确认已读
    default:
      // 默认，消息发给目的地，并给自己回复一个成功
      send({'type':msgObj.type, from: 'server', to: msgObj.from, body: {msg:'发送成功'}});
      send({'type':msgObj.type, from: msgObj.from, to: msgObj.to, body: msgObj.body});
      break;
  }
}

//发送消息
async function send(msgObj){
  msgObj.time = new Date().getTime();
  if(pool[msgObj.to]==undefined){
    //对方不在线
    console.log(msgObj.to,  'not online');
  }else{
    let msg = JSON.stringify(msgObj)
    pool[msgObj.to].send(msg);
  }
}


// 调用 app.listen 方法，指定端口号并启动web服务器
app.listen(8080, function () {
  console.log('Express server running at http://127.0.0.1')
})

如上，服务器只负责实现最简单的信息转发，如同收发快递一样，

2， 能更简单地进行测试是一件比服务器更重要的事情。

   var websocket;
		websocket = new WebSocket("ws://127.0.0.1:8080/ws/A11");
		websocket.onmessage = function(event) {
			var data=JSON.parse(event.data);
			console.log(' 收到消息:%o', event.data);
            let type = parseInt(data.type)
            if (type==110){
              let rawObj = {"type":300,"to":"B11" ,"body":{msg:'你好呀'}}   // B11 需要再开一个网页，把A11 换成B11.
                websocket.send(JSON.stringify(rawObj))
            }
    }

3， 剩下的就是补足各种异常判断了，另外多说一句，微服务的理念很重要，一定要拆分不相干的事情，才能让事情足够简单。