diff --git a/app/Console/Commands/NodeWebSocketServer.php b/app/Console/Commands/NodeWebSocketServer.php
index 8ee7745..bafaccf 100644
--- a/app/Console/Commands/NodeWebSocketServer.php
+++ b/app/Console/Commands/NodeWebSocketServer.php
@@ -184,7 +184,15 @@ class NodeWebSocketServer extends Command
     {
         $host = config('database.redis.default.host', '127.0.0.1');
         $port = config('database.redis.default.port', 6379);
-        $redis = new \Workerman\Redis\Client("redis://{$host}:{$port}");
+
+        // Handle Unix Socket connection
+        if (str_starts_with($host, '/')) {
+            $redisUri = "unix://{$host}";
+        } else {
+            $redisUri = "redis://{$host}:{$port}";
+        }
+
+        $redis = new \Workerman\Redis\Client($redisUri);
 
         $password = config('database.redis.default.password');
         if ($password) {