javascript - 使用 HTTP 请求连续运行 node.js 文件
问题描述
我正在使用 node.js 和 express 来创建应用程序,我有一个文件 TCPServer.js 用于不断轮询 TCP/IP 服务器。我希望能够向读取 IP 地址和端口号的数据库发送单个 HTTP 请求,然后使用该数据调用我的 TCPServer.js 文件,该文件反过来轮询 TCP 服务器。
读取数据库有效,HTTP 请求适用于对 TCPServer 的单个调用,但每当我尝试不断轮询 TCP 服务器时,我都会从服务器收到 1 个轮询响应,然后抛出 500 错误。
因此,如果仅getInputData(ipAddress, connPort)
在 TCPServer.js 中使用,那么 HTTP 请求就可以正常工作,并从我的 TCP 服务器返回一次响应和 200 响应。我得到setInterval(getInputData(ipAddress, connPort), 2000)
了一次数据和一个 500 错误响应。我可以让它每 2 秒轮询一次吗?
TCPServer.js
function getInputData(ipAddress, port) {
"Function for polling TCP Server runs in here"
}
const iModStart = function startInputModule(ipAddress, connPort) {
setInterval(getInputData(ipAddress, connPort), 2000)
}
module.exports = iModStart
用于运行 http 请求的路由处理程序
const iModuleConnect = require('../utils/TCPServer')
//run the polling to input module
router.get('/connections_connect/:id', async (req, res) => {
const _id = req.params.id
try {
const connection = await Connection.findById(_id)
if (!connection) {
return res.status(404).send()
}
if(connection) {
console.log(connection.ipAddress)
console.log(connection.port)
iModuleConnect(connection.ipAddress, connection.port)
}
res.send(connection)
} catch(e) {
res.status(500).send()
}
})
module.exports = router
解决方案
问题是它setInterval
需要一个回调函数作为它的第一个参数,但是你将已经执行的getInputData
函数的结果传递给它。
显然这工作一次,因为函数在第一个间隔之前执行,但是一旦在 2000 毫秒之后达到间隔,就没有回调调用,节点会抛出TypeError [ERR_INVALID_CALLBACK]: Callback must be a function
错误。
要解决此问题,您需要将函数参数绑定到getInputData
并将其作为回调传递给setInterval
:
const iModStart = function startInputModule(ipAddress, connPort) {
setInterval(getInputData.bind(getInputData, ipAddress, connPort), 2000);
}
推荐阅读
- ios - Firebase 动态链接问题
- angular - 检查角度数组对象是否具有指定值
- c# - 我的 IEquatable 有什么问题
, 可比 执行?SortedList 抛出 ArgumentException - jquery - 从 CI_Controller 函数到 Ajax 函数的预期输出问题
- java - 使用 OpenSL ES Android 进行音频合并
- c - 为什么不能在临界区调用 freeRTOS API?
- python - 如何在pyspark的两列上调用平方距离函数?
- c# - 实现接口时如何添加#region?
- c - malloc 实际分配了多少内存,并且可以将变量存储在分配有 malloc 的数组中以节省内存?
- react-native - 在本机反应中无法从 fcm 获得推送通知