feat: support use database as a registry

apollo-adminservice/src/main/resources/application-database-discovery.properties

@@ -0,0 +1,22 @@
+#
+# Copyright 2022 Apollo Authors
+#
+# 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.
+#
+eureka.client.enabled=false
+spring.cloud.discovery.enabled=false
+
+apollo.service.registry.enabled=true
+apollo.service.registry.cluster=default
+apollo.service.registry.heartbeatIntervalInSecond=10
+

apollo-biz/src/main/java/com/ctrip/framework/apollo/biz/entity/JpaMapFieldJsonConverter.java

@@ -0,0 +1,47 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * 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 com.ctrip.framework.apollo.biz.entity;
+
+import com.google.common.reflect.TypeToken;
+import com.google.gson.Gson;
+import java.lang.reflect.Type;
+import java.util.HashMap;
+import java.util.Map;
+import javax.persistence.AttributeConverter;
+import javax.persistence.Converter;
+
+@Converter(autoApply = true)
+class JpaMapFieldJsonConverter implements AttributeConverter<Map<String, String>, String> {
+
+  private static final Gson GSON = new Gson();
+
+  private static final TypeToken<HashMap<String, String>> TYPE_TOKEN = new TypeToken<HashMap<String, String>>() {
+  };
+
+  @SuppressWarnings("unchecked")
+  private static final Type TYPE = TYPE_TOKEN.getType();
+
+  @Override
+  public String convertToDatabaseColumn(Map<String, String> attribute) {
+    return GSON.toJson(attribute);
+  }
+
+  @Override
+  public Map<String, String> convertToEntityAttribute(String dbData) {
+    return GSON.fromJson(dbData, TYPE);
+  }
+}

apollo-biz/src/main/java/com/ctrip/framework/apollo/biz/entity/ServiceRegistry.java

@@ -0,0 +1,152 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * 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 com.ctrip.framework.apollo.biz.entity;
+
+import com.ctrip.framework.apollo.biz.registry.ServiceInstance;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+import javax.persistence.Column;
+import javax.persistence.Convert;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.PrePersist;
+import javax.persistence.Table;
+
+/**
+ * use database as a registry instead of eureka, zookeeper, consul etc.
+ * <p>
+ * persist {@link ServiceInstance}
+ */
+@Entity
+@Table(name = "ServiceRegistry")
+public class ServiceRegistry {
+
+  @Id
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  @Column(name = "Id")
+  private long id;
+
+  @Column(name = "ServiceName", nullable = false)
+  private String serviceName;
+
+  /**
+   * @see ServiceInstance#getUri()
+   */
+  @Column(name = "Uri", nullable = false)
+  private String uri;
+
+  /**
+   * @see ServiceInstance#getCluster()
+   */
+  @Column(name = "Cluster", nullable = false)
+  private String cluster;
+
+  @Column(name = "Metadata", nullable = false)
+  @Convert(converter = JpaMapFieldJsonConverter.class)
+  private Map<String, String> metadata;
+
+  @Column(name = "DataChange_CreatedTime", nullable = false)
+  private LocalDateTime dataChangeCreatedTime;
+
+  /**
+   * modify by heartbeat
+   */
+  @Column(name = "DataChange_LastTime", nullable = false)
+  private LocalDateTime dataChangeLastModifiedTime;
+
+  @PrePersist
+  protected void prePersist() {
+    if (this.dataChangeCreatedTime == null) {
+      dataChangeCreatedTime = LocalDateTime.now();
+    }
+    if (this.dataChangeLastModifiedTime == null) {
+      dataChangeLastModifiedTime = dataChangeCreatedTime;
+    }
+  }
+
+  @Override
+  public String toString() {
+    return "Registry{" +
+        "id=" + id +
+        ", serviceName='" + serviceName + '\'' +
+        ", uri='" + uri + '\'' +
+        ", cluster='" + cluster + '\'' +
+        ", metadata='" + metadata + '\'' +
+        ", dataChangeCreatedTime=" + dataChangeCreatedTime +
+        ", dataChangeLastModifiedTime=" + dataChangeLastModifiedTime +
+        '}';
+  }
+
+  public long getId() {
+    return id;
+  }
+
+  public void setId(long id) {
+    this.id = id;
+  }
+
+  public String getServiceName() {
+    return serviceName;
+  }
+
+  public void setServiceName(String serviceName) {
+    this.serviceName = serviceName;
+  }
+
+  public String getUri() {
+    return uri;
+  }
+
+  public void setUri(String uri) {
+    this.uri = uri;
+  }
+
+  public String getCluster() {
+    return cluster;
+  }
+
+  public void setCluster(String cluster) {
+    this.cluster = cluster;
+  }
+
+  public Map<String, String> getMetadata() {
+    return metadata;
+  }
+
+  public void setMetadata(Map<String, String> metadata) {
+    this.metadata = metadata;
+  }
+
+  public LocalDateTime getDataChangeCreatedTime() {
+    return dataChangeCreatedTime;
+  }
+
+  public void setDataChangeCreatedTime(LocalDateTime dataChangeCreatedTime) {
+    this.dataChangeCreatedTime = dataChangeCreatedTime;
+  }
+
+  public LocalDateTime getDataChangeLastModifiedTime() {
+    return dataChangeLastModifiedTime;
+  }
+
+  public void setDataChangeLastModifiedTime(LocalDateTime dataChangeLastModifiedTime) {
+    this.dataChangeLastModifiedTime = dataChangeLastModifiedTime;
+  }
+}

