在线协同技术调研

总数据结构是StoreStruct Map类型，每一个用户一个id：【item,item,item】-----所有人的item一起形成一个链表

后端<br>//&nbsp;导入WebSocket模块:<br>const&nbsp;WebSocket&nbsp;=&nbsp;require('ws');<br>console.log(WebSocket)<br><br>//&nbsp;引用server类&nbsp;就是说真正的服务在大对象中的Server<br>const&nbsp;WebSocketServer&nbsp;=&nbsp;WebSocket.Server;<br><br>//&nbsp;ws:localhost:8500<br>const&nbsp;server&nbsp;=&nbsp;new&nbsp;WebSocketServer({<br>&nbsp;&nbsp;&nbsp;&nbsp;port:8500<br>})<br><br>//&nbsp;open&nbsp;事件&nbsp;<br>server.on('open',()=&gt;{&nbsp; &nbsp; console.log("webSocket&nbsp;open")&nbsp;&nbsp;})<br>//&nbsp;绑定close&nbsp;事件<br>server.on('close',()=&gt;{&nbsp; &nbsp; console.log("webSocket&nbsp;close") })<br>//&nbsp;绑定error&nbsp;事件<br>server.on('error',()=&gt;{&nbsp; &nbsp; console.log("webSocket&nbsp;error")})<br><br>//&nbsp;绑定connection&nbsp;事件&nbsp;&nbsp;<br>//&nbsp;如果有WebSocket请求接入，server对象可以响应connection事件来处理这个WebSocket：<br>server.on('connection',(ws)=&gt;{<br>&nbsp;&nbsp;&nbsp;&nbsp;console.log("connection&nbsp;只要有人连接，那么我就会被触发，有人进来了");<br><br>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;在这里面绑定message&nbsp;事件&nbsp;&nbsp;&nbsp;msg是前端发送过来的数据<br>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;接收前端传递的数据,最终需要广播出去给每一个客户端<br>&nbsp;&nbsp;&nbsp;&nbsp;ws.on('message',(msg)=&gt;{&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;console.log("message")<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;console.log(msg)<br><br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;那到底如何广播出去呢？server.clients&nbsp;记录着保存所有连接到server上的客户端<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;通过forEach遍历得到每一个用户<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.clients.forEach(item=&gt;{<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;item下有个send方法，把这msg广播出去再返回给前端&nbsp;前端在message事件处理函数中就会收到<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;item.send(msg)<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;})<br>&nbsp;&nbsp;&nbsp;&nbsp;})<br>})