diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java
index 7d4eae353d..7588f74d2d 100644
--- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java
+++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java
@@ -56,6 +56,11 @@ public class MigrationRuleHandler<T> {
         } else {
             try {
                 rule = MigrationRule.parse(rawRule);
+                // FIXME, consumerURL.getHost() might not exactly the ip expected.
+                if (rule.getTargetIps() == null || !rule.getTargetIps().contains(consumerURL.getHost())) {
+                    logger.info("Migration rule ignored, rule target ips " + rule.getTargetIps() + " and local ip " + consumerURL.getHost() + " do not match");
+                    return;
+                }
                 setMigrationRule(rule);
                 step = rule.getStep(consumerURL.getServiceKey());
                 threshold = rule.getThreshold(consumerURL.getServiceKey());
diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/model/MigrationRule.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/model/MigrationRule.java
index 13dffc31b4..c727627374 100644
--- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/model/MigrationRule.java
+++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/model/MigrationRule.java
@@ -41,6 +41,8 @@ public class MigrationRule {
     private String key;
     private MigrationStep step;
     private Float threshold;
+    // FIXME
+    private List<String> targetIps;
     private List<InterfaceMigrationRule> interfaces;
 
     private transient Map<String, InterfaceMigrationRule> interfaceRules;
@@ -100,6 +102,13 @@ public class MigrationRule {
         return interfaces;
     }
 
+    public List<String> getTargetIps() {
+        return targetIps;
+    }
+
+    public void setTargetIps(List<String> targetIps) {
+        this.targetIps = targetIps;
+    }
 
     public void setInterfaces(List<InterfaceMigrationRule> interfaces) {
         this.interfaces = interfaces;