zookeeper報錯： org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.EOFException

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));

    }
}

 

參考資料：

https://blog.csdn.net/zwt0909/article/details/51737750