diff --git a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php
index 3caf1b5..eb679b2 100644
--- a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php
@@ -57,7 +57,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage
 
             // 获取缓存
             $redis = $this->container->get(Redis::class);
-            $redis_key = "user_im_online" . $data['user_id'];
+            $redis_key = "user_im_online_" . $data['user_id'];
             $res = $redis->get($redis_key);
             if ($res){
                 Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟，无需处理");
diff --git a/app/Services/UserService.php b/app/Services/UserService.php
index 2163698..e68ad8e 100644
--- a/app/Services/UserService.php
+++ b/app/Services/UserService.php
@@ -1009,7 +1009,7 @@ class UserService extends BaseService
 
                 // 添加缓存
                 $redis = $this->container->get(Redis::class);
-                $redis_key = "user_im_online" . $user['user_id'];
+                $redis_key = "user_im_online_" . $user['user_id'];
                 $redis->set($redis_key,$msg_data['RequestTime'],30*60);
 
             } elseif ($msg_data['Info']['Action'] == "Disconnect"){
@@ -1045,7 +1045,7 @@ class UserService extends BaseService
 
                 // 删除缓存
                 $redis = $this->container->get(Redis::class);
-                $redis_key = "user_im_online" . $user['user_id'];
+                $redis_key = "user_im_online_" . $user['user_id'];
                 $redis->del($redis_key);
             }