我刚刚开始编写服务器端 javascript，并且一直在阅读有关 socket.io 和 node.js 的教程，但我没有遇到任何演示如何使用 node.js 访问 mysql 数据库的内容。
比如说我想创建一个方法来监听我的数据库中的一个表 mysql.something.com（带有数据库：数据库，用户名：用户名等），如何 我使用 node.js 获取 socket.io 以连接到该数据库并侦听该表的新输入，然后返回该输入？
我想知道是否有人可以给我一个使用发布订阅模型的具体示例。
感谢您的帮助。
【问题讨论】：
npm install mysql IIRC) 并使用它。听起来你误解了基本结构
标签： mysql node.js socket.io serverside-javascript
您必须定期轮询 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);
【讨论】：
如果你已经解决了你的问题，我不知道，但昨天我也遇到了这个问题。我想看一个 node.js、socket.io 和 mysql 的例子。所以我在 youtube 上搜索了很多，发现只有这个..https://www.youtube.com/watch?v=Pw_AhwvxU58.
我希望我能以某种方式帮助你。
【讨论】：
我想知道在处理用户登录时这是否可能？我正在尝试创建一个聊天室，用户可以在其中注册并登录，然后开始聊天。我在拉取用户名以通过套接字聊天系统时遇到问题。
> ` passport.use(new JWTStrategy({
jwtFromRequest: ExtractJwt.fromAuthHeaderAsBearerToken(),
secretOrKey: process.env.SECRET
}
, async function ({ id }, cb) {
try {
const user = await User.findOne({ where: { id }, include: [Post] } )
cb(null, user)
socket.emit('username', user.User.username)
} catch (err) {
cb(err, null)
}
}))`
这只是我在阅读了你们上面发布的内容后发出用户名的糟糕尝试。我不确定这是否可行，但我想知道从这个异步函数中提取 user.User.username 并将其发送到套接字是否允许我在聊天中使用用户名。
【讨论】：