optimize zookeeper serialization method

motan-manager/src/main/java/com/weibo/utils/ZkClientWrapper.java

@@ -1,6 +1,7 @@
 package com.weibo.utils;
 
 import com.weibo.api.motan.exception.MotanFrameworkException;
+import com.weibo.api.motan.registry.zookeeper.StringSerializer;
 import org.I0Itec.zkclient.ZkClient;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Lazy;
@@ -22,7 +23,7 @@ public class ZkClientWrapper {
     @PostConstruct
     void init() {
         try {
-            zkClient = new ZkClient(registryUrl, 10000);
+            zkClient = new ZkClient(registryUrl, 10000, 10000, new StringSerializer());
         } catch (Exception e) {
             throw new MotanFrameworkException("Fail to connect zookeeper, cause: " + e.getMessage());
         }

motan-registry-zookeeper/src/main/java/com/weibo/api/motan/registry/zookeeper/StringSerializer.java

@@ -0,0 +1,32 @@
+package com.weibo.api.motan.registry.zookeeper;
+
+import org.I0Itec.zkclient.exception.ZkMarshallingError;
+import org.I0Itec.zkclient.serialize.SerializableSerializer;
+
+import java.io.ObjectStreamConstants;
+
+public class StringSerializer extends SerializableSerializer {
+    @Override
+    public Object deserialize(byte[] bytes) throws ZkMarshallingError {
+        if (getTag(bytes) == ObjectStreamConstants.STREAM_MAGIC) {
+            return super.deserialize(bytes);
+        }
+        return new String(bytes);
+    }
+
+    @Override
+    public byte[] serialize(Object obj) throws ZkMarshallingError {
+        return obj.toString().getBytes();
+    }
+
+    private short getTag(byte[] bytes) {
+        short s = 0;
+        if (bytes.length > 2) {
+            for (int i = 0; i < 2; i++) {
+                s <<= 8;
+                s |= (bytes[i] & 0x00ff);
+            }
+        }
+        return s;
+    }
+}

motan-registry-zookeeper/src/main/java/com/weibo/api/motan/registry/zookeeper/ZookeeperRegistryFactory.java

@@ -27,15 +27,14 @@
 
 @SpiMeta(name = "zookeeper")
 public class ZookeeperRegistryFactory extends AbstractRegistryFactory {
-
     @Override
     protected Registry createRegistry(URL registryUrl) {
         try {
             int timeout = registryUrl.getIntParameter(URLParamType.connectTimeout.getName(), URLParamType.connectTimeout.getIntValue());
             int sessionTimeout =
                     registryUrl.getIntParameter(URLParamType.registrySessionTimeout.getName(),
                             URLParamType.registrySessionTimeout.getIntValue());
-            ZkClient zkClient = new ZkClient(registryUrl.getParameter("address"), sessionTimeout, timeout);
+            ZkClient zkClient = new ZkClient(registryUrl.getParameter("address"), sessionTimeout, timeout, new StringSerializer());
             return new ZookeeperRegistry(registryUrl, zkClient);
         } catch (ZkException e) {
             LoggerUtil.error("[ZookeeperRegistry] fail to connect zookeeper, cause: " + e.getMessage());