[fit] 统一内存版注册中心和nacos注册中心的配置方式

Author: mikeaaaaaa

examples/fit-example/08-nacos-complicated-apps/app-assistant/src/main/resources/application.yml

@@ -7,8 +7,12 @@ worker:
   environment: 'local'
   environment-sequence: 'local'
 
-nacos:
-  serverAddr: 127.0.0.1:8848
+matata:
+  registry:
+    mode: 'NACOS'
+    host: '127.0.0.1'
+    port: 8848
+    environment: 'local'
 
 server:
   http:

examples/fit-example/08-nacos-complicated-apps/app-default-weather/src/main/resources/application.yml

@@ -7,8 +7,12 @@ worker:
   environment: 'local'
   environment-sequence: 'local'
 
-nacos:
-  serverAddr: 127.0.0.1:8848
+matata:
+  registry:
+    mode: 'NACOS'
+    host: '127.0.0.1'
+    port: 8848
+    environment: 'local'
 
 server:
   http:

framework/fit/java/fit-api/src/main/java/modelengine/fitframework/conf/runtime/MatataConfig.java

@@ -36,6 +36,13 @@ interface Registry {
          */
         String host();
 
+        /**
+         * 获取 {@code 'matata.registry.mode'} 的配置项。
+         *
+         * @return 表示 {@code 'matata.registry.mode'} 的配置项的 {@link RegistryCenterMode}。
+         */
+        RegistryCenterMode mode();
+
         /**
          * 获取 {@code 'matata.registry.port'} 的配置项。
          *
@@ -103,6 +110,8 @@ interface Registry {
          */
         SecureAccess secureAccess();
 
+        Nacos nacos();
+
         /**
          * 表示 {@code 'matata.registry'} 中关于可用服务的配置项。
          */
@@ -198,5 +207,66 @@ interface SecureAccess {
              */
             String secretKey();
         }
+
+        /**
+         * 表示 {@code 'matata.registry.nacos'} 前缀的配置项。
+         */
+        interface Nacos {
+            /**
+             * 获取 {@code 'matata.registry.nacos.username'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.username'} 的配置项的 {@link String}。
+             */
+            String username();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.password'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.password'} 的配置项的 {@link String}。
+             */
+            String password();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.access-key'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.access-key'} 的配置项的 {@link String}。
+             */
+            String accessKey();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.secret-key'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.secret-key'} 的配置项的 {@link String}。
+             */
+            String secretKey();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.is-ephemeral'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.is-ephemeral'} 的配置项的 {@link Boolean}。
+             */
+            Boolean isEphemeral();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.weight'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.weight'} 的配置项的 {@link Float}。
+             */
+            Float weight();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.heartbeat-interval'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.heartbeat-interval'} 的配置项的 {@link Long}。
+             */
+            Long heartbeatInterval();
+
+            /**
+             * 获取 {@code 'matata.registry.nacos.heartbeat-timeout'} 的配置项。
+             *
+             * @return 表示 {@code 'matata.registry.nacos.heartbeat-timeout'} 的配置项的 {@link Long}。
+             */
+            Long heartbeatTimeout();
+        }
     }
 }

framework/fit/java/fit-api/src/main/java/modelengine/fitframework/conf/runtime/RegistryCenterMode.java

@@ -0,0 +1,47 @@
+package modelengine.fitframework.conf.runtime;
+
+import static modelengine.fitframework.inspection.Validation.notBlank;
+
+import modelengine.fitframework.util.StringUtils;
+
+import java.util.Arrays;
+
+/**
+ * 注册中心地址监听模式枚举。
+ *
+ * @author 董智豪
+ * @since 2025-08-04
+ */
+public enum RegistryCenterMode {
+    /** 支持本地内存实现的注册中心。 */
+    MEMORY("MEMORY"),
+
+    /** 支持 Nacos 实现的注册中心。 */
+    NACOS("NACOS"),
+    ;
+
+    /** 注册中心模式标识字符串。 */
+    private final String mode;
+
+    /**
+     * 构造方法，校验并设置注册中心模式标识。
+     *
+     * @param mode 注册中心模式标识字符串
+     */
+    RegistryCenterMode(String mode) {
+        this.mode = notBlank(mode, "The registry center mode cannot be blank.");
+    }
+
+    /**
+     * 根据字符串获取对应的注册中心模式枚举。
+     *
+     * @param mode 注册中心监听模式标识字符串
+     * @return 匹配的 {@link RegistryCenterMode} 枚举常量，未匹配返回 null
+     */
+    public static RegistryCenterMode fromMode(String mode) {
+        return Arrays.stream(RegistryCenterMode.values())
+                .filter(registryCenterMode -> StringUtils.equals(registryCenterMode.mode, mode))
+                .findFirst()
+                .orElse(null);
+    }
+}

framework/fit/java/fit-builtin/plugins/fit-service-coordination-locator/src/main/java/modelengine/fit/service/locator/AddressRepository.java

@@ -16,6 +16,7 @@
 import modelengine.fitframework.broker.Target;
 import modelengine.fitframework.conf.runtime.CommunicationProtocol;
 import modelengine.fitframework.conf.runtime.MatataConfig;
+import modelengine.fitframework.conf.runtime.RegistryCenterMode;
 import modelengine.fitframework.conf.runtime.WorkerConfig;
 import modelengine.fitframework.log.Logger;
 import modelengine.fitframework.util.ObjectUtils;
@@ -53,20 +54,19 @@ public AddressRepository(List<FitServer> servers, WorkerConfig worker, MatataCon
         int port = matata.registry().port();
         int protocolCode = matata.registry().protocolCode();
         CommunicationProtocol protocol = matata.registry().protocol();
-        if (port == 0) {
-            log.debug("The registry port is not set, using the first endpoint of the fit server.");
+        String host = matata.registry().host();
+
+        if(matata.registry().mode() != null && RegistryCenterMode.NACOS.equals(matata.registry().mode())) {
+            log.debug("The registry mode is Nacos, using the local proxy registry center.");
             int size = fitServer.endpoints().size();
             greaterThan(size, 0, "The fit server must have at least one endpoint.");
             Endpoint endpoint = fitServer.endpoints().get(0);
             port = endpoint.port();
             protocolCode = endpoint.protocolCode();
             protocol = CommunicationProtocol.from(endpoint.protocol());
-        }
-        String host = matata.registry().host();
-        if (StringUtils.isBlank(matata.registry().host())) {
-            log.debug("The registry host is not set, using the worker host.");
             host = worker.host();
         }
+
         boolean isRegistryLocalhost =
                 isRegistryLocalhost(actualServers, worker.host(), worker.domain(), host, port, protocolCode);
         String registryWorkerId = isRegistryLocalhost ? worker.id() : host + ":" + port;