|
@@ -20,8 +20,9 @@ def listen_to_redis():
|
|
|
"""监听 Redis 频道并将消息广播到 SocketIO 客户端"""
|
|
|
pubsub = redis_handler.redis.pubsub()
|
|
|
pubsub.subscribe('socket_channel')
|
|
|
-
|
|
|
+ print("daviddebugger:: begin subscribe socket_channel")
|
|
|
for message in pubsub.listen():
|
|
|
+ print("daviddebugger:: come in %s"%message)
|
|
|
if message['type'] == 'message':
|
|
|
data = json.loads(message['data'])
|
|
|
user_id = data.get('user_id')
|