将 Socket.io 与 Sequelize 一起使用

Question

我正在尝试使用 Socket.io 和 Sequelize 创建聊天应用程序。 Socket.io 将处理套接字以允许即时消息传递。 Sequelize 将处理存储消息，因此当您刷新屏幕时，您仍然有您的消息。

发生的事情是，在 localhost 上我的套接字可以工作，但它不会将消息发送到数据库。当我把它放到 Heroku 上时，我的数据库工作正常，但它不使用套接字。

我的套接字位于app.js，我的数据库路由位于routes/messages.js。

我已经研究这个错误一段时间了，我一直在努力寻求帮助。我认为分享这一点的最佳方式是使用我创建的降价，详细说明我为修复我的错误所做的努力，可以在here 找到。我的 repo 可以在 here.

找到

Answer 1

您需要区分几个不同的部分：

• HTTP 服务器，在您的代码中由变量 http 表示
• Express 应用程序，由app 表示
• Socket.IO 服务器，由io 表示
• Socket.IO（客户端）连接（见下文）

HTTP 服务器将“正常”HTTP 请求定向到 Express 应用程序，该应用程序将根据设置的中间件和路由处理它们。使用（至少）两个参数调用路由器处理程序，通常称为 req 和 res，以表示（传入）HTTP 请求和（传出）HTTP 响应。

Socket.IO 服务器处理特定的 Socket.IO 请求，这些请求由 Socket.IO 客户端（在浏览器中运行）发送到服务器。当这样的客户端与服务器建立连接时，connection 事件会在服务器上触发。此事件的任何处理程序都将获得一个参数，通常称为socket，它表示与该客户端的（双向）连接。

该 Socket.IO 连接可以接收消息（从在浏览器中运行的客户端发送），这些消息会触发套接字上的事件。您可以安装一个处理程序来侦听特定消息（如 “聊天消息”），它将接收客户端发送给它的数据作为参数。

您的代码中的问题似乎在于设置所有内容以处理这些聊天消息。正确的设置顺序是：

• 在 Socket.IO 服务器上监听 connection 事件
• 收到此类事件时，为连接上的chat message 事件添加监听器
• 收到此类事件后，将数据写入数据库。

在代码中：

// Listen for new client connections.
io.on('connection', function(socket) {

  // Listen for the client to send a _"chat message"_ message.
  socket.on('chat message', function(data) {

    // Store the data in the database.
    models.Messages.create({
      message  : data.message,
      username : data.username
    });

  });
});

如您所见，req 和 res 在这些 Socket.IO 事件处理程序中不可用，因为它们仅用于正常的 HTTP 请求。

另外，与 HTTP 不同的是，您不必在收到消息后将任何内容发送回客户端，因此我省略了该部分。上面的处理程序仅将消息数据写入数据库（它也不会检查或处理错误，最终您应该添加）。