From eeb06d26c092d12b42d5b450afdbf002fec1795f Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Mon, 15 Mar 2021 20:12:17 +0800
Subject: [PATCH] 优化扫块速度

---
 src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java |   22 ++++++----------------
 1 files changed, 6 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java
index a0a266a..9a58a36 100644
--- a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java
+++ b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java
@@ -32,24 +32,14 @@
 
     @Resource
     RedisUtils redisUtils;
+
     /**
      * TRC20_USDT 同步
      */
     @Scheduled(cron = "0/3 * * * * ? ")
     public void usdtTc20Update() {
-        // 需要加锁
-        boolean lock = redisUtils.setNotExist("USDT_TRC20_UPDATE", 1, 30);
-        if(lock){
-            try{
-                trxUsdtUpdateService.monitorCoinListener();
-            } catch (Exception e){
-                e.printStackTrace();
-            }finally {
-                // 若异常 需要删除
-                redisUtils.del("USDT_TRC20_UPDATE");
-            }
-        }
-
+        // 波场3秒出一个块
+        trxUsdtUpdateService.monitorCoinListener();
     }
 
     /**
@@ -77,17 +67,17 @@
         blockCoinService.updateBtcUsdt();
     }
 
-//    @Scheduled(cron = "0 3/20 * * * ? ")
+    //    @Scheduled(cron = "0 3/20 * * * ? ")
     public void btcUpdate() {
         blockCoinService.updateBtc();
     }
 
-//    @Scheduled(cron = "0 4/20 * * * ? ")
+    //    @Scheduled(cron = "0 4/20 * * * ? ")
     public void eosUpdate() {
         blockCoinService.updateEos();
     }
 
-//    @Scheduled(cron = "0 6/20 * * * ? ")
+    //    @Scheduled(cron = "0 6/20 * * * ? ")
     public void xrpUpdate() {
         blockCoinService.updateXrp();
     }

--
Gitblit v1.9.1