查询一个表，然后使用 knex 和 postgres 将结果流式传输到 socket.io

Question

我想查询一个表并在内容进入时将其写入套接字，以进行更大的查询。 I was reading the documentation for streams。我试图用 socket.io 来实现它。下面是我的/users 路由示例，其中app 是express 的实例，io 是socket.io 的实例。

module.exports = function (app, io) {
  app.get('/users', function (req, res, next) {
    const limit = req.queryParams.limit || 100;
    const stream = req.db.select('*').from('users').limit(limit).stream();
    req.on('close', stream.close.bind(stream));  // manually close on request cancel
    // how can you stream to the socket?
    // how do you know when the amount is reached to end the response?
  });
}

我想知道的是； 如何将此查询的结果流式传输到 io 套接字中？每当找到结果时，我想基本上发出一个added 事件，使用表名、id 和找到的条目作为参数。

Answer 1

如何流式传输到套接字？

您可以通过从 knex 流中侦听 data 事件并通过 io.emit 将数据传递到 socket.io 来访问流式 DB 行。

您如何知道何时达到结束响应的金额？

流将发出一个end 事件。

您知道当end 事件触发时流已完成，但由于您在 HTTP 通道上接受请求但通过单独的 Web 套接字通道响应，您可以立即将 HTTP 响应发送到 res 而无需等待如果您愿意，可以查看数据库查询结果 (res.send())。

 module.exports = function (app, io) {
  app.get('/users', function (req, res, next) {
    const limit = req.queryParams.limit || 100;
    const stream = req.db.select('*').from('users').limit(limit).stream();
    stream.on('data', function (row) {
      io.emit('user', row)
    })
    .on('error', function (error) {
      io.emit('error', error.message)
    })
    .on('end', function () {
      io.emit('end')
    })
    req.on('close', stream.close.bind(stream));  // manually close on request cancel
    // how can you stream to the socket?
    // how do you know when the amount is reached to end the response?
  });
}