如何在Node.js中正确监听PostgreSQL插入通知？

核心问题：连接被提前释放 #

你的代码里调用了done()，这会把监听PostgreSQL通知的客户端还给连接池。连接被回收后，后续的数据库通知就无法传递到你的应用了——PostgreSQL的LISTEN需要保持长连接，不能在执行LISTEN后立即释放客户端。

修正后的Node.js监听代码 #

修改监听逻辑，移除done()调用，同时增加重连机制应对连接断开的情况：

//tools
const express = require('express');
const app = express();
const cors = require('cors');
const bodyParser = require('body-parser');
const port = 3001;
const pool = require('./db'); //stores my postgresql credentials

// Middleware
app.use(cors())
app.use(bodyParser.json())
app.use(bodyParser.urlencoded({extended: true}))

// Apply app.listen notification to console.log
app.listen(port, () => {
    console.log(`App running on port ${port}.`)
})

// 初始化通知监听
setupNotificationListener();

// 封装监听逻辑，支持断连重连
function setupNotificationListener() {
    pool.connect(function(err, client, done) {
        if(err) {
            console.error('数据库连接失败:', err);
            setTimeout(setupNotificationListener, 5000); // 5秒后重试
            return;
        }

        // 监听通知事件
        client.on('notification', function(msg) {
            console.log('收到PostgreSQL通知:', msg);
            // 在这里添加调用外部API的逻辑
            // 示例：fetch('https://your-external-api.com', {
            //   method: 'POST',
            //   headers: { 'Content-Type': 'application/json' },
            //   body: msg.payload
            // });
        });

        // 连接断开时自动重连
        client.on('end', function() {
            console.log('监听连接断开，准备重新连接');
            setupNotificationListener();
        });

        // 执行LISTEN命令
        client.query("LISTEN channel", function(err) {
            if(err) {
                console.error('执行LISTEN命令失败:', err);
                done(); // 出错时释放客户端
                setTimeout(setupNotificationListener, 5000);
                return;
            }
            console.log('已开始监听PostgreSQL频道: channel');
        });

        // 不要调用done()，保持连接持续打开
        // done(); // 移除这一行
    });
}

额外检查点 #

• 验证触发器有效性：手动执行SELECT pg_notify('channel', 'test message');，如果Node.js能收到这条测试消息，说明触发器可能存在问题——检查触发器是否绑定到了正确的表名（你的代码里写的ON table要替换成实际表名），以及触发器函数是否有权限执行pg_notify。
• 调整连接池配置：如果使用的是pg库的连接池，检查idleTimeoutMillis参数，避免超时回收长连接。
• 完善错误捕获：确保所有数据库操作的错误都被打印出来，避免静默失败导致排查困难。

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