java - 听/通知 pgconnection 关闭 java？

Question

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

Java 中的

LISTENER 类:

        @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 启动时，我配置了在启动时调用监听器类(@Startup 注释)并且它开始在 channel 上监听。

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

但是，当我以编程方式在表上发送 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 类的一个成员变量中，然后它就起作用了。

Answer 1

通知监听器由该库在内部维护为弱引用，这意味着您必须在外部持有硬引用，这样它们才不会被垃圾回收。查看 BasicContext 类第 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”调用将返回 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);

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