pub/sub 내부 구조

redis pub/sub

Redis pub/sub는 다른 메시지 브로커와 달리, 메시지 지속성이 없다.

즉, 메시지를 전송하고 바로 삭제되는데, Redis 내부에 저장되지 않는다.

실시간으로 데이터를 처리하는 경우 적합하지만 메시지가 저장되지 않는것에 주의해야 한다.

• 지속성이 중요하지 않은 메시지를 처리하기에 적합하다.

• 100% 전송 보장이 되지 않아도 되는 곳에 사용하기 좋다.

이벤트를 발행하는 publisher는 특정 Channel(Topic)에 이벤트를 전송한다.

이를 구독하는 subscriber가 존재하는데, 해당 토픽에 구독한 구독자는 퍼블리셔에 상관없이 모든 이벤트를 수신할 수 있다.

pub/sub 내부 구조

Redis pu/sub은 Server channel/pattern 구조체와 Client channel/pattern 구조체가 있다.

• channel : dict(hash table)

• pattern : LinkedList

채널과 패턴은 위와 같은 자료구조에 저장된다고 한다.

Server channel/pattern

dict 구조체를 가르키는 pubsub_channels 필드

• dict 구조체는 여러개의 dictEntry를 가진다.

• 각 엔트리는 { Key(robj channel) : Value(list) } 로 구성되어 있고, list는 LinkedList이다.

• list는 여러 개의 listNode를 가지면서 각 노드는 client를 가르킨다.

publish가 동작하고 message를 전송하면, dict에서 전달받은 channel(dictEntry의 key)을 찾는다.

그리고 dictEntry의 value인 LinkedList를 돌면서 구독한 client에게 메시지를 보낸다.

list를 가르키는 pubsub_pattern 필드

• list에 속해있는 Node들은 각각의 pubsubPattern 구조체를 가르킨다.

• pubsubPattern 구조체는 클라이언트 패턴을 가지고있다.

따라서 publish의 동작은 다음과 같다.

1. publish channel_name message

2. pubsub_chaennels에서 각 channel을 구독한 client에게 메시지를 전달하고

3. pubsub_patterns 패턴안에서 패턴과 일치하는 client에게 메시지를 보낸다.

Client channel/pattern

pubsub_channels 필드

• 클라이언트는 구독한 채널을 저장하는 dict 구조체를 가르킨다.

• 서버와 다르게 dictEntry에는 메시지인 Value는 없고 채널인 Key만 가지고 있다.

따라서 클라이언트는 채널의 존재만 추적하고 실제로 메시지를 관리하지 않는다.

Subscribe 명령이 수행되면 클라이언트 구조체와 서버 구조체 동시에 해당 채널이 저장되고 클라이언트는 해당 채널의 메시지를 수신할 수 있게 된다.

Publish 명령이 수행되면, 서버는 해당 채널을 구독하는 모든 클라이언트를 찾아서 메시지를 전송한다. 이 과정에서 서버 구조체가 사용된다.

pubsub_patterns 필드

• 클라이언트개 pattern을 저장하는 구조체다.

• 클라이언트가 구독한 패턴을 저장하는 리스트를 가리킨다.

• 리스트의 각 노드는 직접 robj pattern 구조체에 연결한다. 구조체는 클라이언트와 패턴을 포함하는데, 클라이언트는 Redis에 연결된 사용자 또는 애플리케이션이다.