您好，我需要将字节数组作为对象来读取。但是，每当我尝试时，它都会打印出 Stream CorruptedException。

下面是我写的代码

public class TestSave {
    public static void main(String[] args) {
        String key = "redismap";
        Map<String, Object> map = new HashMap<String, Object>();
        List<String> list = new ArrayList<String>();

        map.put("String", "test");
        map.put("List", list);

        ObjectOutputStream oos = null;
        ByteArrayOutputStream bos = null;

        JedisHelper helper = JedisHelper.getInstacne();
        Jedis connection = helper.getConnection();

        try{
            bos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(bos);
            oos.writeObject(map);
            byte[] value = bos.toByteArray();           
            oos.close();
            connection.set(key.getBytes(), value);
        }catch(Exception e){e.printStackTrace();}
        helper.returnResource(connection);
        helper.destroyPool();
        System.out.println("DONE!");
    }
}

那么，这是读取代码

public class TestWithdaw {
    public static void main(String[] args) {
        JedisHelper helper = JedisHelper.getInstacne();
        Jedis connection = helper.getConnection();
        String key = "redismap";
        String result = connection.get(key);
        byte[] primalData = result.getBytes();
        System.out.println("Byte Arrays : " + Arrays.toString(primalData));

        ByteArrayInputStream bis = null;
        ObjectInputStream ois = null;

        try{
            bis = new ByteArrayInputStream(primalData);
            ois = new ObjectInputStream(bis);
            Object resultMap = ois.readObject();

            System.out.println("resultMap : " + resultMap);
            ois.close();
        }catch(Exception e){e.printStackTrace();}
        helper.returnResource(connection);
        helper.destroyPool();
    }
}

这就是我收到的错误消息。

java.io.StreamCorruptedException: invalid stream header: EFBFBDEF
    at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804)
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299)
    at org.owls.redis.test.TestWithdaw.main(TestWithdaw.java:28)

我不明白这个流 header 有什么问题。 这些是我已经尝试过的:-

1. 在编写代码时将List 更改为Vector。 (串行问题)

谢谢你帮助我:D

最佳答案

我认为问题出在您对序列化字节的存储和检索 - 执行序列化和反序列化的代码本身没问题。

没有中间存储，代码可以工作，如下所示:

  ByteArrayOutputStream bos = new ByteArrayOutputStream();
  ObjectOutputStream oos = new ObjectOutputStream(bos);
  oos.writeObject(map);
  byte[] value = bos.toByteArray();
  oos.close();

  for (byte b : value)
  {
    System.out.print(Integer.toHexString(0xff & b) + " ");
  }
  System.out.println("");

  final ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(value));
  final Object read = ois.readObject();

  System.out.println("read: " + read);

这会产生:

ac ed 0 5 73 72 0 11 6a 61 76 61 2e 75 74 69 6c 2e 48 61 73 68 4d 61 70 5 7 da c1 c3 16 60 d1 3 0 2 46 0 a 6c 6f 61 64 46 61 63 74 6f 72 49 0 9 74 68 72 65 73 68 6f 6c 64 78 70 3f 40 0 0 0 0 0 c 77 8 0 0 0 10 0 0 0 2 74 0 6 53 74 72 69 6e 67 74 0 4 74 65 73 74 74 0 4 4c 69 73 74 73 72 0 13 6a 61 76 61 2e 75 74 69 6c 2e 41 72 72 61 79 4c 69 73 74 78 81 d2 1d 99 c7 61 9d 3 0 1 49 0 4 73 69 7a 65 78 70 0 0 0 0 77 4 0 0 0 0 78 78

read: {List=[], String=test}

你会看到我们发现字节流的开头是ac ed 00 05 73，它是以下Java对象序列化规范常量:

• STREAM_MAGIC
• STREAM_VERSION
• TC_OBJECT

因此，您的调查应该集中在为什么您的原始数据与最初生成的数据不匹配。

让我们朝那个方向继续(免责声明:我从未使用过 Redis)...

您可以使用以下代码从 Redis 取回数据:

String key = "redismap";
String result = connection.get(key);
byte[] primalData = result.getBytes();

在这里，您将数据作为 Java String 取回，然后使用 Java VM 的默认编码方案获取字节。这可能与 Redis 使用的编码表示不同。

为什么不使用返回 byte[] 的版本？那将是:

String key = "redismap";
byte[] primalData = connection.get(key.getBytes());

这很可能在任何 String 到 byte[] 编码和解码中都是一致的。

关于java - 读取对象时发生 StreamCorrupedException，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22500807/