在 node.js 中使用 node-fetch 将数据发送到 Pure Data (Pd) 导致 ETIMEDOUT

Posted 2023-03-14

【中文标题】在 node.js 中使用 node-fetch 将数据发送到 Pure Data (Pd) 导致 ETIMEDOUT

【英文标题】：Send data with node-fetch in node.js to Pure Data (Pd) result in ETIMEDOUT

【发布时间】：2021-01-10 19:11:33

【问题描述】：

我正在构建一个声音装置，用于下载天气信息并将其转换为声音。另外，我在 p5.js 中创建了一个简单的 html 站点，它使用户能够关闭音量并使用滑块播放音乐。一切都整齐地集成在 node.js 服务器中。

使用 socket.io 将数据从sketch.js 文件发送到 server.js 文件。来自服务器的数据通过名为“node-fetch”的节点包发送到 Pure data，并通过 [netreceive] 对象接收。所有这些都是通过 localhost (http://"ip-adress":port) 完成的。

关于问题：一切运行良好，但大约三到六个小时后，节点服务器似乎失去与 Pd（纯数据）的连接并终止。我重新启动，同样的事情发生了。错误信息如下：

Sep 24 14:55:52 raspberrypi bash[7530]: (node:7561) UnhandledPromiseRejectionWarning: FetchError: request to http://192.168.1.219:3558/ failed, reason: connect ETIMEDOUT 192.168.1.219:3558
Sep 24 14:55:52 raspberrypi bash[7530]:     at ClientRequest.<anonymous> (/home/pi/Documents/pd2_repository/node_modules/node-fetch/lib/index.js:1455:11)
Sep 24 14:55:52 raspberrypi bash[7530]:     at ClientRequest.emit (events.js:198:13)
Sep 24 14:55:52 raspberrypi bash[7530]:     at Socket.socketErrorListener (_http_client.js:401:9)
Sep 24 14:55:52 raspberrypi bash[7530]:     at Socket.emit (events.js:198:13)
Sep 24 14:55:52 raspberrypi bash[7530]:     at emitErrorNT (internal/streams/destroy.js:91:8)
Sep 24 14:55:52 raspberrypi bash[7530]:     at emitErrorAndCloseNT (internal/streams/destroy.js:59:3)
Sep 24 14:55:52 raspberrypi bash[7530]:     at process._tickCallback (internal/process/next_tick.js:63:19)
Sep 24 14:55:52 raspberrypi bash[7530]: (node:7561) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 735)

我不知道从哪里开始寻找答案：是我的sketch.js、server.js、Pd 中的错误，还是与互联网有关？应该不是代理问题，因为我是在 localhost 上运行的，对吧？

这是我的sketch.js 中的一个示例：

function setup() 
  noCanvas();

  // Start a socket connection to the server
  socket = io.connect(url + ':3000');

async function getISS() 
    const response = await fetch(api_url);
    const data = await response.json();
    console.log(data.timeSeries[2].validTime);

    var smhiData = 
      pcat: data.timeSeries[2].parameters[2].level,
      sunUp: 6,
      sunDown: 20
    ;
    socket.emit('smhiToPd', smhiData); 

这是服务器的示例：

io.sockets.on('connection', newConnection);

// We are given a websocket object in our function
function newConnection(socket) 
    console.log('We have a new client: ' + socket.id);
socket.on('smhiToPd', smhi);

    async function smhi(data)
        pcat = data.pcat;

        fetch("http://" + ip + ":" + 3558, 
            method: "PUT", 
            body: ";pcat " + pcat + ";"
        );
    

这就是它在 Pd 中的样子： Netreceive-object listening to port 3558

Pd 和 Node 使用 systemd 启动脚本启动。

关于 Pd 的一些信息： 版本：0.51-2。 标志：-rt 和 -nogui。 音频率：48 kHz 块大小：64 延迟：512。

计算机是运行 Raspbian 的 Raspberry Pi 4。 Pd 进程以大约 15-35 % 的 CPU 运行。

PS 非常感谢您的帮助。请注意，我是初学者，我的编程技能和知识非常有限。我会尽力理解您可能有的任何答案或想法！

PPS 我知道我还没有在服务器中实现 .catch。我刚刚在我的代码中实现了它，我正在等待另一个崩溃。

编辑：目前，bash 正在吐出此错误消息，至少每秒 50 条消息，并且 pd 正在运行接近 100% 的 CPU。

Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed
Sep 25 07:46:52 raspberrypi bash[10566]: netreceive: accept failed

我想我找到了 [netreceive] 的源代码。这是关于“接受失败”的部分。任何人都可以理解这一点吗？

static void netreceive_connectpoll(t_netreceive *x)

    int fd = accept(x->x_connectsocket, 0, 0);
    if (fd < 0) post("netreceive: accept failed");
    else
    
        t_socketreceiver *y = socketreceiver_new((void *)x, 
            (t_socketnotifier)netreceive_notify,
                (x->x_msgout ? netreceive_doit : 0), 0);
        sys_addpollfn(fd, (t_fdpollfn)socketreceiver_read, y);
        outlet_float(x->x_connectout, ++x->x_nconnections);
    

【参考方案1】：

我找到了导致连接关闭和计算机冻结的原因的答案。这是 Pd 的 [netreceive] 每次收到新消息时都会打开一个新连接。这适用于几个连接，但随着连接数量的增加，负载变得越来越重，最终导致计算机死机。

为什么 Pd 每次收到数据都会打开一个新的连接？不确定。是不是和 TCP 协议有关？