使用node.js中的nodefetch将数据发送到ETIMEDOUT中的Pure data(Pd)结果



我正在构建一个声音安装,它可以下载天气信息并将其转换为声音。此外,我在p5.js中制作了一个简单的html网站,使用户可以关闭音量并使用滑块播放音乐。所有东西都整齐地集成在node.js服务器中。

使用socket.io将数据从sketch.js文件发送到server.js文件;"节点获取";,其中它与[netreceive]对象一起接收。所有这些都是通过localhost(http://"ip-address":端口(完成的。

关于问题:一切都运行得很好,但大约三到六个小时后,节点服务器似乎失去了与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中的错误,还是与互联网有关?这不应该是代理问题,因为我在本地主机上运行它,对吧?

这是我素描的一个样本.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对象侦听端口3558

Pd和Node是用systemd启动脚本启动的。

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

电脑是一台运行树莓派4树莓。Pd工艺以大约15-35%的CPU运行。

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

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

编辑:目前,bash正在吐出这个错误消息,每秒至少有50条消息,pd运行的CPU接近100%。

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

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

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

最新更新