如何使用Postgres数据库在Java中获得异步/事件驱动的LISTEN/NOTIT支持

Question

据我所知，Java 中用于 LISTEN/NOTIFY 的 JDBC 驱动程序不支持真正的事件驱动通知。 您必须经常轮询数据库以查看是否有新通知。

我在 Java 中有哪些选项（可能是 JDBC 以外的其他选项？），如果有的话，以真正的事件驱动方式异步获取通知而无需轮询？

Answer 1

使用 pgjdbc-ng 驱动程序。

http://impossibl.github.io/pgjdbc-ng/

它支持异步通知，无需轮询。我已经成功地使用了它。

见 https://database-patterns.blogspot.com/2014/04/postgresql-nofify-websocket-spring-mvc.html

源代码：https://bitbucket.org/neilmcg/postgresql-websocket-example

奥列格也有一个很好的例子答案

Answer 2

下面是使用 com.impossibl.postgres.api （pgjdbc-ng-0.6-complete.jar） 和 JDK 1.8 的异步模式：

import com.impossibl.postgres.api.jdbc.PGConnection;
import com.impossibl.postgres.api.jdbc.PGNotificationListener;
import com.impossibl.postgres.jdbc.PGDataSource;    
import java.sql.Statement;
public static void listenToNotifyMessage(){
    PGDataSource dataSource = new PGDataSource();
    dataSource.setHost("localhost");
    dataSource.setPort(5432);
    dataSource.setDatabase("database_name");
    dataSource.setUser("postgres");
    dataSource.setPassword("password");
    PGNotificationListener listener = (int processId, String channelName, String payload) 
        -> System.out.println("notification = " + payload);
    try (PGConnection connection = (PGConnection) dataSource.getConnection()){
        Statement statement = connection.createStatement();
        statement.execute("LISTEN test");
        statement.close();
        connection.addNotificationListener(listener);
        while (true){ }
    } catch (Exception e) {
        System.err.println(e);
    }
}

为数据库创建触发器函数：

CREATE OR REPLACE FUNCTION notify_change() RETURNS TRIGGER AS $$
    BEGIN
        SELECT pg_notify('test', TG_TABLE_NAME);
        RETURN NEW;
    END;
$$ LANGUAGE plpgsql;

为要跟踪的每个表分配触发器：

CREATE TRIGGER table_change 
    AFTER INSERT OR UPDATE OR DELETE ON table_name
    FOR EACH ROW EXECUTE PROCEDURE notify_change();

Answer 3

似乎没有办法解决这个问题。 你可以绕过它，因为已经提出了一些建议，但最终，你将进行轮询。