solve the websocket blocking problem

zhouaini528 · Jun 18, 2021 · 8b6fde5 · 8b6fde5
1 parent 2cecd5a
commit 8b6fde5
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 4 deletions.
diff --git a/src/Api/WebSocket/SocketClient.php b/src/Api/WebSocket/SocketClient.php
@@ -41,6 +41,8 @@ protected function init(){
 
         $this->add('keysecret',[]);//目前总共key
 
+        $this->add('global_local',[]);//临时存储数据
+
         $this->add('debug',[]);
     }
 
@@ -121,6 +123,7 @@ protected function getData($global,$callback=null,$sub=[]){
         $all_sub=$global->get('all_sub');
         if(empty($all_sub)) return [];
 
+        $global_local=$global->get('global_local');
         $temp=[];
         //print_r($all_sub);die;
         //默认返回所有数据
@@ -129,7 +132,8 @@ protected function getData($global,$callback=null,$sub=[]){
                 if(is_array($v)) $table=$k;
                 else $table=$v;
 
-                $data=$global->get(strtolower($table));
+                //$data=$global->get(strtolower($table));
+                $data=$global_local['public'][strtolower($table)];
                 if(empty($data)) continue;
                 $temp[$table]=$data;
             }
@@ -148,8 +152,8 @@ protected function getData($global,$callback=null,$sub=[]){
                     $data=$global->getQueue(strtolower($v));
                 }else{
                     //public
-
-                    $data=$global->get(strtolower($v));
+                    //$data=$global->get(strtolower($v));
+                    $data=$global_local['public'][strtolower($v)];
                 }
                 if(empty($data)) continue;
 

diff --git a/src/Api/WebSocket/SocketServer.php b/src/Api/WebSocket/SocketServer.php
@@ -24,6 +24,7 @@ class SocketServer
     private $config=[];
 
     private $public_url=['public','kline'];
+    private $local_global=['public'=>[],'private'=>[]];
 
     function __construct(array $config=[])
     {
@@ -112,7 +113,8 @@ private function onMessage($global){
             if($con->tag=='public'){
                 if(isset($data['table']) && isset($data['data'][0]['symbol'])) {
                     $table=strtolower($data['table'].':'.$data['data'][0]['symbol']);
-                    $global->save($table,$data);
+                    //$global->save($table,$data);
+                    $this->local_global['public'][$table]=$data;
 
                     /*$debug=$global->get('debug2');
                     if($debug==1){
@@ -217,6 +219,11 @@ private function other($con,$global){
                 //private
             }
         });
+
+        //异步保存数据，不然会有阻塞问题。 0.2秒保存一次
+        Timer::add(0.2, function() use($global) {
+            $global->save('global_local',$this->local_global);
+        });
     }
 
     /**