¿Cómo obtengo soporte LISTEN / NOTIFY asincrónico / impulsado por eventos en Java usando una base de datos Postgres?

Solución:

Utilice el controlador pgjdbc-ng.

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

Admite notificaciones asincrónicas, sin sondeo. Lo he usado con éxito.

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

Oleg también tiene un buen ejemplo de respuesta

Aquí hay un patrón asincrónico usando com.impossibl.postgres.api (pgjdbc-ng-0.6-complete.jar) con 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);
    }
}

Cree una función de activación para su base de datos:

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

Asigne un activador para cada tabla de la que desee realizar un seguimiento:

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

---

---

Utiliza Nuestro Buscador