apollo-biz/src/main/java/com/ctrip/framework/apollo/biz/registry/DatabaseDiscoveryClient.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * 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 com.ctrip.framework.apollo.biz.registry;
+
+import com.ctrip.framework.apollo.biz.registry.configuration.support.ApolloServiceRegistryProperties;
+import java.util.List;
+
+/**
+ * @see org.springframework.cloud.client.discovery.DiscoveryClient
+ */
+public interface DatabaseDiscoveryClient {
+
+  /**
+   * find by {@link ApolloServiceRegistryProperties#getServiceName()},
+   * then filter by {@link ApolloServiceRegistryProperties#getCluster()}
+   */
+  List<ServiceInstance> getInstances(String serviceName);
+}

apollo-biz/src/main/java/com/ctrip/framework/apollo/biz/registry/DatabaseDiscoveryClientImpl.java

@@ -0,0 +1,79 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * 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 com.ctrip.framework.apollo.biz.registry;
+
+import com.ctrip.framework.apollo.biz.entity.ServiceRegistry;
+import com.ctrip.framework.apollo.biz.registry.configuration.support.ApolloServiceDiscoveryProperties;
+import com.ctrip.framework.apollo.biz.registry.configuration.support.ApolloServiceRegistryProperties;
+import com.ctrip.framework.apollo.biz.service.ServiceRegistryService;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+public class DatabaseDiscoveryClientImpl implements DatabaseDiscoveryClient {
+  private final ServiceRegistryService serviceRegistryService;
+
+  private final ApolloServiceDiscoveryProperties discoveryProperties;
+
+  private final String cluster;
+
+  public DatabaseDiscoveryClientImpl(
+      ServiceRegistryService serviceRegistryService,
+      ApolloServiceDiscoveryProperties discoveryProperties,
+      String cluster) {
+    this.serviceRegistryService = serviceRegistryService;
+    this.discoveryProperties = discoveryProperties;
+    this.cluster = cluster;
+  }
+
+  /**
+   * find by {@link ApolloServiceRegistryProperties#getServiceName()}
+   */
+  @Override
+  public List<ServiceInstance> getInstances(String serviceName) {
+    final List<ServiceRegistry> serviceRegistryListFiltered;
+    {
+      LocalDateTime healthTime = LocalDateTime.now()
+          .minusSeconds(this.discoveryProperties.getHealthCheckIntervalInSecond());
+      List<ServiceRegistry> filterByHealthCheck =
+          this.serviceRegistryService.findByServiceNameDataChangeLastModifiedTimeGreaterThan(
+              serviceName, healthTime
+          );
+      serviceRegistryListFiltered = filterByCluster(filterByHealthCheck, this.cluster);
+    }
+
+    return serviceRegistryListFiltered.stream()
+        .map(DatabaseDiscoveryClientImpl::convert)
+        .collect(Collectors.toList());
+  }
+
+  static ApolloServiceRegistryProperties convert(ServiceRegistry serviceRegistry) {
+    ApolloServiceRegistryProperties registration = new ApolloServiceRegistryProperties();
+    registration.setServiceName(serviceRegistry.getServiceName());
+    registration.setUri(serviceRegistry.getUri());
+    registration.setCluster(serviceRegistry.getCluster());
+    return registration;
+  }
+
+  static List<ServiceRegistry> filterByCluster(List<ServiceRegistry> list, String cluster) {
+    return list.stream()
+        .filter(serviceRegistry -> Objects.equals(cluster, serviceRegistry.getCluster()))
+        .collect(Collectors.toList());
+  }
+
+}

apollo-biz/src/main/java/com/ctrip/framework/apollo/biz/registry/DatabaseServiceRegistry.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * 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 com.ctrip.framework.apollo.biz.registry;
+
+/**
+ * @see org.springframework.cloud.client.serviceregistry.ServiceRegistry
+ */
+public interface DatabaseServiceRegistry {
+
+  /**
+   * register an instance to database
+   */
+  void register(ServiceInstance instance);
+
+  /**
+   * remove an instance from database
+   */
+  void deregister(ServiceInstance instance);
+}