add Number of messages WS queue shuold hold, default 100

README.md

@@ -404,6 +404,9 @@ $huobi->config([
     //Channel data update time,default 0.5 seconds
     //'data_time'=>0.5,
 
+    //Number of messages WS queue shuold hold, default 100
+    //'queue_count'=>100,
+
     //Set up subscription platform, default 'spot'
     'platform'=>'spot', //options value 'spot' 'future' 'swap' 'linear' 'option'
     //Or you can set it like this
@@ -445,6 +448,9 @@ $huobi->config([
     //Channel data update time,default 0.5 seconds
     //'data_time'=>0.5,
 
+    //Number of messages WS queue shuold hold, default 100
+    //'queue_count'=>100,
+
     //Set up subscription platform, default 'spot'
     'platform'=>'spot', //options value 'spot' 'future' 'swap' 'linear' 'option'
     //Or you can set it like this

README_CN.md

@@ -399,6 +399,9 @@ $huobi->config([
     //频道数据更新时间,默认 0.5 秒
     //'data_time'=>0.5,
 
+    //私有数据队列默认保存100条
+    //'queue_count'=>100,
+
     //设置订阅平台, 默认 'spot'
     'platform'=>'spot', //参数值为 'spot' 'future' 'swap' 'linear' 'option'
     //或者也可以这样更灵活的设置
@@ -438,6 +441,9 @@ $huobi->config([
     //频道数据更新时间,默认 0.5 秒
     //'data_time'=>0.5,
 
+    //私有数据队列默认保存100条
+    //'queue_count'=>100,
+
     //设置订阅平台, 默认 'spot'
     'platform'=>'spot', //参数值为 'spot' 'future' 'swap' 'linear' 'option'
     //或者也可以这样更灵活的设置

src/Api/WebSocket/SocketGlobal.php

@@ -92,7 +92,7 @@ protected function getQueue($key){
      */
     protected function saveQueue($key,$value){
         //最大存储数据量，超过后保留一条最新的数据，其余数据全部删除。
-        $max=100;
+        $max= isset($this->config['queue_count']) ? $this->config['queue_count'] : 100;
 
         if(!isset($this->client->$key)) $this->add($key,[$value]);
         else {

tests/websocket/client_future.php

@@ -269,15 +269,7 @@
     }
 
     case 10005:{
-        $huobi->keysecret($key_secret[1]);
-        $huobi->subscribe();
-        break;
-    }
-
-    //subscribe
-    case 10006:{
-        $huobi->keysecret($key_secret[0]);
-        $huobi->subscribe();
+        $huobi->client()->test_reconnection();
         break;
     }
 }

tests/websocket/client_spot.php

@@ -230,6 +230,11 @@
         $huobi->client()->test2();
         break;
     }
+
+    case 10005:{
+        $huobi->client()->test_reconnection();
+        break;
+    }
 }