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 字段没有使用, 并且将总是指向一个空字串。)
注意: 在 PostgreSQL 6.4 和更高的版本里, be_pid 是正在通知的服务器的 PID, 而在早些的版本里它总是你自己的服务器的PID。
Example 27-2 给出了一个使用异步通知的例子。
PQnotifies() 实际上并不读取服务器数据; 它只是返回被前面的另一个libpq函数吸收的信息。 在以前的 libpq 的版本里, 周期性的收到NOTIFY信息的唯一方法是持续的提交命令, 即使是空查询也可以,并且在每次 PQexec()后检查 PQnotifies() 。现在这个方法也能还工作, 不过我们认为它太浪费处理器时间而废弃了它。
在你没有可用的命令提交时检查NOTIFY消息的更好的方法是调用 PQconsumeInput(),然后检查 PQnotifies()。你可以使用 select() 来等待服务器数据的到达, 这样在没有数据可处理时可以不浪费 CPU 时间。 (参阅PQsocket() 获取用于 select()的文件描述符。) 注意这种方法不管你使用 PQsendQuery/PQgetResult 还是简单的 PQexec来执行命令都能工作。不过,你应该记住在每次 PQgetResult 或 PQexec后检查 PQnotifies() ,看看在处理命令的过程中是否有通知到达。