流量切换异常

[zxn-git]

管理后台：

zk节点：

问题：

1. 如果不配置流量切换，启动没问题也可以连接上server
2. 在后台配置好流量切换后，在启动client就会失败
3. 在后台删除流量切换，依然会启动失败，只能收到删除zk的command节点

启动客户端异常：
19:29:15.876 [main] WARN warn - [ZookeeperRegistry] false to subscribe motan://10.3.0.32:0/com.mtan.interf.FooService?group=motan-ulive-rpc1 from zookeeper://127.0.0.1:2181/com.weibo.api.motan.registry.RegistryService?group=default_rpc
com.weibo.api.motan.exception.MotanFrameworkException: error_message: Failed to discover command motan://10.3.0.32:0/com.mtan.interf.FooService?group=motan-ulive-rpc1 from zookeeper(zookeeper://127.0.0.1:2181/com.weibo.api.motan.registry.RegistryService?group=default_rpc), cause: java.io.StreamCorruptedException: invalid stream header: 7B22636C, status: 503, error_code: 20001,r=null
at com.weibo.api.motan.registry.zookeeper.ZookeeperRegistry.discoverCommand(ZookeeperRegistry.java:214)
at com.weibo.api.motan.registry.support.command.CommandFailbackRegistry.doDiscover(CommandFailbackRegistry.java:70)
at com.weibo.api.motan.registry.support.command.CommandFailbackRegistry.doSubscribe(CommandFailbackRegistry.java:49)
at com.weibo.api.motan.registry.support.AbstractRegistry.subscribe(AbstractRegistry.java:105)
at com.weibo.api.motan.registry.support.FailbackRegistry.subscribe(FailbackRegistry.java:119)
at com.weibo.api.motan.cluster.support.ClusterSupport.init(ClusterSupport.java:108)
at com.weibo.api.motan.config.handler.SimpleConfigHandler.buildClusterSupport(SimpleConfigHandler.java:56)
at com.weibo.api.motan.config.RefererConfig.createClusterSupport(RefererConfig.java:196)
at com.weibo.api.motan.config.RefererConfig.initRef(RefererConfig.java:138)
at com.weibo.api.motan.config.RefererConfig.getRef(RefererConfig.java:94)
at com.weibo.api.motan.config.springsupport.RefererConfigBean.getObject(RefererConfigBean.java:40)
at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.doGetObjectFromFactoryBean(FactoryBeanRegistrySupport.java:178)
at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.getObjectFromFactoryBean(FactoryBeanRegistrySupport.java:103)
at org.springframework.beans.factory.support.AbstractBeanFactory.getObjectForBeanInstance(AbstractBeanFactory.java:1646)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:254)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1054)
at com.mtan.ThreadPoolFullClient.main(ThreadPoolFullClient.java:14)
Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'remoteService': FactoryBean threw exception on object creation; nested exception is com.weibo.api.motan.exception.MotanFrameworkException: error_message: [ZookeeperRegistry] false to subscribe motan://10.3.0.32:0/com.mtan.interf.FooService?group=motan-ulive-rpc1 from zookeeper://127.0.0.1:2181/com.weibo.api.motan.registry.RegistryService?group=default_rpc, status: 503, error_code: 20001,r=null
at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.doGetObjectFromFactoryBean(FactoryBeanRegistrySupport.java:185)
at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.getObjectFromFactoryBean(FactoryBeanRegistrySupport.java:103)
at org.springframework.beans.factory.support.AbstractBeanFactory.getObjectForBeanInstance(AbstractBeanFactory.java:1646)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:254)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1054)
at com.mtan.ThreadPoolFullClient.main(ThreadPoolFullClient.java:14)
Caused by: com.weibo.api.motan.exception.MotanFrameworkException: error_message: [ZookeeperRegistry] false to subscribe motan://10.3.0.32:0/com.mtan.interf.FooService?group=motan-ulive-rpc1 from zookeeper://127.0.0.1:2181/com.weibo.api.motan.registry.RegistryService?group=default_rpc, status: 503, error_code: 20001,r=null
at com.weibo.api.motan.registry.support.FailbackRegistry.subscribe(FailbackRegistry.java:126)
at com.weibo.api.motan.cluster.support.ClusterSupport.init(ClusterSupport.java:108)
at com.weibo.api.motan.config.handler.SimpleConfigHandler.buildClusterSupport(SimpleConfigHandler.java:56)
at com.weibo.api.motan.config.RefererConfig.createClusterSupport(RefererConfig.java:196)
at com.weibo.api.motan.config.RefererConfig.initRef(RefererConfig.java:138)
at com.weibo.api.motan.config.RefererConfig.getRef(RefererConfig.java:94)
at com.weibo.api.motan.config.springsupport.RefererConfigBean.getObject(RefererConfigBean.java:40)
at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.doGetObjectFromFactoryBean(FactoryBeanRegistrySupport.java:178)
... 6 more
Caused by: com.weibo.api.motan.exception.MotanFrameworkException: error_message: Failed to discover command motan://10.3.0.32:0/com.mtan.interf.FooService?group=motan-ulive-rpc1 from zookeeper(zookeeper://127.0.0.1:2181/com.weibo.api.motan.registry.RegistryService?group=default_rpc), cause: java.io.StreamCorruptedException: invalid stream header: 7B22636C, status: 503, error_code: 20001,r=null
at com.weibo.api.motan.registry.zookeeper.ZookeeperRegistry.discoverCommand(ZookeeperRegistry.java:214)
at com.weibo.api.motan.registry.support.command.CommandFailbackRegistry.doDiscover(CommandFailbackRegistry.java:70)
at com.weibo.api.motan.registry.support.command.CommandFailbackRegistry.doSubscribe(CommandFailbackRegistry.java:49)
at com.weibo.api.motan.registry.support.AbstractRegistry.subscribe(AbstractRegistry.java:105)
at com.weibo.api.motan.registry.support.FailbackRegistry.subscribe(FailbackRegistry.java:119)
... 13 more

