这个想法是,水中的传感器将数据发送到我的数据库,我希望这些数据被实时地发送到前端,换句话说:数据库更新,然后是前端更新。
我使用的工具:
它实际上运行良好,这是我处理实时数据流的主要代码。
const Zips = require("./dataSchema");
io.on("connection", (socket) => {
setInterval(()=>{
Zips.find().then((result) => {
socket.emit("output", result);
});
}, 5000)
});
#Zips是模式使用猫鼬
我使用use间隔每5秒更新一次。
问题:
是否提供任何函数或方法,因此不需要setInterval或任何其他方式?
##edit 11/8射线显示文档工作。
发布于 2021-11-08 08:33:39
解决办法:
io.on("connection",(socket)=>{
const changeStream = Zips.watch()
changeStream.on('change',(next)=>{
if(next.operationType=="insert"){
Zips.find().then((result) => {
socket.emit("output", result);
});
}
})
})
使用watch()
,然后回调函数提供了大量可以跟踪的数据。
文档:变更流
https://stackoverflow.com/questions/69853231
复制相似问题