pg 中的 Listen/Notify 是用来提供客户端之间通过服务段进行消息通信的机制。
listen：监听消息通道
unlisten：取消先前的监听
notify：发送消息到消息通道中
pg_notify()：与 notify 命令的功能相同，也可以发送消息到消息同道中。
pg_listening_channels()：调用此函数可以查询当前 session 已注册了哪些消息监听。
LISTEN
LISTEN channel （channel值任意）
用来注册一个消息通道。
如果在事务中执行 listen，那么事务必须成功 commit，listen才生效。
session 退出后 listen 自动释放。
NOTIFY
NOTIFY channel [, payload] （payload默认要求小于8000字节, 且必须是常量） -- OR pg_notify(channel, payload)
用来往消息通道发送异步消息。
如果在事务中执行 notify，那么必须等事务成功 commit 之后这个消息才会塞进消息队列。
消息在事务和事务之间的间隙传递。因此如果有一个 listen 的 session 中跑了一个很长的事务，那么要等这个事务结束才能接收到这个过程中发出的 notify。
一个消息如果在发出 notify 之前有监听者，必须等这些监听者都接收到了这个消息才从消息队列中去除。
UNLISTEN
UNLISTEN { channel | *)}
注册消息监听后，如果不想再收到相应的消息，可以使用 UNLISTEN 取消监听。UNLISTEN * 可以取消所有监听的注册，在会话结束是也会自动执行这个命令。
示例
通用场景
多个 session 可以同时监听同一个消息通道。当发送端发送一个消息时，所有监听者都可能收到此消息。
-- session 1 postgresql > listen test -- session 2 postgresql > listen test -- session 3 postgresql > notify test, 'hello world'; -- session 1 postgresql > select 1; -- session 2 postgresql > select 1;
回滚场景
如果在事务中调用 notify 发送消息，实际消息要在事务提交时才会被发送，如果事务回滚了，消息将不会发送
-- session 1 postgresql > listen test -- session 2 postgresql > begin; postgresql > notify test, 'hello world'; -- session 1 postgresql > select 1; -- session 2 postgresql > begin; postgresql > notify test, 'hello world'; postgresql > end; -- session 1 postgresql > select 1;
相同消息
如果在一个事务中发送两条消息的通道名称相同，消息字符串也完全相同，则实际上只有一条消息发送出去
-- session 1 postgresql > listen test -- session 2 postgresql > notify test, 'hello world1'; postgresql > notify test, 'hello world1'; postgresql > notify test, 'hello world2'; -- session 1 postgresql > select 1;
