9

我刚刚失去了几个小时调试我的应用程序,我相信我偶然发现了一个(另一个 o_O)Java 错误......嗅闻......我希望不是,因为这会很伤心 :(

我正在执行以下操作:

  1. 创建mask带有一些标志的 EnumSet
  2. 序列化它(使用ObjectOutputStream.writeObject(mask)
  3. 清除和设置其他一些标志mask
  4. 再次序列化

预期结果:第二个序列化对象与第一个不同(反映实例的变化)

得到的结果:第二个序列化对象是第一个的精确副本

编码:

enum MyEnum {
    ONE, TWO
}

@Test
public void testEnumSetSerialize() throws Exception {           
    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    ObjectOutputStream stream = new ObjectOutputStream(bos);

    EnumSet<MyEnum> mask = EnumSet.noneOf(MyEnum.class);
    mask.add(MyEnum.ONE);
    mask.add(MyEnum.TWO);
    System.out.println("First serialization: " + mask);
    stream.writeObject(mask);

    mask.clear();
    System.out.println("Second serialization: " + mask);
    stream.writeObject(mask);
    stream.close();

    ObjectInputStream istream = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()));

    System.out.println("First deserialized " + istream.readObject());
    System.out.println("Second deserialized " + istream.readObject());
}

它打印:

First serialization: [ONE, TWO]
Second serialization: []
First deserialized [ONE, TWO]
Second deserialized [ONE, TWO]  <<<<<< Expecting [] here!!!!

我使用EnumSet不正确吗?我是否必须每次都创建一个新实例而不是清除它?

感谢您的输入!

**** 更新 ****

我最初的想法是使用 anEnumSet作为掩码来指示在随后的消息中哪些字段将存在或不存在,因此是一种带宽和 cpu 使用优化。大错特错!!!AnEnumSet需要很长时间来序列化,每个实例需要 30 (!!!) 字节!太空经济就这么多:)

简而言之,虽然ObjectOutputStream对于原始类型来说非常快(正如我已经在这里的一个小测试中发现的那样:https : //stackoverflow.com/a/33753694),但对于(尤其是小)对象来说,它非常缓慢且效率低下。 .

因此,我通过使自己的 EnumSet 由 int 支持并直接序列化/反序列化 int(而不是对象)来解决它。

static class MyEnumSet<T extends Enum<T>> {
    private int mask = 0;

    @Override
    public boolean equals(Object o) {
        if (o == null || getClass() != o.getClass()) return false;
        return mask == ((MyEnumSet<?>) o).mask;
    }

    @Override
    public int hashCode() {
        return mask;
    }

    private MyEnumSet(int mask) {
        this.mask = mask;
    }

    public static <T extends Enum<T>> MyEnumSet<T> noneOf(Class<T> clz) {
        return new MyEnumSet<T>(0);
    }

    public static <T extends Enum<T>> MyEnumSet<T> fromMask(Class<T> clz, int mask) {
        return new MyEnumSet<T>(mask);
    }

    public int mask() {
        return mask;
    }

    public MyEnumSet<T> add(T flag) {
        mask = mask | (1 << flag.ordinal());
        return this;
    }

    public void clear() {
        mask = 0;
    }
}

private final int N = 1000000;

@Test
public void testSerializeMyEnumSet() throws Exception {

    ByteArrayOutputStream bos = new ByteArrayOutputStream(N * 100);
    ObjectOutputStream out = new ObjectOutputStream(bos);

    List<MyEnumSet<TestEnum>> masks = Lists.newArrayList();

    Random r = new Random(132477584521L);
    for (int i = 0; i < N; i++) {
        MyEnumSet<TestEnum> mask = MyEnumSet.noneOf(TestEnum.class);
        for (TestEnum f : TestEnum.values()) {
            if (r.nextBoolean()) {
                mask.add(f);
            }
        }
        masks.add(mask);
    }

    logger.info("Serializing " + N + " myEnumSets");
    long tic = TicToc.tic();
    for (MyEnumSet<TestEnum> mask : masks) {
        out.writeInt(mask.mask());
    }
    TicToc.toc(tic);
    out.close();
    logger.info("Size: " + bos.size() + " (" + (bos.size() / N) + "b per object)");

    logger.info("Deserializing " + N + " myEnumSets");
    MyEnumSet<TestEnum>[] deserialized = new MyEnumSet[masks.size()];

    ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()));
    tic = TicToc.tic();
    for (int i = 0; i < deserialized.length; i++) {
        deserialized[i] = MyEnumSet.fromMask(TestEnum.class, in.readInt());
    }
    TicToc.toc(tic);

    Assert.assertArrayEquals(masks.toArray(), deserialized);

}

在序列化过程中大约快 130 倍,在反序列化过程中大约快 25 倍......

我的枚举集:

17/12/15 11:59:31 INFO - Serializing 1000000 myEnumSets
17/12/15 11:59:31 INFO - Elapsed time is 0.019 s
17/12/15 11:59:31 INFO - Size: 4019539 (4b per object)
17/12/15 11:59:31 INFO - Deserializing 1000000 myEnumSets
17/12/15 11:59:31 INFO - Elapsed time is 0.021 s

常规枚举集:

17/12/15 11:59:48 INFO - Serializing 1000000 enumSets
17/12/15 11:59:51 INFO - Elapsed time is 2.506 s
17/12/15 11:59:51 INFO - Size: 30691553 (30b per object)
17/12/15 11:59:51 INFO - Deserializing 1000000 enumSets
17/12/15 11:59:51 INFO - Elapsed time is 0.489 s

虽然它并不安全。例如,它不适用于超过 32 个条目的枚举。

如何确保枚举在创建 MyEnumSet 时的值少于 32 个?

4

1 回答 1

12

ObjectOutputStream 序列化对对象的引用,并在第一次发送对象时序列化实际对象。如果您修改一个对象并再次发送它,那么 ObjectOutputStream 所做的就是再次发送对该对象的引用

这有一些后果

  • 如果您修改一个对象,您将看不到这些修改
  • 它必须在两端保留对曾经发送的每个对象的引用。这可能是一个微妙的内存泄漏。
  • 这样做的原因是您可以序列化对象图而不是树。例如,A 指向 B,而 B 又指向 A。您只想发送 A 一次。

解决这个问题并取回一些内存的方法是在每个完整对象之后调用reset() 。例如在打电话之前flush()

重置将忽略已写入流的任何对象的状态。状态被重置为与新的 ObjectOutputStream 相同。流中的当前点被标记为重置,因此相应的 ObjectInputStream 将在同一点重置。之前写入流的对象不会被称为已经在流中。它们将再次写入流。

另一种方法是使用writeUnshared,但是这会将浅层非共享性应用于顶级对象。在它的情况下EnumSet会有所不同,但是Enum[]它包装的仍然是共享的 o_O

将“非共享”对象写入 ObjectOutputStream。此方法与 writeObject 相同,不同之处在于它始终将给定对象作为流中新的唯一对象写入(与指向先前序列化实例的反向引用相反)。

简而言之,这不是错误,而是预期的行为。

于 2015-12-16T16:27:07.817 回答