[zxn-git]

client、server motan版本：
<motan_version>1.1.14</motan_version>
管理后台：
拉的最新github代码

[zxn-git]

服务启动后，在控制台配置：client报错
20:52:27.642 [ZkClient-EventThread-13-127.0.0.1:2181] ERROR org.I0Itec.zkclient.ZkEventThread - Error handling event ZkEvent[Data of /motan/motan-ulive-rpc1/command changed sent to com.weibo.api.motan.registry.zookeeper.ZookeeperRegistry$3@20b8330a]
org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.StreamCorruptedException: invalid stream header: 7B22636C
at org.I0Itec.zkclient.serialize.SerializableSerializer.deserialize(SerializableSerializer.java:37)
at org.I0Itec.zkclient.ZkClient.derializable(ZkClient.java:740)
at org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:773)
at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:546)
at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
Caused by: java.io.StreamCorruptedException: invalid stream header: 7B22636C
at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:857)
at java.io.ObjectInputStream.(ObjectInputStream.java:349)
at org.I0Itec.zkclient.serialize.TcclAwareObjectIputStream.(TcclAwareObjectIputStream.java:30)
at org.I0Itec.zkclient.serialize.SerializableSerializer.deserialize(SerializableSerializer.java:31)
... 4 common frames omitted
20:52:27.642 [ZkClient-EventThread-13-127.0.0.1:2181] DEBUG org.I0Itec.zkclient.ZkEventThread - Delivering event #2 done

[rayzhang0603]

看异常应该是管理后台和client使用的zkclient的SerializableSerializer不同导致的，后台写入命令使用的编码方式与client使用的解码方式不同，导致无法解析流量指令。

可以从下面几个方面排查一下问题：

1. 管理后台和client实际使用的zk相关jar包版本是否一致。比如org.apache.zookeeper及com.101tec.zkclient是否因依赖冲突使用了不同的版本。
2. 管理后台和client使用的zkregistry是否一致，即regProtocol的值同为“zookeeper”或者同为“zk”，这是motan提供的两种实现

• zookeeper：使用ZookeeperRegistryFactorySPI实现类，zkclient使用默认的“SerializableSerializer”编码
• zk：使用ZookeeperStringSerializerRegistryFactorySPI实现类，zkclient直接使用utf8的string编码。

3. 如果是其他原因可以参考上面两个SPI扩展实现自己指定的编解码方式，spi扩展方式可以参考这里

[zxn-git]

谢谢，已解决
管理后台是直接下载源码启动的，ZkClient初始化用的是StringSerializer，client默认使用SerializableSerializer