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