diff --git a/ruoyi-fastapi-backend/utils/semantic_cache_service.py b/ruoyi-fastapi-backend/utils/semantic_cache_service.py
index 63de9ca..343097b 100644
--- a/ruoyi-fastapi-backend/utils/semantic_cache_service.py
+++ b/ruoyi-fastapi-backend/utils/semantic_cache_service.py
@@ -230,14 +230,14 @@ class SemanticCacheService:
                 chat_id=chat_id
             )
             
-            existing = redis.get(cache_key)
+            existing = await redis.get(cache_key)
             if existing:
                 logger.debug(f"[SemanticCache] 问题已存在，跳过: {question[:30]}...")
                 return True
             
-            self._cleanup_old_cache(chat_id, redis)
+            await self._cleanup_old_cache(chat_id, redis)
             
-            redis.set(
+            await redis.set(
                 cache_key, 
                 json.dumps(entry.to_dict()), 
                 ex=self.CACHE_TTL_HOURS * 3600
@@ -245,7 +245,7 @@ class SemanticCacheService:
             
             logger.info(f"[SemanticCache] 已缓存 | key={cache_key} | question={question[:30]}...")
             
-            verify = redis.get(cache_key)
+            verify = await redis.get(cache_key)
             logger.info(f"[SemanticCache] 存储验证 | key={cache_key} | found={verify is not None}")
             return True
             
@@ -253,7 +253,7 @@ class SemanticCacheService:
             logger.error(f"[SemanticCache] 存储失败: {e}")
             return False
     
-    def _cleanup_old_cache(self, chat_id: str, redis_client=None) -> int:
+    async def _cleanup_old_cache(self, chat_id: str, redis_client=None) -> int:
         """
         清理旧缓存（当缓存过多时）
         
@@ -268,14 +268,14 @@ class SemanticCacheService:
         
         try:
             pattern = f"{self.CACHE_PREFIX}:{chat_id}:*"
-            cache_keys = redis.keys(pattern)
+            cache_keys = await redis.keys(pattern)
             
             if len(cache_keys) <= self.MAX_CACHE_SIZE:
                 return 0
             
             cache_info = []
             for key in cache_keys:
-                data = redis.get(key)
+                data = await redis.get(key)
                 if data:
                     try:
                         entry = CacheEntry.from_dict(json.loads(data))
@@ -288,7 +288,7 @@ class SemanticCacheService:
             
             deleted = 0
             for key, _ in cache_info[:delete_count]:
-                redis.delete(key)
+                await redis.delete(key)
                 deleted += 1
             
             if deleted > 0: