如何使用socket.io访问mysql数据库

我只是进入编码服务器端的JavaScript，并已阅读关于socket.io和node.js的教程，但我还没有遇到任何事情展示如何使用node.js来访问MySQL数据库。

例如，我想创build一个方法，在mysql.something.com（与数据库：数据库，用户名：用户名等），我的数据库中的表监听一个表，我怎么会得到socket.io与node.js连接该数据库并监听该表的新input，然后返回该input？

我想知道是否有人可以给我一个使用发布订阅模型的具体例子。

谢谢您的帮助。

Answer 1

您必须定期轮询mysql数据库以进行更改，并在检测到更改时发出socket.io事件。 这是一个伪代码

 var mysql = require('mysql'); var connect = mysql.createConnection({ host: 'localhost' , database: 'your_database' , username: 'user' , password: 'password'}); var initial_result; // check for changes after 1 second setTimeout(function(){ connect.query('select * from your_table', function(err, result) { if(err) { throw new Error('Failed');} initial_result = initial_result || result; if(Changed(initial_result, result)) { socket.emit('changed', result); } }); function Changed(pre, now) { // return true if pre != now } }, 1000);