使用node.js中的节点获取将数据发送到ETIMEDOUT中的纯数据Pd结果

问题描述

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

使用socket.io将数据从sketch.js文件发送到server.js文件。来自服务器的数据通过称为“ node-fetch”的节点包发送到Pure数据，并在其中通过[netreceive]对象接收。所有这些都是通过本地主机（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进程运行的cpu约为15-35％。

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);
    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);
    }
}

解决方法

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

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

node-fetch puredata