使用node.js和socket.io向用户显示实时数据

Question

我正在寻求将我们的 Web 应用程序从传统的 PHP/MySQL 优化/升级到更高效的技术。我一直在研究 node.js、socket.io 和 CouchDB，它们看起来很有前途，但我正在寻找建议和一些帮助来选择我们想要的最佳技术。

那么，概述一下当前所做的事情...

我们拥有捕获数据并将其发送到 FTP 服务器（通过 .txt 文件）的设备。 PHP 脚本每 5 分钟运行一次，扫描 FTP 以查找设备发送的 .txt 文件。文件的内容将插入 MySQL 数据库，并删除 .txt 文件。另一个每 15 分钟运行一次的 PHP 脚本将从数据库中整理数据（例如，上一小时的总和值）并生成一个 XML 文档，该文档由 Flash dial 读取。

显然，这里存在很多问题，而且距离实时解决方案还很远，而这正是我们的目标。我们想要的解决方案是，以某种方式，它可以检测 txt 文件何时上传到 FTP，然后仅处理数据（而不是设置运行间隔）。数据仍然需要添加到数据库中，添加到数据库后立即被前端读取。 Flash 将被完全删除，因为它有点……恶心……

有了令人兴奋的新技术，如 Node.js 和 Web Sockets (socket.io)，我相信我们可以极大地改进这个过程！我知道 Ajax 能够执行类似的操作，但听说与 Web Sockets 相比，它的开销相当高。我对数据库如何与 Node.js 一起工作也有点模糊，更不用说我们所追求的最佳选择......

谢谢！

Answer 1

Node 与 NoSQL 配合得很好（尤其是基于 JSON 的 NoSQL），但由于它们是用于处理 Node 中大多数异步数据库并返回 javascript 对象的模块，如果您更喜欢使用 MySQL，我不会放弃使用它。

这是一个与数据库无关的大纲。

var fs = require('fs');  //to watch the FTP
var db = require('db');  //your choice of db
var express = require('express'); //http server
var io = require('socket.io'); //for realtime data push
var app = express.createServer(); //create http server
/*...usual express implementation...*/
app.listen(80);
var socket = io.listen(app); 
db.connect( ..., start );
function checkForFiles () {
  fs.readdir( FTPpath, sendFilesToDB );
};
function sendFilesToDB ( err, files ) {
  if( files.length === 0 ) {
    return checkForFiles();
  }
  db.insert( fileToQuery( files.pop() ), function () {
    sendFilesToDB( err, files );
  });
}
function fileToQuery ( file ) {
  ...
  return query;
}
function start () {
  checkForFiles();
  setTimeout( checkData, 1000 );
}
function checkData () {
  db.query( '....', function ( err, data ) {
    socket.broadcast( processData( data ) );
    setTimeout( checkData, 1000 );
  }
}
function processData (data) {
  ...
  return data;
}