请教 Nodejs socket.io 大神来助攻一下

发布于 1周前 作者 songsunli 来自 nodejs/Nestjs

请教 Nodejs socket.io 大神来助攻一下

最新用 socket.io 写了个小程序，用递归每秒刷新一次数据库，并把读出来的数据 emit 到前端，前端有审核功能，点击后 remove 掉，然后更新数据库，现在出现了一个问题，程序运行一天之后，就会变得非常卡，一看服务器宽带的使用非常高，请教大神，会是什么原因呢

Harmonyos Next教程
14 回复

万能重启进程大法


用递归每秒刷新一次数据库，不是这里的问题？

问题可能出在递归上

不会是每个连接 都 递归每秒刷新一次数据库，并把读出来的数据 emit 到前端 。。。

没有释放数据库链接？ 看下连接池呢

你 f12 看一下 console 那边打了多少的 log… 是那边的问题

为什么用了 socket.io 了还要去做这种 每秒刷新的动作?

socket 不就是为了让你不用每秒刷新吗

websocket 是长连接啊，每秒刷一次是什么目的？

websocket 就是为了解决你轮询的问题，长连接你直接 emit 就好。

感谢各位大神回复，我需要每秒往前端推送一次数据，需要读取数据库的新数据，实现的方式不正确吗

数据库里的新数据是哪里来的？我觉得你这个设计可能是有点欠缺的。提供 3 点建议：

1. 在更新数据的地方提供一个事件或者其它方式的触发功能，一旦触发直接 socket emit 消息，不用一直去扫数据库。

2. 如果更新数据库的操作是其他语言写的，可以试试 Rabbit MQ 列队，这是数据量大的方案。如果是 Postgresql，可以写一个 python 的函数作为触发器，python 有 socket emit 可以用，这是数据量小的方案。

3. 检查 web socket 的前后端代码，已经下线的用户要及时释放 socket 资源，否则虽然前端用户已下线，但是服务器上可能还在一直尝试 emit。

非常感您回答，我们这边服务器是 PHP 架构的，我这个小程序其实也是嵌入到 PHP 项目的，目前是想学习 socket.io，写了个测试的小程序，我现在在调试，可能是数据库连接池没有释放的原因

当然可以，关于 Node.js 和 Socket.io 的问题，我很乐意提供帮助。下面是一个简单的示例，展示如何使用 Node.js 和 Socket.io 创建一个基本的实时聊天服务器和客户端。

服务器端 (server.js)

const express = require('express');
const http = require('http');
const socketIo = require('socket.io');

const app = express();
const server = http.createServer(app);
const io = socketIo(server);

io.on('connection', (socket) => {
  console.log('a user connected');
  
  socket.on('disconnect', () => {
    console.log('user disconnected');
  });

  socket.on('chat message', (msg) => {
    console.log('message: ' + msg);
    io.emit('chat message', msg);
  });
});

server.listen(3000, () => {
  console.log('listening on *:3000');
});

客户端 (index.html)

<!doctype html>
<html>
  <body>
    <script src="/socket.io/socket.io.js"></script>
    <script>
      const socket = io();
      
      function sendMessage() {
        const msg = document.getElementById('myMessage').value;
        socket.emit('chat message', msg);
      }

      socket.on('chat message', function(msg){
        const p = document.createElement('p');
        p.innerHTML = msg;
        document.body.appendChild(p);
      });
    </script>
    <input type="text" id="myMessage" autocomplete="off" /><button onclick="sendMessage()">Send</button>
  </body>
</html>

运行 server.js 后，打开 index.html 文件，即可在浏览器中看到一个简单的实时聊天应用。希望这个示例能帮到你！

回到顶部