feat(sermant-springboot-registry): 添加 Nacos 注册中心支持

- 新增 NacosRegisterConfig 类用于配置 Nacos 相关参数
- 实现 NacosDiscoveryClient 类以支持 Nacos服务发现和注册
- 添加 NacosServiceManager 类用于管理 Nacos 服务
- 实现 NacosInstanceListenable 类以监听 Nacos 实例变化
- 新增 NacosWeightRandomRule 类用于 Nacos 权重随机负载均衡
- 更新配置文件和资源文件以支持 Nacos

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

sermant-plugins/sermant-springboot-registry/config/config.yaml

@@ -9,6 +9,8 @@ sermant.springboot.registry:
   enableRequestCount: false
 
 sermant.springboot.registry.lb:
+  # The type of the registry center, currently supports Nacos and Zookeeper
+  registryCenterType:
   # The load balancer type currently supports RoundRobin、Random、WeightedResponseTime、
   # BestAvailable(Minimum number of concurrent transactions)
   lbType: RoundRobin
@@ -28,3 +30,12 @@ sermant.springboot.registry.lb:
   # For retry scenarios, for {@link java.util.concurrent.TimeoutException}, whether you need to retry, which is enabled
   # by default, and this timeout is mostly used in asynchronous scenarios, such as Future, MinimalHttpAsyncClient
   enableTimeoutExRetry: true
+
+
+nacos.service:
+  username: "nacos" # nacos验证账户
+  password: "nacos" # nacos的验证密码
+  namespace: "sermant" # 命名空间，nacos配置创建命名空间的id值
+  weight: 1 # 服务实例权重值
+  clusterName: DEFAULT # 集群名称
+  ephemeral: true # 是否是临时节点，true为是，false为否

sermant-plugins/sermant-springboot-registry/springboot-registry-plugin/src/main/java/io/sermant/discovery/config/NacosRegisterConfig.java

