fix diff method can not be added to RadixTree

Author: Stellar1999

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/rest/mapping/DefaultRequestMappingRegistry.java

@@ -169,7 +169,7 @@ private void register0(RequestMapping mapping, HandlerMeta handler, AtomicIntege
         try {
             Registration registration = new Registration(mapping, handler);
             for (PathExpression path : mapping.getPathCondition().getExpressions()) {
-                Registration exists = tree.addPath(path, registration);
+                Registration exists = tree.addPath(path, registration, Registration::isOverlap);
                 if (exists == null) {
                     counter.incrementAndGet();
                     if (LOGGER.isDebugEnabled()) {

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/rest/mapping/RadixTree.java

@@ -31,7 +31,9 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
+import java.util.Objects;
 import java.util.function.BiConsumer;
+import java.util.function.BiFunction;
 import java.util.function.Predicate;
 
 /**
@@ -63,13 +65,25 @@ public RadixTree() {
         this(true, '/');
     }
 
+    /**
+     * This is a default implementation that does not check for equality.
+     */
     public T addPath(PathExpression path, T value) {
+        return addPath(path, value, (t, t2) -> Boolean.TRUE);
+    }
+
+    /**
+     * When the path is the same, the predicate is used to determine whether the values are considered equal.
+     * If the predicate returns true, the existing value is returned directly.
+     */
+    public T addPath(PathExpression path, T value, BiFunction<T, T, Boolean> predicate) {
+        Objects.requireNonNull(predicate);
         if (path.isDirect()) {
             KeyString key = new KeyString(path.getPath(), caseSensitive);
             List<Match<T>> matches = directPathMap.computeIfAbsent(key, k -> new ArrayList<>());
             for (int i = 0, size = matches.size(); i < size; i++) {
                 Match<T> match = matches.get(i);
-                if (match.getValue().equals(value)) {
+                if (predicate.apply(match.getValue(), value)) {
                     return match.getValue();
                 }
             }
@@ -85,7 +99,9 @@ public T addPath(PathExpression path, T value) {
                 List<Pair<PathExpression, T>> values = child.values;
                 for (int j = 0, size = values.size(); j < size; j++) {
                     if (values.get(j).getLeft().equals(path)) {
-                        return values.get(j).getRight();
+                        if (predicate.apply(values.get(j).getRight(), value)) {
+                            return values.get(j).getRight();
+                        }
                     }
                 }
                 values.add(Pair.of(path, value));

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/rest/mapping/Registration.java

@@ -47,6 +47,10 @@ public boolean equals(Object obj) {
         return mapping.equals(((Registration) obj).mapping);
     }
 
+    public boolean isOverlap(Registration registration) {
+        return registration == null || mapping.isOverlap(registration.mapping);
+    }
+
     @Override
     public int hashCode() {
         return mapping.hashCode();

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/rest/mapping/RequestMapping.java

@@ -347,6 +347,25 @@ public boolean equals(Object obj) {
                 && Objects.equals(sig, other.sig);
     }
 
+    public boolean isOverlap(RequestMapping requestMapping) {
+        if (this == requestMapping) {
+            return true;
+        }
+        if (requestMapping == null) {
+            return false;
+        }
+        return Objects.equals(pathCondition, requestMapping.pathCondition)
+                && (this.methodsCondition == null
+                        || requestMapping.methodsCondition == null
+                        || this.methodsCondition.isOverlap(requestMapping.methodsCondition))
+                && Objects.equals(paramsCondition, requestMapping.paramsCondition)
+                && Objects.equals(headersCondition, requestMapping.headersCondition)
+                && Objects.equals(consumesCondition, requestMapping.consumesCondition)
+                && Objects.equals(producesCondition, requestMapping.producesCondition)
+                && Objects.equals(customCondition, requestMapping.customCondition)
+                && Objects.equals(sig, requestMapping.sig);
+    }
+
     @Override
     public String toString() {
         StringBuilder sb = new StringBuilder("RequestMapping{name='");

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/rest/mapping/condition/MethodsCondition.java

@@ -19,6 +19,7 @@
 import org.apache.dubbo.remoting.http12.HttpRequest;
 
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.HashSet;
 import java.util.Set;
 
@@ -88,6 +89,10 @@ public int compareTo(MethodsCondition other, HttpRequest request) {
         return 0;
     }
 
+    public boolean isOverlap(MethodsCondition methodsCondition) {
+        return methodsCondition == null || !Collections.disjoint(this.getMethods(), methodsCondition.getMethods());
+    }
+
     @Override
     public int hashCode() {
         return methods.hashCode();

dubbo-rpc/dubbo-rpc-triple/src/test/groovy/org/apache/dubbo/rpc/protocol/tri/rest/mapping/RadixTreeTest.groovy

@@ -17,6 +17,8 @@
 
 package org.apache.dubbo.rpc.protocol.tri.rest.mapping
 
+import org.apache.dubbo.rpc.protocol.tri.rest.mapping.condition.PathExpression
+
 import spock.lang.Specification
 
 class RadixTreeTest extends Specification {
@@ -59,6 +61,42 @@ class RadixTreeTest extends Specification {
             '/a/b/c/d' | 0
     }
 
+    def "test repeat add,no predicate function"() {
+        given:
+            def tree = new RadixTree<Boolean>()
+            Boolean val1 = tree.addPath('/a/*/*', false)
+            Boolean val2 = tree.addPath('/a/*/*', true)
+        expect:
+            val1 == null;
+            val2 == false;
+    }
+
+    def "test repeat add,use predicate function"() {
+        given:
+            def tree = new RadixTree<Boolean>()
+            Boolean val1 = tree.addPath(PathExpression.parse('/a/*/*'), false, { a, b -> a == b })
+            Boolean val2 = tree.addPath(PathExpression.parse('/a/*/*'), true, { a, b -> a == b })
+            Boolean val3 = tree.addPath(PathExpression.parse('/a/*/*'), true, { a, b -> a == b })
+
+        expect:
+            val1 == null;
+            val2 == null;
+        val3 == true;
+    }
+
+    def "test repeat add,use predicate function and Registration"() {
+        given:
+            def tree = new RadixTree<Boolean>()
+            Boolean val1 = tree.addPath(PathExpression.parse('/a/*/*'), false, { a, b -> a == b })
+            Boolean val2 = tree.addPath(PathExpression.parse('/a/*/*'), true, { a, b -> a == b })
+            Boolean val3 = tree.addPath(PathExpression.parse('/a/*/*'), true, { a, b -> a == b })
+
+        expect:
+            val1 == null;
+            val2 == null;
+            val3 == true;
+    }
+
     def "test sub path match"() {
         given:
             def tree = new RadixTree<String>();

dubbo-rpc/dubbo-rpc-triple/src/test/groovy/org/apache/dubbo/rpc/protocol/tri/rest/mapping/RegistrationSpec.groovy

@@ -0,0 +1,64 @@
+/*
+ * 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.dubbo.rpc.protocol.tri.rest.mapping
+
+import org.apache.dubbo.remoting.http12.HttpMethods
+import org.apache.dubbo.rpc.protocol.tri.rest.mapping.meta.HandlerMeta
+
+import spock.lang.Specification
+
+class RegistrationSpec extends Specification {
+
+    def "isMethodOverlap should return true when methods overlap"() {
+        given:
+            def mapping1 = new RequestMapping.Builder().method(HttpMethods.GET.name(), HttpMethods.PUT.name()).build()
+            def mapping2 = new RequestMapping.Builder().method(HttpMethods.PUT.name(), HttpMethods.POST.name()).build()
+            def meta = GroovyMock(HandlerMeta)
+            def reg1 = new Registration(mapping1, meta)
+            def reg2 = new Registration(mapping2, meta)
+
+        expect:
+            reg1.isOverlap(reg2)
+    }
+
+    def "isMethodOverlap should return false when methods do not overlap"() {
+        given:
+            def mapping1 = new RequestMapping.Builder().method(HttpMethods.GET.name()).build()
+            def mapping2 = new RequestMapping.Builder().method(HttpMethods.PUT.name()).build()
+
+            def meta = GroovyMock(HandlerMeta)
+            def reg1 = new Registration(mapping1, meta)
+            def reg2 = new Registration(mapping2, meta)
+
+        expect:
+            !reg1.isOverlap(reg2)
+    }
+
+    def "isMethodOverlap should return true if any MethodsCondition is null"() {
+        given:
+            def mapping1 = new RequestMapping.Builder().build()
+            def mapping2 = new RequestMapping.Builder().build()
+
+            def meta = GroovyMock(HandlerMeta)
+            def reg1 = new Registration(mapping1, meta)
+            def reg2 = new Registration(mapping2, meta)
+
+        expect:
+            reg1.isOverlap(reg2)
+    }
+}