implement apollo dynamic config

Signed-off-by: chenzhenyang <[email protected]>

Author: aaaandychen

pom.xml

@@ -85,6 +85,7 @@
         <nexus.staging.plugin.version>1.6.7</nexus.staging.plugin.version>
         <central.publishing.maven.plugin.version>0.5.0</central.publishing.maven.plugin.version>
         <frontend.plugin.version>1.12.1</frontend.plugin.version>
+        <apollo.version>2.4.0</apollo.version>
 
         <sermant.name>sermant-agent</sermant.name>
         <sermant.basedir>${pom.basedir}</sermant.basedir>

sermant-agentcore/sermant-agentcore-core/src/main/java/io/sermant/core/service/dynamicconfig/common/DynamicConfigServiceType.java

@@ -23,6 +23,11 @@
  * @since 2021-12-27
  */
 public enum DynamicConfigServiceType {
+
+    /**
+     * apollo configuration center
+     */
+    APOLLO,
     /**
      * zookeeper configuration center
      */

sermant-agentcore/sermant-agentcore-implement/pom.xml

@@ -126,6 +126,21 @@
             <artifactId>zookeeper</artifactId>
             <version>${zookeeper.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.ctrip.framework.apollo</groupId>
+            <artifactId>apollo-client</artifactId>
+            <version>${apollo.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.ctrip.framework.apollo</groupId>
+            <artifactId>apollo-openapi</artifactId>
+            <version>${apollo.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.ctrip.framework.apollo</groupId>
+            <artifactId>apollo-core</artifactId>
+            <version>${apollo.version}</version>
+        </dependency>
         <dependency>
             <groupId>com.alibaba.nacos</groupId>
             <artifactId>nacos-client</artifactId>

sermant-agentcore/sermant-agentcore-implement/src/main/java/io/sermant/implement/service/dynamicconfig/BufferedDynamicConfigService.java

@@ -18,6 +18,7 @@
 
 import io.sermant.core.service.dynamicconfig.DynamicConfigService;
 import io.sermant.core.service.dynamicconfig.common.DynamicConfigListener;
+import io.sermant.implement.service.dynamicconfig.apollo.ApolloDynamicConfigService;
 import io.sermant.implement.service.dynamicconfig.kie.KieDynamicConfigService;
 import io.sermant.implement.service.dynamicconfig.nacos.NacosDynamicConfigService;
 import io.sermant.implement.service.dynamicconfig.zookeeper.ZooKeeperDynamicConfigService;
@@ -50,6 +51,9 @@ public BufferedDynamicConfigService() {
             case NACOS:
                 service = new NacosDynamicConfigService();
                 break;
+            case APOLLO:
+                service = new ApolloDynamicConfigService();
+                break;
             default:
                 service = new ZooKeeperDynamicConfigService();
         }

sermant-agentcore/sermant-agentcore-implement/src/main/java/io/sermant/implement/service/dynamicconfig/apollo/ApolloBufferedClient.java

@@ -0,0 +1,76 @@
+/*
+ * Copyright (C) 2025-2025 Sermant Authors. All rights reserved.
+ *
+ *   Licensed under the Apache License, Version 2.0 (the "License");
+ *   you may not use this file except in compliance with the License.
+ *   You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing, software
+ *   distributed under the License is distributed on an "AS IS" BASIS,
+ *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *   See the License for the specific language governing permissions and
+ *   limitations under the License.
+ */
+
+package io.sermant.implement.service.dynamicconfig.apollo;
+
+import com.ctrip.framework.apollo.ConfigChangeListener;
+
+import java.io.Closeable;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+/**
+ * @author Chen Zhenyang
+ * @since 2025/8/7
+ */
+public class ApolloBufferedClient implements Closeable {
+    private static final Logger LOGGER = Logger.getLogger(ApolloBufferedClient.class.getName());
+    private final ApolloClient apolloClient;
+
+    public ApolloBufferedClient() {
+        apolloClient = new ApolloClient();
+    }
+
+    @Override
+    public void close() {
+        try {
+            apolloClient.close();
+        } catch (Exception e) {
+            LOGGER.log(Level.SEVERE, "Apollo close exception, msg is: ", e);
+        }
+    }
+
+    public boolean publishConfig(String key, String group, String content) {
+        return apolloClient.publishConfig(key, group, content);
+    }
+
+    public boolean removeConfig(String key, String group) {
+        return apolloClient.removeConfig(key, group);
+    }
+
+    public List<String> getListKeysFromGroup(String group) {
+        Map<String, List<String>> res = apolloClient.getConfigList(null, group, true);
+        return res.get(group);
+    }
+
+    public String getConfig(String key, String group) {
+        return apolloClient.getConfig(key, group);
+    }
+
+    public boolean addGroupListener(String group, ConfigChangeListener apolloListener) {
+        return apolloClient.addGroupListener(group, apolloListener);
+    }
+
+    public boolean addConfigListener(String key, String group, ConfigChangeListener apolloListener) {
+        return apolloClient.addConfigListener(key, group, apolloListener);
+    }
+
+    public boolean removeConfigListener(String validGroup, ConfigChangeListener ccl) {
+        return apolloClient.removeConfigListener(validGroup, ccl);
+    }
+}