LISTEN/NOTIFY pgconnection 关闭 java？

Question

我正在使用 PostgreSQL 数据库并应用它的 LISTEN/NOTIFY 功能。所以我的监听器在我的 AS（应用程序服务器）上，我在我的数据库上配置了触发器，这样当对 table 执行 CRUD 操作时，就会在 AS 上发送 NOTIFY 请求。

监听器 class 在 java:

        @Singleton
        @Startup
    NotificationListenerInterface.class)
        public class NotificationListener extends Thread implements NotificationListenerInterface {

            @Resource(mappedName="java:/RESOURCES") 
            private DataSource ds;

            @PersistenceContext(unitName = "one")
            EntityManager em;

            Logger logger = Logger.getLogger(NotificationListener.class);

            private Connection Conn;
            private PGConnection pgConnection = null;
            private NotifyRequest notifyRequest = null;

            @PostConstruct
            public void notificationListener() throws Throwable {

                System.out.println("Notification****************");
                try
                {


                    Class.forName("com.impossibl.postgres.jdbc.PGDriver");
                    String url = "jdbc:pgsql://192.xx.xx.126:5432/postgres";


                    Conn = DriverManager.getConnection(url,"postgres","password");
                    this.pgConnection = (PGConnection) Conn;

                    System.out.println("PG CONNECTON: "+ pgConnection);
                    Statement listenStatement = Conn.createStatement();
                    listenStatement.execute("LISTEN notify_channel");
                    listenStatement.close();

                    pgConnection.addNotificationListener(new PGNotificationListener() {

                        @Override
                        public void notification(int processId, String channelName, String payload){

                            System.out.println("*********INSIDE NOTIFICATION*************");

                            System.out.println("Payload: " + jsonPayload);

}

因此，当我的 AS 启动时，我已配置为在启动时调用侦听器 class (@Startup annotation) 并开始在频道上侦听。

现在这工作正常，如果说测试我在数据库中手动编辑我的 table，通知生成并且 LISTENER 收到它。

但是，当我以编程方式在 table 上发送 UPDATE 请求时，UPADTE 已成功执行，但 LISTENER 没有收到任何东西。

我感觉当我发送请求时我的 LISTENER 连接断开了（它也连接到编辑实体），但我不确定。我阅读了有关永久连接和池化连接的信息，但无法决定如何进行。

我正在使用 pgjdbc (http://impossibl.github.io/pgjdbc-ng/) jar 作为异步通知，因为 jdbc 连接需要轮询。

编辑：

当我尝试使用标准 jdbc jar（不是 pgjdbc）轮询上述侦听器时，我收到了通知。

我愿意 PGNotification notif[] = con.getNotifications() 我收到通知，但是像下面这样异步执行我没有收到通知。

    pgConnection.addNotificationListener(new PGNotificationListener() {

         @Override
         public void notification(int processId, String channelName, String payload){

            System.out.println("*********INSIDE NOTIFICATION*************");
         }

已解决：

我的侦听器 在函数执行完成后超出范围 ，因为我的侦听器具有函数范围。所以将它保存到我的启动 bean class 的成员变量中，然后它就起作用了。

Answer 1

通知侦听器由该库在内部维护为弱引用，这意味着您必须在外部持有硬引用，这样它们就不会被垃圾回收。查看 BasicContext class 行 642 - 655:

public void addNotificationListener(String name, String channelNameFilter, NotificationListener listener) {

    name = nullToEmpty(name);
    channelNameFilter = channelNameFilter != null ? channelNameFilter : ".*";

    Pattern channelNameFilterPattern = Pattern.compile(channelNameFilter);

    NotificationKey key = new NotificationKey(name, channelNameFilterPattern);

    synchronized (notificationListeners) {
      notificationListeners.put(key, new WeakReference<NotificationListener>(listener));
    }

}

如果 GC 接收到您的侦听器，对弱引用的“get”调用将 return 为 null，并且不会触发，如第 690 - 710 行所示

  @Override
  public synchronized void reportNotification(int processId, String channelName, String payload) {

    Iterator<Map.Entry<NotificationKey, WeakReference<NotificationListener>>> iter = notificationListeners.entrySet().iterator();
    while (iter.hasNext()) {

      Map.Entry<NotificationKey, WeakReference<NotificationListener>> entry = iter.next();

      NotificationListener listener = entry.getValue().get();
      if (listener == null) {

        iter.remove();
      }
      else if (entry.getKey().channelNameFilter.matcher(channelName).matches()) {

        listener.notification(processId, channelName, payload);
      }

    }

}

要解决此问题，请这样添加您的通知侦听器：

/// Do not let this reference go out of scope!
    PGNotificationListener listener = new PGNotificationListener() {

    @Override
    public void notification(int processId, String channelName, String payload) {
        // interesting code
    };
};
    pgConnection.addNotificationListener(listener);

在我看来，弱引用的用例很奇怪...

LISTEN/NOTIFY pgconnection 关闭 java？

LISTEN/NOTIFY pgconnection goes down java?

java

postgresql

database-connection

connection-pooling

pg-jdbc