在Spring Boot中实现PostgreSQL LISTEN命令：监听status_change频道事件

当然可以实现，你之前用@EventListener监听PGNotification没生效，是因为PGNotification不是Spring容器自动发布的ApplicationEvent类型，Spring的事件监听机制只能处理Spring体系内的事件，而PostgreSQL的通知是驱动层面的回调事件，不会自动被Spring识别。

下面给两种可行的实现方式：

方式一：直接通过PostgreSQL驱动监听（简单直接） #

创建一个Spring组件，初始化时获取PostgreSQL底层连接，添加通知监听器，并保持连接监听：

@Component
public class PostgresStatusChangeListener {

    @Autowired
    private DataSource dataSource;
    private PGConnection pgConnection;
    private Thread listenerThread;

    @PostConstruct
    public void initNotificationListener() {
        try {
            // 获取数据库连接并转换为PGConnection
            Connection conn = dataSource.getConnection();
            if (conn instanceof PGConnection) {
                pgConnection = (PGConnection) conn.unwrap(PGConnection.class);
                
                // 添加指定频道的通知监听器
                pgConnection.addNotificationListener((channel, pid, payload) -> {
                    if ("status_change".equals(channel)) {
                        // 直接处理通知内容
                        handleStatusChange(payload);
                    }
                });

                // 启动线程轮询保持监听（避免连接闲置被回收）
                listenerThread = new Thread(() -> {
                    while (!Thread.currentThread().isInterrupted()) {
                        try {
                            // 5秒超时轮询，不阻塞线程
                            pgConnection.getNotifications(5000);
                        } catch (SQLException e) {
                            // 可添加重连逻辑
                            e.printStackTrace();
                        }
                    }
                });
                listenerThread.start();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    @PreDestroy
    public void shutdownListener() {
        if (listenerThread != null) {
            listenerThread.interrupt();
        }
        try {
            if (pgConnection != null) {
                pgConnection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private void handleStatusChange(String payload) {
        System.out.println("收到status_change通知：" + payload);
        // 这里编写你的业务逻辑
    }
}

方式二：结合Spring事件机制使用@EventListener #

如果一定要用@EventListener，需要先把PostgreSQL的通知转换为Spring自定义事件：

1. 定义自定义Spring事件 #

public class StatusChangeEvent extends ApplicationEvent {
    private final String payload;

    public StatusChangeEvent(String payload) {
        super(payload);
        this.payload = payload;
    }

    public String getPayload() {
        return payload;
    }
}

2. 修改监听器组件，发布Spring事件 #

@Component
public class PostgresStatusChangeListener {

    @Autowired
    private DataSource dataSource;
    @Autowired
    private ApplicationEventPublisher eventPublisher;
    private PGConnection pgConnection;
    private Thread listenerThread;

    @PostConstruct
    public void initNotificationListener() {
        try {
            Connection conn = dataSource.getConnection();
            if (conn instanceof PGConnection) {
                pgConnection = (PGConnection) conn.unwrap(PGConnection.class);
                
                pgConnection.addNotificationListener((channel, pid, payload) -> {
                    if ("status_change".equals(channel)) {
                        // 发布Spring自定义事件
                        eventPublisher.publishEvent(new StatusChangeEvent(payload));
                    }
                });

                listenerThread = new Thread(() -> {
                    while (!Thread.currentThread().isInterrupted()) {
                        try {
                            pgConnection.getNotifications(5000);
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                });
                listenerThread.start();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    // 省略@PreDestroy方法...
}

3. 编写@EventListener监听自定义事件 #

@Component
public class StatusChangeEventHandler {

    @EventListener
    @Transactional
    public void handleMaintenanceUpdate(StatusChangeEvent event) {
        System.out.println("通过Spring事件收到通知：" + event.getPayload());
        // 业务逻辑处理
    }
}

注意事项 #

• 确保PostgreSQL驱动版本适配，推荐使用最新的postgresql依赖
• 监听用的数据库连接不能被连接池回收，必要时可以单独配置一个专属数据源用于监听
• 可以添加连接断开后的自动重连逻辑，保证监听的稳定性

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