Redis를 활용한 Message Queue(Pub/Sub) 만들기 ( with python )

1. 우선 해당 모듈을 설치한다. 

pip install redis

 

2. publisher 만들기

import redis

# Redis 클라이언트 생성
redis_client = redis.Redis(host='localhost', port=6379)

# 채널에 메시지 발행
redis_client.publish('my-channel', 'Hello, world!')

publish() 메서드를 사용하여 my-channel 채널에 메시지를 발행합니다. 

 

3. subscriber 만들기

import redis

# Redis 클라이언트 생성
redis_client = redis.Redis(host='localhost', port=6379)

# 채널 구독
pubsub = redis_client.pubsub()
pubsub.subscribe('my-channel')

# 메시지 수신 대기
for message in pubsub.listen():
    print(message)

 

 pubsub() 메서드를 사용하여 my-channel 채널을 구독한다 그런 다음 listen() 메서드를 사용하여 메시지를 수신 대기한다.