libpq 应用把 LISTEN 和 UNLISTEN 命令作为通常的 SQL 查询提交.因此,通过调用 PQnotifies() 可以侦测到 NOTIFY 消息的到达.
PGnotify* PQnotifies(PGconn *conn); typedef struct pgNotify { char relname[NAMEDATALEN]; /* name of relation * containing data */ int be_pid; /* process id of backend */ } PGnotify;在处理完 PQnotifies 返回的 PGnotify 对象后,别忘了用 free() 把它释放,以避免内存泄漏。
注意:在 PostgreSQL 6.4 和更高的版本里,be_pid 是正在通知的后端的 PID,而在早些的版本里它总是你自己的后端的PID。
PQnotifies() 实际上不读取后端数据;它只是返回被前面的另一个libpq 函数吸收的信息.在以前的 libpq 的版本里,周期性的收到通知(NOTIFY)信息的唯一方法是持续的提交查询,即使是空查询也可以,并且在每次 PQexec() 后检查 PQnotifies()。现在这个方法也能还工作,不过我们认为它太浪费处理器时间而废弃了它。
在你没有可用的查询提交时检查 NOTIFY 消息的更好的方法是调用 PQconsumeInput(),然后检查 PQnotifies().你可以使用 select(2) 来等待后端数据的到达,这样在没有数据可处理时可以不浪费CPU 时间.注意这种方法不管你使用 PQsendQuery/ PQgetResult 还是简单的 PQexec 来执行查询都能工作.不过,你应该记住在每次 PQgetResult 或 PQexec 后检查 PQnotifies(),看看在处理查询的过程中是否有通知到达.