javascript - 使用 Node js每秒加载一次查询

Question

我想在插入后选择数据，所以我想要的是每秒检查一次是否有新数据。我创建了一个选择查询，然后尝试使用控制台日志显示它。请帮助我，我是新手。这是我的代码

Controller

var connection = require('../../config/db');

function myQuery(callback) {
this.pushActivity = function(req, res, next) {
    var salesman_id = req.query.salesman_id
    connection.acquire(function(err, con) {
        con.query('SELECT * FROM `activities` where salesman_id="'+salesman_id+'" and kunci="0" and created=NOW()', function(err, data) {
            con.release();
            if (err) {
                return res.json({ status: 400, message: 'Failed', result: [] });
            } else {
                console.log(data)
                // return res.json(data);
            }
        });
    });
};
callback();
}

function wait10sec(){
 setTimeout(function(){
     myQuery(wait10sec);
 }, 10000);
}

myQuery(wait10sec);

module.exports = new myQuery();

路由器

var ad = 
require('./../../controllers/mobile/activity_after_deal');

module.exports = {
   configure: function(app) {
      app.route('/api_ad_push_notif').get(ad.pushActivity);
   }
};

Answer 1

这不是一个好的和有效的方法。尝试在更改数据的放置请求上使用监听器而不是使用此方法，并在更改事件之后执行 Get 查询并输出更改的数据。使用 Socket.io Library用于此类目的。