内部使用oa后台

app/Console/Commands/WebSocketServer.php

@@ -2,6 +2,7 @@
 
 namespace App\Console\Commands;
 
+use Illuminate\Support\Facades\Redis;
 use Ratchet\MessageComponentInterface;
 use Ratchet\ConnectionInterface;
 use Ratchet\Server\IoServer;
@@ -51,9 +52,9 @@ class WebSocketServer extends Command
                         {
                             echo "Message from {$from->resourceId}: $msg\n";
                             foreach ($this->server->clients as $client) {
-                                if ($from !== $client) {
-                                    $client->send($msg);
-                                }
+                                $queueName = 'log_queue'; // 队列名称
+                                $logData = Redis::lpop($queueName);
+                                $client->send($logData);
                             }
                         }
 

app/Http/Controllers/Api/TestController.php

@@ -76,15 +76,15 @@ die;
                 'tag' => $request['tag'],
                 'timestamp' => time(),
             ];
-            $webSocketServer = new WebSocketServer();
-            $webSocketServer->pushMessageToClients(json_encode($logData));
+//            $webSocketServer = new WebSocketServer();
+//            $webSocketServer->pushMessageToClients(json_encode($logData));
 //            $this->webSocketServer->pushMessageToClients(json_encode($logData));
 //            foreach ($this->clients as $client) {
 //                $client->send(json_encode($logData));
 //            }
 //            broadcast(new MessageSent(json_encode($logData)))->toOthers();
             // 推送数据到 Redis 队列
-//            Redis::rpush($queueName, json_encode($logData));
+            Redis::rpush($queueName, json_encode($logData));
 
 
         }