ws替换EventSource

web/ws_task_real.php

@@ -12,7 +12,6 @@ ob_implicit_flush(1);
 
 use app\common\dm\Dm;
 use app\common\logic\PassFlow;
-require_once __DIR__ . '/workman/vendor/autoload.php';
 require_once __DIR__ . '../../source/application/common/dm/Dm.php';
 require_once __DIR__ . '../../source/application/common/logic/PassFlow.php';
 require_once __DIR__ . '../../source/thinkphp/helper.php';

web/ws_task_real_ty.php

@@ -2,11 +2,17 @@
 /**
  * 体育
  */
-use Workerman\Worker;
+
-use Workerman\Timer;
+
+header("Access-Control-Allow-Origin:*");
+header('X-Accel-Buffering: no');
+header('Content-Type: text/event-stream');
+header('Cache-Control: no-cache');
+ob_end_clean();
+ob_implicit_flush(1);
+
 use app\common\dm\Dm;
 use app\common\logic\PassFlow;
-require_once __DIR__ . '/workman/vendor/autoload.php';
 require_once __DIR__ . '../../source/application/common/dm/Dm.php';
 require_once __DIR__ . '../../source/application/common/logic/PassFlow.php';
 require_once __DIR__ . '../../source/thinkphp/helper.php';
@@ -15,24 +21,11 @@ require_once __DIR__ . '../../source/application/common.php';
 $config = require_once __DIR__ . '../../source/application/database.php';
 
 date_default_timezone_set('Asia/Shanghai');
+$dm = new Dm($config['connections']['dm']);
 
-$worker = new Worker('websocket://0.0.0.0:1235');
+$xh = 0;
-$worker->count = 4;
+while($xh < 1) {
-// 进程启动后定时推送数据给客户端
-$worker->onWorkerStart = function($worker) use($config) {
-    # 数据库链接不能在主进程，方法外是主进程
-    $dm = new Dm($config['connections']['dm']);
-    // 每2.5秒执行一次
-    $time_interval = 3;
-    Timer::add($time_interval, function()use($worker,$dm){
-        foreach($worker->connections as $connection) {
     $data = [];
-            # 主动推送对应页面数据
-
-//            $groupIdArr = [];
-//            $groupRes = $dm->select('bt_passenger_monitor_group',['type' => 1]);
-//            foreach ($groupRes as $groupRow) $groupIdArr[] = $groupRow['groupId'];
-//            $groupIdStr = !empty($groupIdArr) ? implode("|",$groupIdArr) : '';
 
     # 累计服务人数
     $data['allGroupNum'] = ['data' => PassFlow::allGroupNum($dm,['type' => 1])];
@@ -49,8 +42,26 @@ $worker->onWorkerStart = function($worker) use($config) {
     # 各场馆服务人次趋势
     $data['toDayGroupsEnterNum'] = ['data' => PassFlow::toDayGroupsEnterNum($dm,['type' => 1])];
 
-            $connection->send(json_encode($data));
+    $xh = $xh + 1;
+    returnEventData($data,"message",$xh);
+    sleep(3);
+}
+
+function returnEventData($returnData, $event='message', $id=0, $retry=0) {
+    $str = '';
+    if($id>0) {
+        $str .= "id: {$id}".PHP_EOL;
+    }
+    if($event) {
+        $str.= "event: {$event}".PHP_EOL;
+    }
+    if($retry>0) {
+        $str .= "retry: {$retry}".PHP_EOL;
+    }
+    if(is_array($returnData)) {
+        $returnData = json_encode($returnData);
     }
-    });
+    $str .= "data: {$returnData}".PHP_EOL;
-};
+    $str .= PHP_EOL;
-Worker::runAll();
+    echo $str;
+}

web/ws_task_real_wh.php

@@ -2,11 +2,15 @@
 /**
  * 文化
  */
-use Workerman\Worker;
+header("Access-Control-Allow-Origin:*");
-use Workerman\Timer;
+header('X-Accel-Buffering: no');
+header('Content-Type: text/event-stream');
+header('Cache-Control: no-cache');
+ob_end_clean();
+ob_implicit_flush(1);
+
 use app\common\dm\Dm;
 use app\common\logic\PassFlow;
-require_once __DIR__ . '/workman/vendor/autoload.php';
 require_once __DIR__ . '../../source/application/common/dm/Dm.php';
 require_once __DIR__ . '../../source/application/common/logic/PassFlow.php';
 require_once __DIR__ . '../../source/thinkphp/helper.php';
@@ -15,18 +19,12 @@ require_once __DIR__ . '../../source/application/common.php';
 $config = require_once __DIR__ . '../../source/application/database.php';
 
 date_default_timezone_set('Asia/Shanghai');
+$dm = new Dm($config['connections']['dm']);
 
-$worker = new Worker('websocket://0.0.0.0:1236');
+$xh = 0;
-$worker->count = 4;
+while($xh < 1) {
-// 进程启动后定时推送数据给客户端
-$worker->onWorkerStart = function($worker) use($config) {
-    # 数据库链接不能在主进程，方法外是主进程
-    $dm = new Dm($config['connections']['dm']);
-    // 每2.5秒执行一次
-    $time_interval = 3;
-    Timer::add($time_interval, function()use($worker,$dm){
-        foreach($worker->connections as $connection) {
     $data = [];
+
     # 主动推送对应页面数据
 
     # 累计服务人数 - 24小时服务人次
@@ -41,8 +39,26 @@ $worker->onWorkerStart = function($worker) use($config) {
     # 图书馆数据统计
     $data['getLibraryLeaseData'] = ['data' => PassFlow::getLibraryLeaseData($dm)];
 
-            $connection->send(json_encode($data));
+    $xh = $xh + 1;
+    returnEventData($data,"message",$xh);
+    sleep(3);
+}
+
+function returnEventData($returnData, $event='message', $id=0, $retry=0) {
+    $str = '';
+    if($id>0) {
+        $str .= "id: {$id}".PHP_EOL;
+    }
+    if($event) {
+        $str.= "event: {$event}".PHP_EOL;
+    }
+    if($retry>0) {
+        $str .= "retry: {$retry}".PHP_EOL;
+    }
+    if(is_array($returnData)) {
+        $returnData = json_encode($returnData);
     }
-    });
+    $str .= "data: {$returnData}".PHP_EOL;
-};
+    $str .= PHP_EOL;
-Worker::runAll();
+    echo $str;
+}