express-ws如何定期检查自定义事件并自动采取行动

Question

我正在使用 express-ws https://www.npmjs.com/package/express-ws（API 这有助于为 express 和 websocket 客户端创建服务器）。

app.ws('/', function(ws, req) {
  console.log("New connection")
  if (content.length > 0) {
    console.log(content)
    ws.send(content)
  }
  ws.on('message', function(msg, flags) {
    console.log("Received "+ msg);
  });
  ws.on('data', function(msg, flags) {
    var data = []; // List of Buffer objects
    res.on("data", function(chunk) {
      data.push(chunk); // Append Buffer object
      console.log(data)
    })
  })
});

现在，正如您在上面的代码中看到的那样，无论何时创建连接，它都会检查内容的长度，如果长度大于 0，则将内容发送给客户端。

根据网络请求，按照路由器代码更新文件。如果在连接创建后的某个时间修改了此文件，则此问题会出现此问题，此连接不知道它，因此不会调用发送函数。我也试过 fs.watch 但我无法让它工作。

router.post('/run_restart', function(req, res, next) {
  text = '{"to_do": "run_test", "devices":"all", "argv": { "test": "' + req.body.cmd + '", "cycles": "' + req.body.cycles + '", "awake_for": "' + req.body.wt + '" }}'
  path = process.env['HOME']+'/Desktop/automation/Stressem/StressemWeb/bin/task.txt'
  fs.writeFile(path, text)
  res.render('home.jade', { title: 'Stressem' });
});

fs.watch(file, function (event) {
  fs.stat(file, function (err, stats) {
    if(stats.size>80){
      console.log("Event: " + event);
      fs.readFile(file, 'utf8', function (err, data) {
        if (err) throw err;
        content = data.toString();
      });
    }
  });

我想要的是每当文件更新时，ws.send 可以为其中一个 websocket 连接调用。

Answer 1

这个简单的代码很适合 express。如果一些延迟对你来说不是问题，你可以使用它。

setInterval(milisecondsToCheck, checkFunction)

更多

http://www.w3schools.com/jsref/met_win_setinterval.asp

https://developer.mozilla.org/en-US/docs/Web/API/WindowTimers/setInterval

如果你这样使用它，你可以在完成后完成它：

var timer = setInterval(milisecondsToCheck, checkFunction);

要清除它：

clearInterval(timer);

Answer 2

由于您的服务器是更改文件的服务器，因此无需使用 fs.watch，因为您已经知道文件何时更改。剩下要做的就是遍历打开的连接列表并向它们发送新内容。

var connections = []; // Keeps track of all connections
app.ws('/', function(ws, req) {
   console.log("New connection")
   connections.push(ws); // Add the new connection to the list

  if (content.length > 0) {
    console.log(content)
    ws.send(content)
  }
  ws.on('message', function(msg, flags) {
    console.log("Received "+ msg);
  });
  ws.on('data', function(msg, flags) {
    var data = []; // List of Buffer objects
    res.on("data", function(chunk) {
      data.push(chunk); // Append Buffer object
      console.log(data)
    })
  })
  // TODO: Make sure you remove closed connections from `connections`
  // by listening for the ws `close` event.
});

router.post('/run_restart', function(req, res, next) {
  text = '{"to_do": "run_test", "devices":"all", "argv": { "test": "' + req.body.cmd + '", "cycles": "' + req.body.cycles + '", "awake_for": "' + req.body.wt + '" }}'
  path = process.env['HOME']+'/Desktop/automation/Stressem/StressemWeb/bin/task.txt'
  fs.writeFile(path, text)
  res.render('home.jade', { title: 'Stressem' });

  connections.forEach(function(c){
    c.send(text); // Send the new text to all open connections
  }
});

请注意：如果您有多个进程或服务器，这将不起作用，但由于您正在写入本地文件系统而不是数据库，我认为这不是必需的。

Answer 3

用这样的方法解决了这个问题

var conn_array = [];
app.ws('/', function(ws, req) {
    conn_array.push(ws)
    console.log("New connection")

    fs.readFile(file, 'utf8', function (err, data) {
        if (err) throw err;
        content = data.toString();
        if (content.length > 0) {
            console.log(content.length)
            conn_array[0].send(content)
        }
    });


    ws.on('message', function(msg, flags) {
        console.log("Received "+ msg);
    });

    ws.on('data', function(msg, flags) {
        var data = []; // List of Buffer objects
        res.on("data", function(chunk) {
            data.push(chunk); // Append Buffer object
            console.log(data)
        })
    })
});

function readFile(){
    console.log("I am here")
    fs.readFile(file, 'utf8', function (err, data) {
        if (err) throw err;
        content = data.toString();
        if (content.length > 0 && conn_array.length>0) conn_array[0].send(content);
    })
}

var interval = setInterval(readFile, 100000);

现在我假设只有一个客户

express-ws如何定期检查自定义事件并自动采取行动

express-ws how to periodically check a custom event and take action automatically

filesystemwatcher

websocket

node.js

express