27.7. 异步通知

PostgreSQL 通过LISTEN和NOTIFY命令提供对异步通知的支持。 一个服务器用LISTEN命令注册一个它感兴趣的通知条件 （也可以用UNLISTEN命令停止监听）。 所有正在监听某一通知条件的会话在该条件名的 NOTIFY（通知）被任何会话执行后都将被异步地通知。 通知发出者不会传递附加的信息到监听者。因此，很典型地是， 任何实际的需要被传递的数据都是通过一个数据库表传递的。 通常，条件名与相关联的表同名，但是并不是一定要与某个表相关才行。

libpq 应用把LISTEN和 UNLISTEN 命令作为通常的 SQL 命令提交。 随后通过调用PQnotifies()可以侦测到 NOTIFY 消息的到达。

函数PQnotifies 从一个来自服务器的未处理的通知信息列表中返回下一条通知。 如果没有未处理的信息则返回 NULL 指针。 一旦PQnotifies返回一条通知， 该通知会被认为已处理并且将被从通知列表中删除。

PGnotify *PQnotifies(PGconn *conn);

typedef struct pgNotify {
    char *relname;		   /* 通知名字*/
    int  be_pid;		   /* 服务器进程 id*/
    char *extra;                /* 通知参数 */
} PGnotify;

在处理完 PQnotifies 返回的PGnotify对象后， 别忘了用PQfreemem() 把它释放，以避免内存泄漏。 释放 PGnotify 指针就足够了；relname 和 extra 字段并未代表独立分配的内存。（目前，extra 字段没有使用， 并且将总是指向一个空字串。）

Example 27-2 给出了一个使用异步通知的例子。

PQnotifies() 实际上并不读取服务器数据； 它只是返回被前面的另一个libpq函数吸收的信息。 在以前的 libpq 的版本里， 周期性的收到NOTIFY信息的唯一方法是持续的提交命令， 即使是空查询也可以，并且在每次 PQexec()后检查 PQnotifies() 。现在这个方法也能还工作， 不过我们认为它太浪费处理器时间而废弃了它。

在你没有可用的命令提交时检查NOTIFY消息的更好的方法是调用 PQconsumeInput()，然后检查 PQnotifies()。你可以使用 select() 来等待服务器数据的到达， 这样在没有数据可处理时可以不浪费 CPU 时间。 （参阅PQsocket() 获取用于 select()的文件描述符。） 注意这种方法不管你使用 PQsendQuery/PQgetResult 还是简单的 PQexec来执行命令都能工作。不过，你应该记住在每次 PQgetResult 或 PQexec后检查 PQnotifies() ，看看在处理命令的过程中是否有通知到达。