[Feature-apache#15103][Standalone]Support using JDBC registry plugin …

…in standalone mode.(apache#15139)

dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/JdbcRegistryConfiguration.java

@@ -34,7 +34,7 @@
 @ConditionalOnProperty(prefix = "registry", name = "type", havingValue = "jdbc")
 public class JdbcRegistryConfiguration {
 
-    @Bean
+    @Bean("sqlSessionFactory")
     @ConditionalOnProperty(prefix = "registry.hikari-config", name = "jdbc-url")
     public SqlSessionFactory jdbcRegistrySqlSessionFactory(JdbcRegistryProperties jdbcRegistryProperties) throws Exception {
         MybatisSqlSessionFactoryBean sqlSessionFactoryBean = new MybatisSqlSessionFactoryBean();

dolphinscheduler-standalone-server/README.md

@@ -0,0 +1,15 @@
+# Introduction
+
+This module is used to start the dolphinscheduler in standalone mode. Currently Zookeeper and JDBC plugin are enabled as registries, depending on the properties configuration.
+
+# How to use
+
+1. Select the type of registry you want. The default is Zookeeper
+
+-  If you have chosen Zookeeper as the registry, you can refer to the dollinscheduler-registry-plugins dollinscheduler-registry-Zookeeper readme.md documentation for configuration. (note: the default is of type Zookeeper, and a mock Zookeeper server is created, without the need to actually install ZK)
+-  If you choose JDBC as the Registry, you can refer to the readme.md documentation for configuration
+
+
+
+
+##

dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/StandaloneServer.java

@@ -17,28 +17,50 @@
 
 package org.apache.dolphinscheduler;
 
-import org.apache.curator.test.TestingServer;
+import org.apache.dolphinscheduler.registry.StandaloneRegistry;
+
+import java.util.List;
+import java.util.Optional;
 
 import lombok.extern.slf4j.Slf4j;
 
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ConfigurableApplicationContext;
 
 @SpringBootApplication
 @Slf4j
 public class StandaloneServer {
 
+    @Value("${registry.type}")
+    private String registryType;
+
+    @Autowired
+    private List<StandaloneRegistry> registries;
+
     public static void main(String[] args) throws Exception {
         try {
-            // We cannot use try-with-resources to close "TestingServer", since SpringApplication.run() will not block
-            // the main thread.
-            TestingServer zookeeperServer = new TestingServer(true);
-            System.setProperty("registry.zookeeper.connect-string", zookeeperServer.getConnectString());
-            SpringApplication.run(StandaloneServer.class, args);
+            ConfigurableApplicationContext context = SpringApplication.run(StandaloneServer.class, args);
+            StandaloneServer standaloneServer = context.getBean(StandaloneServer.class);
+            standaloneServer.registry();
         } catch (Exception ex) {
             log.error("StandaloneServer start failed", ex);
             System.exit(1);
         }
     }
 
+    private void registry() {
+        Optional<StandaloneRegistry> registry = registries.stream()
+                .filter(r -> r.supports(registryType))
+                .findFirst();
+
+        if (registry.isPresent()) {
+            registry.get().init();
+        } else {
+            log.error("Unsupported registry type: {}", registryType);
+        }
+    }
+
 }

dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/registry/JdbcStandaloneRegistry.java

@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.dolphinscheduler.registry;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class JdbcStandaloneRegistry implements StandaloneRegistry {
+
+    @Override
+    public void init() {
+
+    }
+
+    @Override
+    public boolean supports(String registryType) {
+        return "jdbc".equalsIgnoreCase(registryType);
+    }
+}

dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/registry/StandaloneRegistry.java

@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.dolphinscheduler.registry;
+
+public interface StandaloneRegistry {
+
+    void init();
+
+    boolean supports(String registryType);
+}

dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/registry/ZookeeperStandaloneRegistry.java

@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.dolphinscheduler.registry;
+
+import org.apache.curator.test.TestingServer;
+
+import lombok.extern.slf4j.Slf4j;
+
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class ZookeeperStandaloneRegistry implements StandaloneRegistry {
+
+    @Override
+    public void init() {
+        try {
+            // We cannot use try-with-resources to close "TestingServer", since SpringApplication.run() will not block
+            TestingServer zookeeperServer = new TestingServer(true);
+            System.setProperty("registry.zookeeper.connect-string", zookeeperServer.getConnectString());
+        } catch (Exception ex) {
+            log.error("Zookeeper TestingServer create failed", ex);
+        }
+    }
+
+    @Override
+    public boolean supports(String registryType) {
+        return "zookeeper".equalsIgnoreCase(registryType);
+    }
+}