0

我正在构建一个处理二进制反序列化的类。该方法open()接收一个InputStream和一个OutputStream。这些是由另open()一种接收路径作为参数的方法创建的。InputStream实际上是一个ByteArrayInputStream. 我已经做了一些测试来证明该方法InputStream正在到达open()带有内容的方法 - 实际上是。但是当我尝试设置一个ObjectInputStream使用它时，它不起作用。没有抛出异常，但是当我尝试从中读取字节时，它总是给我-1.

二进制策略类

public class BinaryStrategy implements SerializableStrategy{
  public BinaryStrategy(){
    try{
        open("products.ser");
    }catch(IOException ioe){

    }
  } 
  @Override
  public void open(InputStream input, OutputStream output) throws IOException  {
    try{
        this.ois = new ObjectInputStream(input);
    }catch(Exception ioe){
        System.out.println(ioe);
    }
    this.oos = new ObjectOutputStream(output);
  }
  @Override
  public void writeObject(fpt.com.Product obj) throws IOException {
    oos.writeObject(obj);
    oos.flush();
  }
  @Override
  public Product readObject() throws IOException {
    Product read = new Product();
    try{
        read.readExternal(ois);
    }catch(IOException | ClassNotFoundException exc){
        System.out.println(exc);
    }
    return read;
  }
}

接口 SerializableStrategy （只是默认方法）

    default void open(Path path) throws IOException {
    if (path != null) {
        ByteArrayInputStream in = null;
        if (Files.exists(path)) {
            byte[] data = Files.readAllBytes(path);
            in = new ByteArrayInputStream(data);
        }
        OutputStream out = Files.newOutputStream(path);
        open(in, out);
    }

产品类别

public class Product implements java.io.Externalizable {
    @Override
public void writeExternal(ObjectOutput out) throws IOException {
    out.writeLong(getId());
    out.writeObject(getName());
    out.writeObject(getPrice());
    out.writeObject(getQuantity());
}

@Override
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
    this.setId((Long)in.readLong());
    this.setName((String) in.readObject());
    this.setPrice((Double) in.readObject());
    this.setQuantity((Integer) in.readObject());
}

我不得不个性化它，因为属性是SimplePropertys

在public void open(InputStream input, OutputStream output)我尝试做一些如下的事情来测试：

    public void open(InputStream input, OutputStream output) throws IOException {
    try{
        System.out.println(input.available() + " " + input.read() + " " + input.read());
        //is gives me: 181 172 237
        //181 is the exact size of the file I have, so i think that the Output is ok
        //172 237 - just some chars that are in the file
        //I know that for now on it is going to give me an excepetion because
        // of the position of the index that is reading. I did it just to test
        this.ois = new ObjectInputStream(input);
    }catch(Exception ioe){
        System.out.println(ioe);
    }
    this.oos = new ObjectOutputStream(output);
}

然后是另一个测试：

public void open(InputStream input, OutputStream output) throws IOException {
    try{
        this.ois = new ObjectInputStream(input);
        System.out.println(ois.available() + " " + ois.read());
        //here is where I am receiving -1 and 0 available bytes!
        //so something is going wrong right here.
        //i tried to just go on and try to read the object,
        //but I got a EOFException, in other words, -1.
    }catch(Exception ioe){
        System.out.println(ioe);
    }
    this.oos = new ObjectOutputStream(output);
}
4

3 回答 3

2

请检查由 代表的文件path是否有写入 java 对象。
来自 ObjectInputStream API 文档https://docs.oracle.com/javase/7/docs/api/java/io/ObjectInputStream.html

ObjectInputStream 反序列化以前使用 ObjectOutputStream 编写的原始数据和对象。

ObjectInputStream 用于恢复之前序列化的那些对象。

如果您正在执行 a this.ois.readObject()，并且得到 a -1，则文件中可能不包含对象。

更新：readObject返回一个对象而不是一个int. 如果您正在使用 中的read方法ois，并且您得到一个-1，那么该文件是空的。

此外，您的文件有可能包含-1作为其内容；）

于 2016-05-14T15:04:44.793 回答
0

问题是我读ObjectInputStream错了。这就像是：

read.readExternal(ois);

但正确的方法是：

read = (Product)ois.readObject();

由于我这样做时遇到了异常，我认为问题出ObjectInputStream在使用ByteArrayInputStream. 多么大的错误！:D

感谢所有试图提供帮助的人。

于 2016-05-14T16:56:13.807 回答
0

ObjectInputStream, 内部使用 aBlockDataInputStream执行其读取操作。当您调用read. 只有当它作为“块”落下时它才会读取一个字节

输出也不是我所期望的。但是，如果您查看 的代码ObjectInputStream.read()，它是有道理的。

readObject因此，在您的情况下，仅用于恢复对象的状态是有意义的。

再次继承你的代码......

class SimpleJava {

    public static void open(InputStream input, OutputStream output) throws IOException {

        try {
            ObjectInputStream ois = new ObjectInputStream(input);
            System.out.println(ois.available());// 0
            System.out.println(ois.available() + " " + ois.read() + " " + ois.read());// 0 -1 -1
            // Reads the object even if the available returned 0 
            // and ois.read() returned -1
            System.out.println("object:" + ois.readObject());// object:abcd
        }
        catch (Exception ioe) {
            ioe.printStackTrace();
        }
    }

    static void open(Path path) throws IOException {

        if (path != null) {
            ByteArrayInputStream in = null;
            if (Files.exists(path)) {
                byte[] data = Files.readAllBytes(path);
                in = new ByteArrayInputStream(data);
            }
            OutputStream out = Files.newOutputStream(path);
            open(in, out);
        }
    }

    public static void main(String[] args) throws Exception {

        ObjectOutputStream oos = new ObjectOutputStream(new FileOutputStream(new File("/home/pradhan/temp.object")));
        oos.writeObject("abcd");//writes a string object for us to read later
        oos.close();
        //
        open(FileSystems.getDefault().getPath("/home/user/temp.object"));
    }
}

这是输出...

0
0 -1 -1
object:abcd
于 2016-05-14T17:41:34.330 回答