Node.js中基于net模块的消息处理代码是否实时存储至数据库？

你的这段代码是异步存储，并非实时同步写入数据库，核心原因如下：

• mysql2的query方法属于异步IO操作：它通过回调函数处理执行结果。当socket收到数据触发data事件后，调用db.query()会将数据库写入请求放入Node.js的事件队列，当前线程不会阻塞等待数据库操作完成，而是继续处理后续的网络事件或消息。也就是说，代码只是发起了写入请求，不会等到数据库确认写入成功后再处理下一条消息。

• 当前代码的潜在问题：回调中直接throw e会导致进程崩溃，应该替换为错误日志记录；如果短时间内收到大量消息，异步请求的积压可能会造成写入延迟。

如果需要更接近“实时”的写入效果（保证消息顺序且尽可能低延迟），可以做这些优化：

• 使用mysql2的Promise API配合async/await，实现串行或可控的并行写入
• 对消息做批量处理，减少数据库连接请求次数
• 添加错误重试机制，避免单次写入失败丢失数据

附上格式化后的代码：

const net = require("net");
const mysql = require("mysql2");

const server = net.createServer(socket => {
    socket.on("data", data => {
          db.query("INSERT INTO messages (message) VALUES (?)", [data.toString()], (e, r) => {
        if (!e) {
            console.log("Saved the message successfully!");
        } else {
            throw e;
        }
      });
    });
});

server.listen(3000, "127.0.0.1", () => {
    console.log("Connected to the server successfully!");
});

const db = mysql.createConnection({
    host: "127.0.0.1",
    port: 3306,
    user: "root",
    password: "",
    database: "message"
});

db.connect(err => {
    if (!err) {
        console.log("Connected to the database successfully!");
    } else {
        throw err;
    }
});

内容的提问来源于stack exchange，提问作者user22296820