[PostgreSQL] Listen & Notify

#PostgreSQL

PostgreSQL은 구독 모델도 지원한다. DB가 왜 이런걸 제공하는지는 모르겠지만...

아무튼 구독 시스템을 만들기에는 꽤나 유용하다.
SELECT 1 from ... 같은걸 날리는 단순 폴링보다도 부하가 적고 구현이 용이한 부분이 있다.

Listen

먼저 수신자 측에서 생각해보자.
수신은 listen이라는 특수한 명령어를 통해서 수행할 수 있다.

이건 "foo"라는 이름의 채널을 수신한다는 뜻이다.

이 명령을 사용하는 순간 현재 트랜잭션 세션이 구독 상태가 되고, polling을 통해서 이벤트를 받아오게 된다.

이건 터미널 세션이라서 뭔가 기다리지 않고 바로 끝난 것처럼 보이지만, 사실 이벤트가 날아오면 받아올 수 있는 상태가 된 것이다.
애플리케이션 수준에서는 커넥션을 통해서 polling을 하고, 수신된 이벤트를 갖다 쓰면 된다.

구독을 해제하려면 unlisten을 쓰면 된다.

이제 notify를 날려서 구독자들을 깨워보자.
notify는 문자열 기반으로 메세지를 보낼 수도 있고, 메시지 없이 알림만 보낼 수도 있다.

이건 "foo"라는 채널에 "hello"라는 메시지를 보내는 것이다.

그러면 수신자는 그 메세지를 조회할 수 있다.
터미널 세션은 폴링을 즉각 수신하는 그런 UI는 없어서, 세미콜론 하나 정도는 쳐야지 받아온다.

아무튼 이렇게 잘 가져온 것을 볼 수 있다.

PostgreSQL의 구독 모델은 Redis pub/sub과 비슷한 부분이 많다.

우선, 하나의 채널에 구독자가 여럿이라면 구독자들은 하나의 메세지를 전부 공유한다.
한놈만 받고 그런건 아니다.

그리고 여기서 하나 유의할 점은, listen이 없는 채널에 notify를 하면, 그 알림은 버려진다는 것이다.
이런 한계도 Redis pub/sub과 비슷하다.

하나의 트랜잭션 세션은 여러개의 채널을 listen하고 여러개의 구독 상태를 가질 수 있다.