zookeeper報錯: org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.EOFException
阿新 • • 發佈:2018-11-11
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字串 */ publicObject 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)); } }
參考資料: