简介
Server-Sent Events，即服务器推送事件，是一种基于 HTTP 的浏览器服务器通信技术，用于向浏览器推送数据。相比于 WebSockets，Server-Sent Events 更加轻量级，不需要建立双向通信，而且是基于标准的 HTTP 传输。本文将介绍如何使用 Server-Sent Events 连接 MySQL 数据库，以实现实时数据更新和推送。
实现过程
1. 安装依赖
在使用之前，需要安装依赖包 express 和 mysql。可以通过以下命令进行安装：
npm install express mysql --save
2. 创建服务器端
在服务器端，需要引入 express 和 mysql，然后创建一个 express 应用程序实例，并使用 mysql 进行连接。在连接数据库后，可以通过查询语句获取相应的数据，并将其推送给客户端。以下是服务器端的示例代码：
// javascriptcn.com 代码示例
const express = require('express');
const mysql = require('mysql');
const app = express();
const db = mysql.createConnection({
host: 'localhost',
user: 'user',
password: 'password',
database: 'database'
});
db.connect((err) => {
if (err) throw err;
console.log('MySQL Connected');
});
app.get('/events', (req, res) => {
res.set({
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
const query = 'SELECT * FROM table';
let lastEventId = req.headers['last-event-id'] || 0;
db.query(query, (err, result) => {
if (err) throw err;
result.forEach((row) => {
if (row.id > lastEventId) {
res.write(`id: ${row.id}\n`);
res.write(`data: ${JSON.stringify(row)}\n\n`);
lastEventId = row.id;
}
});
});
req.on('close', () => {
console.log(`Connection closed: ${req.headers['user-agent']}`);
});
});
app.listen(3000, () => {
console.log('Server started on port 3000');
});3. 创建客户端
在客户端，使用 JavaScript 创建一个 EventSource 对象，指定服务器端的地址。然后可以通过监听 message 事件来处理服务器端推送的数据。以下是客户端的示例代码：
// javascriptcn.com 代码示例
const source = new EventSource('/events');
let lastEventId = 0;
source.addEventListener('message', (event) => {
console.log(JSON.parse(event.data));
lastEventId = event.lastEventId;
});
source.addEventListener('error', (error) => {
console.log(`EventSource error: ${error}`);
});4. 测试
启动服务器端和客户端后，可以通过修改数据库中的数据来测试实时更新和推送。在客户端控制台中可以看到服务器端推送的数据。
总结
使用 Server-Sent Events 连接 MySQL 数据库，可以实现实时更新和推送，提高应用程序的实时性和交互性。本文介绍了实现的基本过程和示例代码，希望能对读者有所帮助。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/6547d4ea7d4982a6eb229549