Fix redis pubsub socket timeout (#1206)

Author: wu-clan

backend/common/cache/pubsub.py

@@ -38,7 +38,7 @@ async def subscribe_and_listen() -> None:  # noqa: C901
 
             try:
                 # 使用独立连接
-                pubsub_client = RedisCli()
+                pubsub_client = RedisCli(socket_timeout=None)
                 pubsub = pubsub_client.pubsub()
                 await pubsub.subscribe(settings.CACHE_PUBSUB_CHANNEL)
 

backend/common/socketio/server.py

@@ -14,6 +14,10 @@
 sio = socketio.AsyncServer(
     client_manager=socketio.AsyncRedisManager(
         f'redis://:{urllib.parse.quote(settings.REDIS_PASSWORD)}@{settings.REDIS_HOST}:{settings.REDIS_PORT}/{settings.REDIS_DATABASE}',
+        redis_options={
+            'socket_timeout': None,
+            'socket_connect_timeout': settings.REDIS_TIMEOUT,
+        },
     ),
     async_mode='asgi',
     cors_allowed_origins=settings.CORS_ALLOWED_ORIGINS,

backend/database/redis.py

@@ -16,7 +16,7 @@ def __init__(
         port: int = settings.REDIS_PORT,
         password: str = settings.REDIS_PASSWORD,
         db: int = settings.REDIS_DATABASE,
-        socket_timeout: int = settings.REDIS_TIMEOUT,
+        socket_timeout: int | None = settings.REDIS_TIMEOUT,
         socket_connect_timeout: int = settings.REDIS_TIMEOUT,
         *,
         socket_keepalive: bool = True,