使用JavaScript实现聊天服务器

提到聊天服务器，首先想到的都是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， 剩下的就是补足各种异常判断了，另外多说一句，微服务的理念很重要，一定要拆分不相干的事情，才能让事情足够简单。