refactor registerSupportNewProtocol

zuojunyuan · Feb 25, 2017 · 8954860 · 8954860
1 parent 3638232
commit 8954860
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...istry-zookeeper/src/main/java/com/dianping/pigeon/registry/zookeeper/CuratorRegistry.java b/...istry-zookeeper/src/main/java/com/dianping/pigeon/registry/zookeeper/CuratorRegistry.java
@@ -483,6 +483,9 @@ public boolean isSupportNewProtocol(String serviceAddress, String serviceName) t
     @Override
     public void setSupportNewProtocol(String serviceAddress, String serviceName, boolean support)
             throws RegistryException {
+        // only write to zk when support new protocol to relieve the pressure of zk
+        if (!support) return;
+
         try {
             String protocolPath = Utils.getProtocolPath(serviceAddress);
             if (client.exists(protocolPath, false)) {
@@ -516,6 +519,9 @@ public void setSupportNewProtocol(String serviceAddress, String serviceName, boo
     @Override
     public void unregisterSupportNewProtocol(String serviceAddress, String serviceName, boolean support)
             throws RegistryException {
+        // only write to zk when support new protocol to relieve the pressure of zk
+        if (!support) return;
+
         try {
             String protocolPath = Utils.getProtocolPath(serviceAddress);
             if (client.exists(protocolPath, false)) {