zookeeper报错: org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.EOFException
2023-09-14 09:11:44 时间
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)); } }
参考资料:
相关文章
- Jmeter里的全能java测试sampler - Java request
- ZooKeeper学习之-Zookeeper简单介绍(一)
- zookeeper原生API做java客户端
- java中替换文件内容
- spring boot: java @interface注解
- JAVA学习(三):Java基础语法(变量、常量、数据类型、运算符与数据类型转换)
- Java实现 洛谷 P3916 图的遍历(反向DFS+记忆化搜索)
- Java实现 LeetCode 522 最长特殊序列 II(查找最长的非子序列的长度)
- Java实现 蓝桥杯VIP 算法训练 数组查找及替换问题
- 【JAVA】Java 异常中e的getMessage()和toString()方法的异同
- Java软件生产监控工具Btrace的使用
- 【JAVA】 04-Java中的多线程
- java代码编译得到smali代码
- macos:安装java 17.0.6(android studio报错:Unable to locate a Java Runtime.)
- Atitit. servlet 与 IHttpHandler ashx listen 和HttpModule的区别与联系 原理理论 架构设计 实现机制 java php c#.net j
- atitit. java跟php的比较..为什么大企业喜欢java 而不是php
- 详解jvm之java类加载机制和类加载器(ClassLoader) 深入理解Java类加载器(ClassLoader) 如何自定义类加载器 深入说明双亲委派 双亲委派模型的破坏者-线程上下文类加载器
- java 字符型转换成浮点型
- java 程序运行的基础知识【Java bytecode】
- Java IO:SocketChannel和Selector在ZooKeeper中应用
- JAVA语言之Java 中不同的并行实现的性能比较
- Java开发之高并发必备篇(七)——线程池
- java 解析域名得到host
- 【java】Java线程池实现原理及业务中的实践