@@ -0,0 +1,349 @@
+package io.sermant.discovery.config;
+
+import io.sermant.core.config.ConfigManager;
+import io.sermant.core.config.common.ConfigTypeKey;
+import io.sermant.core.plugin.config.PluginConfig;
+import io.sermant.core.plugin.config.PluginConfigManager;
+import io.sermant.core.plugin.config.ServiceMeta;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Properties;
+
+/**
+ * nacos注册插件配置
+ *
+ * @author xiaozhao
+ * @since 2024-11-16
+ */
+@ConfigTypeKey(value = "nacos.service")
+public class NacosRegisterConfig implements PluginConfig {
+    /**
+     * 默认拉取间隔时间
+     */
+    private static final long DEFAULT_NOTIFY_DELAY = 5000L;
+
+    /**
+     * 默认监控时间
+     */
+    private static final long DEFAULT_LOOKUP_INTERVAL = 30L;
+
+    /**
+     * 默认数据页大小
+     */
+    private static final int DEFAULT_PAGINATION_SIZE = 100;
+
+    /**
+     * spring cloud zone
+     * 若未配置默认使用系统环境变量的zone, 即spring.cloud.loadbalancer.zone
+     */
+    private String zone;
+
+    /**
+     * 是否加密
+     */
+    private boolean secure = false;
+
+    /**
+     * nacos认证账户
+     */
+    private String username;
+
+    /**
+     * nacos认证密码
+     */
+    private String password;
+
+    /**
+     * 节点地址
+     */
+    private String endpoint = "";
+
+    /**
+     * 命名空间
+     */
+    private String namespace;
+
+    /**
+     * nacos日志文件名
+     */
+    private String logName;
+
+    /**
+     * 服务实例权重
+     */
+    private float weight = 1f;
+
+    /**
+     * 集群名称
+     */
+    private String clusterName = "DEFAULT";
+
+    /**
+     * 组
+     */
+    private String group = "DEFAULT_GROUP";
+
+    /**
+     * 启动时是否加载缓存
+     */
+    private String namingLoadCacheAtStart = "false";
+
+    /**
+     * 命名空间AK
+     */
+    private String accessKey;
+
+    /**
+     * 命名空间SK
+     */
+    private String secretKey;
+
+    /**
+     * 实例是否可用
+     */
+    private boolean instanceEnabled = true;
+
+    /**
+     * 是否临时节点
+     */
+    private boolean ephemeral = true;
+
+    /**
+     * 实例元数据
+     */
+    private Map<String, String> metadata = new HashMap<>();
+
+    /**
+     * 是否快速失败取缓存数据，false为不取，直接失败
+     */
+    private boolean failureToleranceEnabled = false;
+
+    /**
+     * 服务名分隔符
+     */
+    private String serviceNameSeparator = ":";
+
+    /**
+     * 数据页大小
+     */
+    private int paginationSize = DEFAULT_PAGINATION_SIZE;
+
+    /**
+     * 监控时间
+     */
+    private long lookupInterval = DEFAULT_LOOKUP_INTERVAL;
+
+    /**
+     * 唤醒延时时间
+     */
+    private long notifyDelay = DEFAULT_NOTIFY_DELAY;
+
+    /**
+     * 构造方法
+     */
+    public NacosRegisterConfig() {
+        final ServiceMeta serviceMeta = ConfigManager.getConfig(ServiceMeta.class);
+        if (serviceMeta == null) {
+            return;
+        }
+        zone = serviceMeta.getZone();
+        group = serviceMeta.getApplication();
+    }
+
+    public String getZone() {
+        return zone;
+    }
+
+    public void setZone(String zone) {
+        this.zone = zone;
+    }
+
+    public boolean isSecure() {
+        return secure;
+    }
+
+    public void setSecure(boolean secure) {
+        this.secure = secure;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+    public String getEndpoint() {
+        return endpoint;
+    }
+
+    public void setEndpoint(String endpoint) {
+        this.endpoint = endpoint;
+    }
+
+    public String getNamespace() {
+        return namespace;
+    }
+
+    public void setNamespace(String namespace) {
+        this.namespace = namespace;
+    }
+
+    public String getLogName() {
+        return logName;
+    }
+
+    public void setLogName(String logName) {
+        this.logName = logName;
+    }
+
+    public float getWeight() {
+        return weight;
+    }
+
+    public void setWeight(float weight) {
+        this.weight = weight;
+    }
+
+    public String getClusterName() {
+        return clusterName;
+    }
+
+    public void setClusterName(String clusterName) {
+        this.clusterName = clusterName;
+    }
+
+    public String getGroup() {
+        return group;
+    }
+
+    public void setGroup(String group) {
+        this.group = group;
+    }
+
+    public String getNamingLoadCacheAtStart() {
+        return namingLoadCacheAtStart;
+    }
+
+    public void setNamingLoadCacheAtStart(String namingLoadCacheAtStart) {
+        this.namingLoadCacheAtStart = namingLoadCacheAtStart;
+    }
+
+    public String getAccessKey() {
+        return accessKey;
+    }
+
+    public void setAccessKey(String accessKey) {
+        this.accessKey = accessKey;
+    }
+
+    public String getSecretKey() {
+        return secretKey;
+    }
+
+    public void setSecretKey(String secretKey) {
+        this.secretKey = secretKey;
+    }
+
+    public boolean isInstanceEnabled() {
+        return instanceEnabled;
+    }
+
+    public void setInstanceEnabled(boolean instanceEnabled) {
+        this.instanceEnabled = instanceEnabled;
+    }
+
+    public boolean isEphemeral() {
+        return ephemeral;
+    }
+
+    public void setEphemeral(boolean ephemeral) {
+        this.ephemeral = ephemeral;
+    }
+
+    public Map<String, String> getMetadata() {
+        return metadata;
+    }
+
+    public void setMetadata(Map<String, String> metadata) {
+        this.metadata = metadata;
+    }
+
+    public boolean isFailureToleranceEnabled() {
+        return failureToleranceEnabled;
+    }
+
+    public void setFailureToleranceEnabled(boolean failureToleranceEnabled) {
+        this.failureToleranceEnabled = failureToleranceEnabled;
+    }
+
+    public String getServiceNameSeparator() {
+        return serviceNameSeparator;
+    }
+
+    public void setServiceNameSeparator(String serviceNameSeparator) {
+        this.serviceNameSeparator = serviceNameSeparator;
+    }
+
+    public int getPaginationSize() {
+        return paginationSize;
+    }
+
+    public void setPaginationSize(int paginationSize) {
+        this.paginationSize = paginationSize;
+    }
+
+    public long getLookupInterval() {
+        return lookupInterval;
+    }
+
+    public void setLookupInterval(long lookupInterval) {
+        this.lookupInterval = lookupInterval;
+    }
+
+    public long getNotifyDelay() {
+        return notifyDelay;
+    }
+
+    public void setNotifyDelay(long notifyDelay) {
+        this.notifyDelay = notifyDelay;
+    }
+
+    /**
+     * 获取配置参数
+     *
+     * @return 配置
+     */
+    public Properties getNacosProperties() {
+        LbConfig lbConfig = PluginConfigManager.getPluginConfig(LbConfig.class);
+        Properties properties = new Properties();
+        properties.put(PropertyKeyConst.SERVER_ADDR, lbConfig.getRegistryAddress());
+        properties.put(PropertyKeyConst.USERNAME, Objects.toString(username, ""));
+        properties.put(PropertyKeyConst.PASSWORD, Objects.toString(password, ""));
+        properties.put(PropertyKeyConst.NAMESPACE, Objects.toString(namespace, ""));
+        properties.put(PropertyKeyConst.NACOS_NAMING_LOG_NAME, Objects.toString(logName, ""));
+        if (endpoint.contains(PropertyKeyConst.HTTP_URL_COLON)) {
+            int index = endpoint.indexOf(PropertyKeyConst.HTTP_URL_COLON);
+            properties.put(PropertyKeyConst.ENDPOINT, endpoint.substring(0, index));
+            properties.put(PropertyKeyConst.ENDPOINT_PORT, endpoint.substring(index + 1));
+        } else {
+            properties.put(PropertyKeyConst.ENDPOINT, endpoint);
+        }
+        properties.put(PropertyKeyConst.ACCESS_KEY, Objects.toString(accessKey, ""));
+        properties.put(PropertyKeyConst.SECRET_KEY, Objects.toString(secretKey, ""));
+        properties.put(PropertyKeyConst.CLUSTER_NAME, clusterName);
+        properties.put(PropertyKeyConst.NAMING_LOAD_CACHE_AT_START, namingLoadCacheAtStart);
+        return properties;
+    }
+}