[fit] 增加Registry port、IP信息的动态获取

Author: mikeaaaaaa

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

@@ -13,6 +13,7 @@
 import modelengine.fitframework.annotation.Component;
 import modelengine.fitframework.broker.Endpoint;
 import modelengine.fitframework.broker.Target;
+import modelengine.fitframework.conf.runtime.CommunicationProtocol;
 import modelengine.fitframework.conf.runtime.MatataConfig;
 import modelengine.fitframework.conf.runtime.WorkerConfig;
 import modelengine.fitframework.log.Logger;
@@ -41,25 +42,41 @@ public class AddressRepository implements RegistryLocator {
      * @param servers 表示 FIT 的服务器的列表的 {@link List}{@code <}{@link FitServer}{@code >}。
      * @param worker 表示进程配置的 {@link WorkerConfig}。
      * @param matata 表示 matata 配置的 {@link MatataConfig}。
+     * @param fitServer 表示 FIT 服务器的 {@link FitServer}。
      */
-    public AddressRepository(List<FitServer> servers, WorkerConfig worker, MatataConfig matata) {
+    public AddressRepository(List<FitServer> servers, WorkerConfig worker, MatataConfig matata, FitServer fitServer) {
         List<FitServer> actualServers = ObjectUtils.getIfNull(servers, Collections::emptyList);
         notNull(worker, "The worker config cannot be null.");
         notNull(matata, "The matata config cannot be null.");
+        notNull(fitServer, "The fitserver cannot be null.");
+        int port = matata.registry().port();
+        int protocolCode = matata.registry().protocolCode();
+        CommunicationProtocol protocol = matata.registry().protocol();
+        if(0 == port){
+            Endpoint endpoint = fitServer.endpoints().stream().findFirst().orElse(null);
+            notNull(endpoint, "The fit server must have at least one endpoint.");
+            port = endpoint.port();
+            protocolCode = endpoint.protocolCode();
+            protocol = CommunicationProtocol.from(endpoint.protocol());
+        }
+        String host = matata.registry().host();
+        if(StringUtils.isBlank(matata.registry().host())) {
+            host = worker.host();
+        }
         boolean isRegistryLocalhost = isRegistryLocalhost(actualServers,
                 worker.host(),
                 worker.domain(),
-                matata.registry().host(),
-                matata.registry().port(),
-                matata.registry().protocolCode());
+                host,
+                port,
+                protocolCode);
         String registryWorkerId =
-                isRegistryLocalhost ? worker.id() : matata.registry().host() + ":" + matata.registry().port();
+                isRegistryLocalhost ? worker.id() : host + ":" + port;
         this.registryTarget = Target.custom()
                 .workerId(registryWorkerId)
-                .host(matata.registry().host())
+                .host(host)
                 .endpoints(Collections.singletonList(Endpoint.custom()
-                        .port(matata.registry().port())
-                        .protocol(matata.registry().protocol().name(), matata.registry().protocolCode())
+                        .port(port)
+                        .protocol(protocol.name(), protocolCode)
                         .build()))
                 .environment(matata.registry().environment())
                 .extensions(matata.registry().visualExtensions())
@@ -68,7 +85,7 @@ public AddressRepository(List<FitServer> servers, WorkerConfig worker, MatataCon
     }
 
     private static boolean isRegistryLocalhost(List<FitServer> servers, String localHost, String localDomain,
-            String registryHost, int registryPort, int registryProtocol) {
+                                               String registryHost, int registryPort, int registryProtocol) {
         if (!isRegistryHost(localHost, localDomain, registryHost)) {
             return false;
         }

framework/fit/java/fit-runtime/src/main/resources/fitframework.yml

@@ -11,9 +11,9 @@ worker:
 
 matata:
   registry:
-    host: 'localhost' # 默认连接的注册中心为本地
-    port: 8080 # 默认连接注册中心的端口为本地默认的 8080 端口
-    protocol: 2 # 注册中心默认使用 Http 的传输协议
+#    host: 'localhost' # 默认连接的注册中心为本地
+#    port: 8080 # 默认连接注册中心的端口为本地默认的 8080 端口
+#    protocol: 2 # 注册中心默认使用 Http 的传输协议
     environment: 'local' # 默认注册中心的环境标和本地默认配置一致
     available-services: # 将注册中心和获取地址相关的服务进行配置，其他服务都可以通过以下服务进行地址获取
     # 订阅服务并获取所订阅服务地址的接口