zookeeper报错： org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.EOFException
主要因为是没有序列化。
可以使用默认的序列化类。如下所示：
zkClient.setZkSerializer( new SerializableSerializer());
但是使用默认的SerializableSerializer()查看节点数据时，有可能会出现乱码。
我们可以通过实现ZkSerialized接口来自定义序列化类。
首先在pom.xml中添加依赖包guava，如下所示：
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>25.1-jre</version>
</dependency>
自定义序列化类，如下：
public class MyZkSerializer implements ZkSerializer {
/**
* 序列化，将对象转化为字节数组
*/
public byte[] serialize(Object obj) throws ZkMarshallingError {
return String.valueOf(obj).getBytes(Charsets.UTF_8);
}
/**
* 反序列化，将字节数组转化为UTF_8字符串
*/
public Object deserialize(byte[] bytes) throws ZkMarshallingError {
return new String(bytes, Charsets.UTF_8);
}
}
接下来只要设置序列化方式就可以了。
zkClient.setZkSerializer(new MyZkSerializer());
如下所示：
/**
* 获取节点数据
*/
public class PathData {
private static Logger logger=Logger.getLogger(PathData.class); public static void main(String[] args) {
String zkServer="127.0.0.1:2181";
String path="/zk-permanent";
ZkClient zkClient=new ZkClient(zkServer,5000);
logger.info("使用zkClient查询节点数据：");
//zkClient需要设置序列化后，才可以获取节点数据。不然会报错：ZkMarshallingError: java.io.EOFException
//默认的SerializableSerializer()可以会出现乱码。以下采用自定义的序列化设置
// zkClient.setZkSerializer( new SerializableSerializer());
zkClient.setZkSerializer(new MyZkSerializer());
zkClient.subscribeDataChanges(path, new IZkDataListener() {
@Override
public void handleDataChange(String dataPath, Object data) throws Exception {
logger.debug("Node:" +dataPath+" changed, new data:"+data);
} @Override
public void handleDataDeleted(String dataPath) throws Exception {
logger.debug("Node:"+dataPath+"deleted");
}
});
logger.debug(path+"节点下的数据为："+ zkClient.readData(path)); }
}
参考资料：