[type:feature] Custome classloader hot load plugins to gateway.

.github/workflows/e2e-k8s.yml

@@ -209,6 +209,8 @@ jobs:
             script: e2e-springcloud-sync
           - case: shenyu-e2e-case-apache-dubbo
             script: e2e-apache-dubbo-sync
+          - case: shenyu-e2e-case-motan
+            script: e2e-motan-sync
           - case: shenyu-e2e-case-sofa
             script: e2e-sofa-sync
           - case: shenyu-e2e-case-grpc

.gitignore

@@ -13,6 +13,7 @@ dependency-reduced-pom.xml
 release.properties
 cobertura.ser
 *.gpg
+plugins
 
 # eclipse ignore
 .settings/

pom.xml

@@ -217,30 +217,6 @@
                 <version>${bytebuddy.version}</version>
             </dependency>
 
-            <dependency>
-                <groupId>com.weibo</groupId>
-                <artifactId>motan-core</artifactId>
-                <version>${motan.version}</version>
-            </dependency>
-
-            <dependency>
-                <groupId>com.weibo</groupId>
-                <artifactId>motan-transport-netty4</artifactId>
-                <version>${motan.version}</version>
-            </dependency>
-
-            <dependency>
-                <groupId>com.weibo</groupId>
-                <artifactId>motan-registry-zookeeper</artifactId>
-                <version>${motan.version}</version>
-            </dependency>
-
-            <dependency>
-                <groupId>com.weibo</groupId>
-                <artifactId>motan-springsupport</artifactId>
-                <version>${motan.version}</version>
-            </dependency>
-
             <dependency>
                 <groupId>com.google.code.gson</groupId>
                 <artifactId>gson</artifactId>
@@ -276,39 +252,6 @@
                 <version>${apache.dubbo.version}</version>
             </dependency>
 
-            <dependency>
-                <groupId>com.alipay.sofa</groupId>
-                <artifactId>sofa-rpc-all</artifactId>
-                <version>${sofa.rpc.version}</version>
-                <exclusions>
-                    <exclusion>
-                        <groupId>net.jcip</groupId>
-                        <artifactId>jcip-annotations</artifactId>
-                    </exclusion>
-                    <exclusion>
-                        <groupId>io.grpc</groupId>
-                        <artifactId>grpc-core</artifactId>
-                    </exclusion>
-                    <exclusion>
-                        <artifactId>grpc-api</artifactId>
-                        <groupId>io.grpc</groupId>
-                    </exclusion>
-                    <exclusion>
-                        <artifactId>grpc-protobuf</artifactId>
-                        <groupId>io.grpc</groupId>
-                    </exclusion>
-                    <exclusion>
-                        <artifactId>grpc-stub</artifactId>
-                        <groupId>io.grpc</groupId>
-                    </exclusion>
-                    <exclusion>
-                        <artifactId>grpc-netty-shaded</artifactId>
-                        <groupId>io.grpc</groupId>
-                    </exclusion>
-                </exclusions>
-            </dependency>
-
-
             <dependency>
                 <groupId>com.alibaba</groupId>
                 <artifactId>dubbo</artifactId>
@@ -832,6 +775,39 @@
                     </execution>
                 </executions>
             </plugin>
+
+            <plugin>
+                <groupId>org.commonjava.maven.plugins</groupId>
+                <artifactId>directory-maven-plugin</artifactId>
+                <version>0.1</version>
+                <executions>
+                    <execution>
+                        <id>directories</id>
+                        <goals>
+                            <goal>highest-basedir</goal>
+                        </goals>
+                        <phase>initialize</phase>
+                        <configuration>
+                            <property>main.basedir</property>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-clean-plugin</artifactId>
+                <configuration>
+                    <filesets>
+                        <fileset>
+                            <directory>plugins</directory>
+                            <includes>
+                                <include>**/*</include>
+                            </includes>
+                            <followSymlinks>false</followSymlinks>
+                        </fileset>
+                    </filesets>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

script/clean_duplicated_jar.sh

@@ -0,0 +1,38 @@
+#!/bin/bash
+
+# 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.
+
+echo 'Remove duplicated jar files...'
+
+# 获取第一个目录下的所有文件
+dir1=$1
+array1=($(find $dir1 -type f))
+
+# 获取第二个目录下的所有文件
+dir2=$2
+array2=($(find $dir2 -type f))
+
+# 遍历两个数组，检查是否存在重复的文件
+for file in "${array1[@]}"; do
+    for otherfile in "${array2[@]}"; do
+        if [[ $(basename "$file") == $(basename "$otherfile") ]]; then
+            # 删除重复的文件
+            rm -f "$otherfile"
+            break;
+        fi
+    done
+done

shenyu-admin-listener/shenyu-admin-listener-apollo/src/main/java/org/apache/shenyu/admin/listener/apollo/ApolloClient.java

@@ -75,7 +75,6 @@ public String getItemValue(final String key) {
         return openItemDTO.getValue();
     }
 
-
     /**
      * removeItemKey.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/config/properties/DashboardProperties.java

@@ -37,15 +37,13 @@ public class DashboardProperties implements InitializingBean {
      * record log limit.
      */
     private Integer recordLogLimit = 12;
-
-
+
     /**
      * Only supports deleting logs older than a certain day.
      * default is 3.
      */
     private Integer onlyCleanDays = 3;
-
-
+
     /**
      * enable print api log..
      * default is false.
@@ -64,14 +62,12 @@ public class DashboardProperties implements InitializingBean {
      */
     private Boolean enableSuperAdminPasswordSafe = true;
 
