tag router supports anyhost (apache#4431)

Fixes apache#4393
iiweniiang · Sep 17, 2019 · fb1f98b · fb1f98b
1 parent dbb0a64
commit fb1f98b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/tag/TagRouter.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/tag/TagRouter.java
@@ -40,6 +40,7 @@
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
+import static org.apache.dubbo.common.constants.CommonConstants.ANYHOST_VALUE;
 import static org.apache.dubbo.rpc.Constants.FORCE_USE_TAG;
 import static org.apache.dubbo.rpc.cluster.Constants.TAG_KEY;
 
@@ -52,6 +53,7 @@ public class TagRouter extends AbstractRouter implements ConfigurationListener {
     private static final Logger logger = LoggerFactory.getLogger(TagRouter.class);
     private static final String RULE_SUFFIX = ".tag-router";
 
+
     private TagRouterRule tagRouterRule;
     private String application;
 
@@ -212,6 +214,9 @@ private boolean checkAddressMatch(List<String> addresses, String host, int port)
                 if (NetUtils.matchIpExpression(address, host, port)) {
                     return true;
                 }
+                if ((ANYHOST_VALUE + ":" + port).equals(address)) {
+                    return true;
+                }
             } catch (UnknownHostException e) {
                 logger.error("The format of ip address is invalid in tag route. Address :" + address, e);
             } catch (Exception e) {