使用 express.js 和 socket.io 构建推送通知系统的最佳方法

Question

我将 express.js 和 socket.io 一起用于实时推送通知系统。工作正常，我分享了我在服务器端使用的一些代码行

 var app = express();
 var server = require('http').Server(app);
 var io = require('socket.io')(server);
 server.listen(appconfig.webPort, function() {
  console.log('server runing at ' + appconfig.webPort);
 });

 io.on('connection', function(socket) {
   var id = setInterval(function() {
    some database logic here to get data from database  
       socket.emit(data);
  }, 5000);
 });

我的问题是这段代码会增加服务器的负载吗？因为我每隔几秒钟就从数据库中获取数据。 如果它是有害的，那么最好的方法是什么。

Answer 1

我的问题是这段代码会增加服务器的负载吗？当我得到 每隔几秒钟从数据库中获取数据。如果它是有害的，那是什么 最好的方法。

当然会增加负载。对于与您的服务器建立的每个 socket.io 连接，您将启动一个单独的 5 秒间隔计时器，并且在每次触发该计时器时，您正在运行一个或多个数据库查询，然后将这些结果发送到该客户端。

如果您有 50 个连接的客户端，您将每 100 毫秒 (5000 / 50) 运行一次这些查询。如果您有 1000 个连接的客户端，则平均间隔是每 5 毫秒。除了让您的数据库非常忙碌之外，您的服务器也会非常忙碌。如果您有数千个连接的客户端，扩展会迅速恶化。

如果您为每个客户获取相同的数据，那么您应该改变执行此操作的方式。每 5 秒对数据库进行一次查询，然后将相同的结果发送给所有客户端。这可以扩展很多，好多了。

如果您可以完全避免轮询数据库并依靠某种事件触发器来检测更改，那通常效果会更好。