-
     /**
      * enable SuperAdminPassword valid duration.
      * default is 30 day
      */
     private Long superAdminPasswordValidDuration = 30 * AdminConstants.THE_ONE_DAY_MILLIS_TIME;
 
-
     /**
      * Only the super administrator root user has the privileges.
      * default is 3.

shenyu-admin/src/main/java/org/apache/shenyu/admin/discovery/parse/CustomDiscoveryUpstreamParser.java

@@ -49,7 +49,6 @@ public class CustomDiscoveryUpstreamParser implements JsonDeserializer<Discovery
 
     private final Map<String, String> conversion;
 
-
     /**
      * CustomDiscoveryUpstreamParser.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/disruptor/executor/RegisterServerConsumerExecutor.java

@@ -100,8 +100,7 @@ public QueueConsumerExecutor<Collection<DataTypeParent>> create() {
         public String fixName() {
             return "shenyu_register_server";
         }
-
-
+
         /**
          * Add subscribers abstract queue consumer factory.
          *

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/AbstractDataChangedListener.java

@@ -46,7 +46,6 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
-
 /**
  * Abstract class for ConfigEventListener.
  * As we think that the md5 value of the in-memory data is the same as the md5 value of the database,

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/bean/CustomCode.java

@@ -17,7 +17,6 @@
 
 package org.apache.shenyu.admin.model.bean;
 
-
 /**
  * CustomCode.
  */
@@ -29,7 +28,6 @@ public class CustomCode {
 
     private String solution;
 
-
     /**
      * getCode.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/constant/RegConstant.java

@@ -27,7 +27,6 @@ public final class RegConstant {
      */
     public static final String PASSWORD_RULE = "^(?=.*[a-z])(?=.*[A-Z])(?=.*\\d)(?=.*[@$!%*?&#.=_+-])[A-Za-z\\d@$!%*?&#.=_+-]{8,}$";
 
-
     /**
      * At least 8 in length, containing at least one letter and one number.
      */

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/dto/DiscoveryUpstreamDTO.java

@@ -84,7 +84,6 @@ public class DiscoveryUpstreamDTO implements Serializable {
      */
     private Timestamp dateUpdated;
 
-
     /**
      * getId.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/dto/FieldDTO.java

@@ -82,7 +82,6 @@ public class FieldDTO implements Serializable {
      */
     private Timestamp dateUpdated;
 
-
     /**
      * getModelId.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/entity/DetailDO.java

@@ -140,7 +140,6 @@ public int hashCode() {
         return Objects.hash(super.hashCode(), fieldId, example, fieldValue, valueDesc);
     }
 
-
     /**
      * builder.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/entity/PluginDO.java

@@ -369,8 +369,6 @@ public PluginDOBuilder pluginJar(final byte[] pluginJar) {
             return this;
         }
 
-
-
         /**
          * build method.
          *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/enums/EventTypeEnum.java

@@ -232,7 +232,6 @@ public DataEventTypeEnum getType() {
         return type;
     }
 
-
     /**
      * get color.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/AdminDataModelChangedEvent.java

@@ -86,8 +86,7 @@ public AdminDataModelChangedEvent(final Object source, final Object before, fina
         this.consumed = false;
         this.date = new Date();
     }
-
-
+
     /**
      * get type.
      *
@@ -139,8 +138,7 @@ public void consumed() {
     public boolean isConsumed() {
         return consumed;
     }
-
-
+
     /**
      * get date.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/BatchChangedEvent.java

@@ -26,8 +26,7 @@
  * BatchChangedEvent.
  */
 public class BatchChangedEvent extends AdminDataModelChangedEvent {
-
-
+
     /**
      * Create a new {@code PluginChangedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/dict/BatchDictChangedEvent.java

@@ -30,7 +30,6 @@
  */
 public class BatchDictChangedEvent extends BatchChangedEvent {
 
-
     /**
      * Create a new {@code BatchDictChangedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/dict/BatchDictDeletedEvent.java

@@ -54,8 +54,6 @@ public String buildContext() {
         return String.format("the dict[%s] is %s", data, StringUtils.lowerCase(getType().getType().toString()));
     }
 
-
-
     /**
      * get deleted iss.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/dict/DictChangedEvent.java

@@ -29,7 +29,6 @@
  */
 public class DictChangedEvent extends AdminDataModelChangedEvent {
 
-
     /**
      * Create a new {@code DictChangedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/dict/DictCreatedEvent.java

@@ -25,7 +25,6 @@
  */
 public class DictCreatedEvent extends DictChangedEvent {
 
-
     /**
      * Create a new {@code DictCreatedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/dict/DictUpdatedEvent.java

@@ -25,7 +25,6 @@
  */
 public class DictUpdatedEvent extends DictChangedEvent {
 
-
     /**
      * Create a new {@code DictUpdatedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/handle/BatchPluginHandleChangedEvent.java

@@ -30,7 +30,6 @@
  */
 public class BatchPluginHandleChangedEvent extends BatchChangedEvent {
 
-
     /**
      * Create a new {@code PluginChangedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/handle/PluginHandleChangedEvent.java

@@ -29,7 +29,6 @@
  */
 public class PluginHandleChangedEvent extends AdminDataModelChangedEvent {
 
-
     /**
      * Create a new {@code PluginChangedEvent}.operator is unknown.
      *

shenyu-admin/src/main/java/org/apache/shenyu/admin/model/event/metadata/BatchMetaDataChangedEvent.java

@@ -30,7 +30,6 @@
  */
 public class BatchMetaDataChangedEvent extends BatchChangedEvent {
 
-
     /**
      * Create a new {@code BatchMetaDataChangedEvent}.operator is unknown.
      *