能否在TypeORM中使用PostgreSQL的LISTEN/NOTIFY功能？

当然可以通过TypeORM实现PostgreSQL的通知监听，不需要单独维护pg包的连接——核心是直接复用TypeORM已经创建的PostgreSQL连接池，不用额外建连接。

实现步骤： #

1. 获取TypeORM底层的PostgreSQL连接池
   TypeORM的Connection对象内置了PostgreSQL驱动的连接池，通过connection.driver.pool就能拿到pg原生的连接池实例，和你单独用pg包创建的连接池是同一个东西。

2. 从连接池取客户端执行LISTEN并监听事件
   从连接池获取一个客户端，执行LISTEN命令后，监听该客户端的notification事件即可接收PostgreSQL的通知。同时要处理连接断开的重连逻辑，因为连接断开后LISTEN会失效。

具体代码示例 #

import { createConnection } from "typeorm";

async function setupPostgresNotificationListener() {
  // 获取TypeORM已建立的连接
  const connection = await createConnection();
  
  // 拿到PostgreSQL驱动的连接池
  const pgPool = connection.driver.pool;
  
  try {
    // 从连接池获取一个客户端（专门用于监听通知）
    const client = await pgPool.connect();
    
    // 执行LISTEN命令订阅指定频道
    await client.query('LISTEN the_notification;');
    
    // 监听通知事件
    client.on('notification', (message) => {
      console.log('收到PG通知:', {
        channel: message.channel,
        content: message.payload
      });
      // 这里可以添加你的业务逻辑处理
    });
    
    // 处理连接断开的情况，自动重新建立监听
    client.on('end', async () => {
      console.log('监听连接断开，正在重连...');
      await setupPostgresNotificationListener();
    });
    
    console.log('PG通知监听已启动');
  } catch (error) {
    console.error('设置PG通知监听失败:', error);
    // 可以添加重试逻辑
  }
}

// 在应用启动时初始化监听
setupPostgresNotificationListener();

注意事项 #

• 这个客户端会被长期占用用来监听通知，不要调用client.release()，否则连接会被放回池里，监听失效。
• 如果你的应用是多实例部署，每个实例都会收到PostgreSQL的通知，需要根据业务情况处理重复消费的问题。
• 可以根据需求订阅多个频道，执行多次LISTEN命令即可。

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