Browse Source

将日志 与 机器人状态详情进行缓存,

hl 3 weeks ago
parent
commit
189e83becf
1 changed files with 5 additions and 5 deletions
  1. 5 5
      src/Interval.js

+ 5 - 5
src/Interval.js

@@ -32,7 +32,7 @@ function reportNodeStatus() {
 
 //定时清理机器人
 function reportDel() {
-    const intervalInMilliseconds = 2000;
+    const intervalInMilliseconds = 1000 * 5;
     setInterval(() => {
         // logger.info('当前1',robot.appMap);
         robot.appMap.forEach((value, key) => {
@@ -78,7 +78,7 @@ function reportSearchPositions() {//DOTO node 代码修改完毕,待测试
 // 2秒一次对正在运行的,服务器进行余额比对,发生变化则上报
 function reportAmount() {
     // 设置定时器,每隔一定时间(比如每隔5秒)发送一次GET请求
-    const intervalInMilliseconds = 1000;
+    const intervalInMilliseconds = 1000 * 3 + 500;
     setInterval(() => {
         // logger.info('当前2',robot.appMap);
         robot.appMap.forEach((value, key) => {
@@ -96,7 +96,7 @@ function reportAmount() {
 // 问题: http请求过多,加上请求耗时,容易造成拥堵,所以开启线程异步缓存 机器人程序日志,机器人状态详情信息,http直接返回数据
 function cacheLogs() {
     // 设置定时器,每隔一定时间(比如每隔5秒)发送一次GET请求
-    const intervalInMilliseconds = 1000 * 5;
+    const intervalInMilliseconds = 1000 * 3;
     setInterval(() => {
         // logger.info('当前2',robot.appMap);
         robot.appMap.forEach((value, key) => {
@@ -140,7 +140,7 @@ function cacheLogs() {
 
 function cachePredictorState() {
     // 设置定时器,每隔一定时间(比如每隔5秒)发送一次GET请求
-    const intervalInMilliseconds = 1500*2;
+    const intervalInMilliseconds = 1500 * 4;
     setInterval(() => {
         // logger.info('当前2',robot.appMap);
         var config = getRustConfig()
@@ -156,7 +156,7 @@ function cachePredictorState() {
                 var accUrl = "http://127.0.0.1:" + port
                 http.request_get_timeout(`${accUrl}/predictor_state`, {...config.headers})
                     .then((data) => {
-                        if(data.length < 50){
+                        if (data.length < 50) {
                             logger.info(`可能出错的data~~: ${data}`)
                         }
                         value.predictorState = JSON.parse(data)