feat: diff spi properties

Author: kevinten10

sdk-component/src/main/java/group/rxcloud/capa/component/configstore/CapaConfigStoreBuilder.java

@@ -87,7 +87,7 @@ public CapaConfigStore build() {
     private CapaConfigStore buildCapaConfigStore() {
         // load spi capa config store impl
         try {
-            Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.get();
+            Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.apply("configuration");
             String capaConfigStoreClassPath = properties.getProperty(CapaConfigStore.class.getName());
             Class<? extends CapaConfigStore> aClass = (Class<? extends CapaConfigStore>) Class.forName(capaConfigStoreClassPath);
             Constructor<? extends CapaConfigStore> constructor = aClass.getConstructor(CapaObjectSerializer.class);

sdk-component/src/main/java/group/rxcloud/capa/component/http/CapaHttpBuilder.java

@@ -108,7 +108,7 @@ private CapaHttp buildCapaHttp() {
 
         // load spi capa http impl
         try {
-            Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.get();
+            Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.apply("rpc");
             String capaHttpClassPath = properties.getProperty(CapaHttp.class.getName());
             Class<? extends CapaHttp> aClass = (Class<? extends CapaHttp>) Class.forName(capaHttpClassPath);
             Constructor<? extends CapaHttp> constructor = aClass.getConstructor(OkHttpClient.class, CapaObjectSerializer.class);

sdk-infrastructure/src/main/java/group/rxcloud/capa/infrastructure/config/CapaProperties.java

@@ -20,10 +20,15 @@
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.nio.charset.StandardCharsets;
+import java.util.Map;
+import java.util.Objects;
 import java.util.Properties;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Function;
 import java.util.function.Supplier;
 
-import static group.rxcloud.capa.infrastructure.constants.CapaConstants.Properties.CAPA_COMPONENT_PROPERTIES;
+import static group.rxcloud.capa.infrastructure.constants.CapaConstants.Properties.CAPA_COMPONENT_PROPERTIES_PREFIX;
+import static group.rxcloud.capa.infrastructure.constants.CapaConstants.Properties.CAPA_COMPONENT_PROPERTIES_SUFFIX;
 
 /**
  * Global properties for Capa's SDK, using Supplier so they are dynamically resolved.
@@ -53,23 +58,26 @@ public abstract class CapaProperties {
     public static final Supplier<Integer> HTTP_CLIENT_READ_TIMEOUT_SECONDS = () -> DEFAULT_HTTP_CLIENT_READTIMEOUTSECONDS;
 
     /**
-     * Capa's component properties.
+     * Capa's component properties cache map.
      */
-    private static final Properties COMPONENT_PROPERTIES = loadCapaComponentProperties();
+    private static final Map<String, Properties> COMPONENT_PROPERTIES_MAP = new ConcurrentHashMap<>();
 
     /**
      * Capa's component properties.
      */
-    public static final Supplier<Properties> COMPONENT_PROPERTIES_SUPPLIER = () -> COMPONENT_PROPERTIES;
+    public static final Function<String, Properties> COMPONENT_PROPERTIES_SUPPLIER = (componentDomain) ->
+            COMPONENT_PROPERTIES_MAP.computeIfAbsent(componentDomain, s -> loadCapaComponentProperties(componentDomain));
 
-    private static Properties loadCapaComponentProperties() {
-        try (InputStream in = CapaProperties.class.getResourceAsStream(CAPA_COMPONENT_PROPERTIES)) {
+    private static Properties loadCapaComponentProperties(final String componentDomain) {
+        Objects.requireNonNull(componentDomain, "componentDomain not found.");
+        final String fileName = CAPA_COMPONENT_PROPERTIES_PREFIX + componentDomain.toLowerCase() + CAPA_COMPONENT_PROPERTIES_SUFFIX;
+        try (InputStream in = CapaProperties.class.getResourceAsStream(fileName)) {
             InputStreamReader inputStreamReader = new InputStreamReader(in, StandardCharsets.UTF_8);
             Properties properties = new Properties();
             properties.load(inputStreamReader);
             return properties;
         } catch (IOException e) {
-            throw new IllegalArgumentException(CAPA_COMPONENT_PROPERTIES + " file not found.");
+            throw new IllegalArgumentException(fileName + " file not found.");
         }
     }
 }

sdk-infrastructure/src/main/java/group/rxcloud/capa/infrastructure/constants/CapaConstants.java

@@ -27,6 +27,7 @@ interface Environments {
 
     interface Properties {
 
-        String CAPA_COMPONENT_PROPERTIES = "/capa-component.properties";
+        String CAPA_COMPONENT_PROPERTIES_PREFIX = "/capa-component-";
+        String CAPA_COMPONENT_PROPERTIES_SUFFIX = ".properties";
     }
 }

sdk-spi/src/main/java/group/rxcloud/capa/spi/config/CapaSpiProperties.java

@@ -35,7 +35,7 @@ public abstract class CapaSpiProperties {
     public static CapaSpiOptionsLoader getSpiOptionsLoader() {
         // load spi capa http impl
         try {
-            Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.get();
+            Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.apply("rpc");
             String classPath = properties.getProperty(CapaSpiOptionsLoader.class.getName());
             Class<? extends CapaSpiOptionsLoader> aClass = (Class<? extends CapaSpiOptionsLoader>) Class.forName(classPath);
             Constructor<? extends CapaSpiOptionsLoader> constructor = aClass.getConstructor();