|
@@ -18,6 +18,7 @@ redis_handler = RedisHandler()
|
|
|
|
|
|
def listen_to_redis():
|
|
|
"""监听 Redis 频道并将消息广播到 SocketIO 客户端"""
|
|
|
+ print("daviddebugger:: begin subscribe socket_channel 111")
|
|
|
pubsub = redis_handler.redis.pubsub()
|
|
|
pubsub.subscribe('socket_channel')
|
|
|
print("daviddebugger:: begin subscribe socket_channel")
|