重命名

custom-gateway-core/src/main/java/com/shkpr/service/customgateway/core/components/InfluxDBRegistry.java

@@ -12,14 +12,14 @@ import java.util.List;
  * @author 欧阳劲驰
  * @since 1.0.0
  */
-public class InfluxDBRegistry {
+public class InfluxDBClients {
     /**
      * 客户端集合
      */
     List<InfluxDbClient> clients;
 
 
-    public InfluxDBRegistry(Builder builder) {
+    public InfluxDBClients(Builder builder) {
         this.clients = builder.clients;
     }
 
@@ -73,11 +73,11 @@ public class InfluxDBRegistry {
         /**
          * 构建
          */
-        public InfluxDBRegistry build() {
+        public InfluxDBClients build() {
             // 参数验证
             if (CollectionUtils.isEmpty(this.clients)) throw new IllegalStateException("客户端不能为空");
 
-            return new InfluxDBRegistry(this);
+            return new InfluxDBClients(this);
         }
     }
 }

custom-gateway-core/src/main/java/com/shkpr/service/customgateway/core/config/InfluxDbConfig.java

@@ -1,6 +1,6 @@
 package com.shkpr.service.customgateway.core.config;
 
-import com.shkpr.service.customgateway.core.components.InfluxDBRegistry;
+import com.shkpr.service.customgateway.core.components.InfluxDBClients;
 import com.shkpr.service.customgateway.core.domain.InfluxDbClient;
 import com.shkpr.service.customgateway.core.io.YamlPropertySourceFactory;
 import com.shkpr.service.customgateway.core.properties.InfluxDbProperties;
@@ -57,7 +57,7 @@ public class InfluxDbConfig {
      * @return influxDb注册器
      */
     @Bean
-    public InfluxDBRegistry influxDBRegistry() {
+    public InfluxDBClients influxDBClients() {
         this.builder.readTimeout(influxDbProperties.getReadTimeout());
         //客户端集合
         List<InfluxDbClient> clients = influxDbProperties.getClients().stream()
@@ -65,7 +65,7 @@ public class InfluxDbConfig {
                         , client.getDatabase(), this.builder))
                 .collect(Collectors.toList());
         //注册
-        return InfluxDBRegistry.builder()
+        return InfluxDBClients.builder()
                 .addClients(clients)
                 .build();
     }

custom-gateway-core/src/main/java/com/shkpr/service/customgateway/core/utils/InfluxDbUtil.java

@@ -3,7 +3,7 @@ package com.shkpr.service.customgateway.core.utils;
 import com.global.base.log.LogLevelFlag;
 import com.global.base.log.LogPrintMgr;
 import com.shkpr.service.customgateway.core.annotation.InfluxDbMapping;
-import com.shkpr.service.customgateway.core.components.InfluxDBRegistry;
+import com.shkpr.service.customgateway.core.components.InfluxDBClients;
 import com.shkpr.service.customgateway.core.constants.LogFlagBusiType;
 import com.shkpr.service.customgateway.core.domain.InfluxDbClient;
 import com.shkpr.service.customgateway.core.properties.InfluxDbProperties;
@@ -39,12 +39,12 @@ public class InfluxDbUtil {
     private static final String CLASS_NAME = "InfluxDbUtil";
     private static final String BIZ_TYPE = LogFlagBusiType.BUSI_ALL.toStrValue();
     final
-    InfluxDBRegistry influxDBRegistry;
+    InfluxDBClients influxDBClients;
     final
     InfluxDbProperties properties;
 
-    public InfluxDbUtil(InfluxDbProperties properties, InfluxDBRegistry influxDBRegistry) {
-        this.influxDBRegistry = influxDBRegistry;
+    public InfluxDbUtil(InfluxDbProperties properties, InfluxDBClients influxDBClients) {
+        this.influxDBClients = influxDBClients;
         this.properties = properties;
     }
 
@@ -97,7 +97,7 @@ public class InfluxDbUtil {
      */
     public Boolean insert(Point point) {
         try {
-            for (InfluxDbClient influxDb : influxDBRegistry.clients()) {
+            for (InfluxDbClient influxDb : influxDBClients.clients()) {
                 influxDb.write(point);
             }
             return true;
@@ -121,7 +121,7 @@ public class InfluxDbUtil {
                     , String.format("开始批量写入InfluxDb,数据量:%d", points.size()));
             long begin = System.currentTimeMillis();
 
-            for (InfluxDbClient influxDb : influxDBRegistry.clients()) {
+            for (InfluxDbClient influxDb : influxDBClients.clients()) {
                 //转批量对象
                 BatchPoints batchPoints = BatchPoints
                         .database(influxDb.getDatabase())
@@ -152,7 +152,7 @@ public class InfluxDbUtil {
      * @return 实体类集合
      */
     public <E> List<E> query(String sql, Class<E> clazz) {
-        InfluxDbClient influxDb = influxDBRegistry.clients().get(0);
+        InfluxDbClient influxDb = influxDBClients.clients().get(0);
         //执行查询
         QueryResult queryResult = influxDb.query(new Query(sql, influxDb.getDatabase()));
         QueryResult.Series series = getSeries(queryResult);