创建索引时新增公平锁

src/main/java/com/qniao/iot/IotMonitoringDataJob.java

@@ -46,6 +46,7 @@ import java.sql.Date;
 import java.time.*;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.locks.ReentrantLock;
 
 @Slf4j
 public class IotMonitoringDataJob {
@@ -67,6 +68,8 @@ public class IotMonitoringDataJob {
                 return requestConfigBuilder;
             }));
 
+    private static final ReentrantLock lock = new ReentrantLock(true);
+
     /**
      * 当前索引日期后缀
      */
@@ -445,6 +448,7 @@ public class IotMonitoringDataJob {
         try {
             boolean exists = restHighLevelClient.indices().exists(exist, RequestOptions.DEFAULT);
             if (!exists) {
+                lock.lock();
                 // 创建索引
                 CreateIndexRequest request = new CreateIndexRequest(indicesName);
                 // 字段映射
@@ -502,6 +506,8 @@ public class IotMonitoringDataJob {
             }
         } catch (Exception e) {
             e.printStackTrace();
+        }finally {
+            lock.unlock();
         }
     }
 }