add Number of messages WS queue shuold hold, default 100

zhouaini528 · Jan 26, 2021 · 2ab1f54 · 2ab1f54
1 parent ce2d4f5
commit 2ab1f54
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -529,6 +529,9 @@ $okex->config([
 
     //Channel data update time,0.1 seconds
     //'data_time'=>0.1,
+
+    //Number of messages WS queue shuold hold, default 100
+    //'queue_count'=>100,
 ]);
 
 $okex->start();
@@ -561,6 +564,9 @@ $okex->config([
 
     //Channel data update time,0.1 seconds
     //'data_time'=>0.1,
+
+    //Number of messages WS queue shuold hold, default 100
+    //'queue_count'=>100,
 ]);
 ```
 

diff --git a/README_CN.md b/README_CN.md
@@ -527,6 +527,9 @@ $okex->config([
 
     //频道数据更新时间,默认 0.1 秒
     //'data_time'=>0.1,
+
+    //私有数据队列默认保存100条
+    //'queue_count'=>100,
 ]);
 
 $okex->start();
@@ -560,6 +563,9 @@ $okex->config([
 
     //频道数据更新时间,默认 0.1 秒
     //'data_time'=>0.1,
+
+    //私有数据队列默认保存100条
+    //'queue_count'=>100,
 ]);
 ```
 

diff --git a/src/Api/WebSocket/SocketGlobal.php b/src/Api/WebSocket/SocketGlobal.php
@@ -70,7 +70,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 {