Websocket 端点和 Express 路由器

Question

我试图在我的 Express 应用程序中实现 Web 套接字（npm ws），但陷入了如何实现我的 Web 套接字以便它们与 Express 路由器一起工作的问题。

目前，我的端点看起来像这样...

router.post('/create-note', jwtAuthentication, NotesController.createNote);
router.get('/get-notes/:id',jwtAuthentication, NotesController.getUserNotes);
router.??('/socket-endpoint', NotesController.wssNote);

如您所见，我不确定在路由器上调用什么方法。我尝试过使用“get”和“post”，但由于某种原因，它只有在我在邮递员上尝试第二个连接后才有效。 （我单击“连接”，没有任何反应，然后单击“断开连接”并再次连接，它就可以工作了。）

我知道我可以在创建 WebSocketServer 时传入路径...

var wss = new WebSocketServer({server: server, path: "/hereIsWS"});

这确实有效，但是如果可以将路由器与 web 一起使用-sockets，我认为这会让我的整个项目变得更加干净和更有组织。

我遇到过有人推荐“express-ws”，但想知道是否有更好的方法来解决我的问题，特别是不涉及其他软件包的方法。

提前致谢！

Answer 1

您不将 Express 路由器与 webSocket 一起使用。这不是 webSocket 的正确架构。您的 webSocket 服务器可以与 Express 共享一个 http 服务器，但这几乎是两者之间的全部关系。

webSocket 连接到您传递给 webSocketServer() 构造函数的特定路径，因为您似乎已经知道该路径。一旦它们连接起来，它们就会保持连接并形成一个 TCP 管道，您可以将数据包从客户端发送到服务器或从服务器发送到客户端。没有为此使用 Express 路由。

如果需要，您可以通过创建消息名称作为 webSocket 有效负载的一部分，在 webSocket 消息中创建自己的消息处理（这是 webSockets 之上的 socket.io 层为您做的事情），但它与此无关那时与 Express 。这就是您选择处理传入的 webSocket 数据包的方式。

如果有更好的方法来解决我的问题

您的具体问题是什么？也许如果您说出需要帮助的具体问题，我们可以提供进一步的帮助。

要处理传入的 webSocket 消息，您可以按照 ws 服务器文档 中的示例进行操作：

wss.on('connection', function connection(ws) {
  ws.on('message', function message(data) {
    console.log('received: %s', data);
  });

  ws.send('something');
});

为了进一步分解它以处理不同类型的传入 webSocket 消息，您必须创建自己的消息格式，您可以在该格式上进行分支，或者在客户端和服务器上使用 socket.io 来为您执行此操作。