Redis Pub/Sub

사용용도: 인터 PC간 통신, 인터 프로세스 통신, 인터 쓰레드 의 한방향 리얼타임 메세지 통신

  ※  Redis :  메모리상의 데이터 구조체로서 퍼포먼스와 다양성으로 유명

일본 모TV방송사의  PGA일본투어 생방송에 영어 선수명, 순위정보등의 Telop을 리얼타임으로 일본어로 변환하는 프로젝트에 사용.

 

pip install redis

 

Publisher (제공자)

import redis # Connect to local Redis instance redis_client = redis.StrictRedis(host=''localhost'', port=6379, db=0) channel = ''my_channel'' while True:     message = input("Enter a message: ")     redis_client.publish(channel, message)

 

Subscriber (구독자)

import redis # Connect to local Redis instance redis_client = redis.StrictRedis(host=''localhost'', port=6379, db=0) channel = ''my_channel'' pubsub = redis_client.pubsub() pubsub.subscribe(channel) print(f"Subscribed to {channel}. Waiting for messages...") for message in pubsub.listen():     if message[''type''] == ''message'':        print(f"Received: {message[''data''].decode(''utf-8'')}")