fix

console/controllers/WorkermanWebSocketController.php

@@ -77,10 +77,10 @@ class WorkermanWebSocketController extends Controller
 
 
         // 进程启动后设置一个每秒运行一次的定时器
-        $wsWorker->onWorkerStart = function($worker) {
-            \Workerman\Lib\Timer::add(1, function()use($worker){
+        $wsWorker->onWorkerStart = function ($worker) {
+            \Workerman\Lib\Timer::add(1, function () use ($worker) {
                 $time_now = time();
-                foreach($worker->connections as $connection) {
+                foreach ($worker->connections as $connection) {
                     // 有可能该connection还没收到过消息，则lastMessageTime设置为当前时间
                     if (empty($connection->lastMessageTime)) {
                         $connection->lastMessageTime = $time_now;
@@ -95,13 +95,7 @@ class WorkermanWebSocketController extends Controller
         };
 
         // Emitted when data received
-        $wsWorker->onMessage = function ($connection, $data) use ($wsWorker, $uids) {
-            if (!isset($connection->uid)) {
-                $connection->lastMessageTime = time();
-                $connection->uid = $data;
-                $wsWorker->uidConnections[$connection->uid] = $connection;
-                echo $connection->uid . ' 一共 ' . count($wsWorker->uidConnections[$connection->uid]) . PHP_EOL;
-            }
+        $wsWorker->onMessage = function ($connection, $data) {
             if ('binance' == $data) {
                 $con = new \Workerman\Connection\AsyncTcpConnection("ws://stream.binance.com:9443/ws/!ticker@arr");
                 $con->transport = 'ssl';
@@ -176,17 +170,6 @@ class WorkermanWebSocketController extends Controller
                     } else {
                     }
                 };
-                $con->onClose = function ($con) use ($wsWorker) {
-                    echo $con->id,"connection closed\n";
-                    if(isset($con->uid))
-                    {
-                        // 连接断开时删除映射
-                        unset($wsWorker->uidConnections[$con->uid]);
-                    }
-                };
-                $con->onError = function ($con, $code, $msg) {
-                    echo "Error code:$code msg:$msg\n";
-                };
                 $con->connect();
             } elseif ('okex' == $data) {
                 $connection->websocketType = Websocket::BINARY_TYPE_ARRAYBUFFER;