如何使用 Jackson 序列化/反序列化 java.util.stream.Stream？

Question

假设我有以下对象

public class DataObjectA {
    private Stream<DataObjectB> dataObjectBStream;
}

如何使用 Jackson 对它们进行序列化？

Answer 1

下面的类有 2 个元素，其中一个是 Stream，必须用 @JsonSerializer 注释 getterStream 方法，然后重写 Serialize 方法，在我的响应 API 中生成 JSON 流：

公共类 DataSetResultBean 扩展 ResultBean { private static final long serialVersionUID = 1L;

private final List<ComponentBean> structure;
private final Stream<DataPoint> datapoints;

private static class DataPointSerializer extends JsonSerializer<Stream<DataPoint>> 
{
    @Override
    public void serialize(Stream<DataPoint> stream, JsonGenerator gen, SerializerProvider serializers) throws IOException, JsonProcessingException
    {
        gen.writeStartArray();
        try
        {
            stream.forEach(dp -> serializeSingle(gen, dp));
        }
        catch (UncheckedIOException e)
        {
            throw (IOException) e.getCause();
        }
        finally
        {
            stream.close();
        }
        gen.writeEndArray();
    }
    
    public synchronized void serializeSingle(JsonGenerator gen, DataPoint dp) throws UncheckedIOException
    {
        try
        {
            gen.writeStartObject();
            
            for (Entry<DataStructureComponent<?, ?, ?>, ScalarValue<?, ?, ?>> entry: dp.entrySet())
            {
                gen.writeFieldName(entry.getKey().getName());
                gen.writeRawValue(entry.getValue().toString());
            }
            
            gen.writeEndObject();
        }
        catch (IOException e)
        {
            throw new UncheckedIOException(e);
        }
    }
}

public DataSetResultBean(DataSet dataset)
{
    super("DATASET");
    
    structure = dataset.getMetadata().stream().map(ComponentBean::new).collect(toList());
    datapoints = dataset.stream();
}

public List<ComponentBean> getStructure()
{
    return structure;
}

@JsonSerialize(using = DataPointSerializer.class)
public Stream<DataPoint> getDatapoints()
{
    return datapoints;
}

}

Answer 2

请参阅 https://github.com/FasterXML/jackson-modules-java8/issues/3 以获取未解决的问题，以向 Jackson 添加 java.util.Stream 支持。包含代码的初步版本。 （编辑：现在在 2.9.0 中合并和支持）。

如果流是您正在（反）序列化的顶级对象，流支持感觉它会自然/安全地工作，例如从 JAX-RS 资源返回 java.util.stream.Stream<T>，或从 JAX 读取 Stream -RS 客户端。

正如您在示例中所做的那样，作为（反）序列化对象的成员变量的 Stream 比较棘手，因为它是可变的且一次性使用：

private Stream<DataObjectB> dataObjectBStream;

假设它被支持，所有关于存储对流的引用的警告都将适用。您不能多次序列化对象，并且一旦您反序列化包装对象，大概它的流成员将通过 JAX-RS 客户端和 HTTP 连接保留实时连接，这可能会造成意外。

Answer 3

正如其他人指出的那样，您只能在流上迭代一次。如果这对您有用，您可以使用它来序列化：

new ObjectMapper().writerFor(Iterator.class).writeValueAsString(dataObjectBStream.iterator())

如果您使用的是 2.5 之前的 Jackson 版本，请使用 writerWithType() 而不是 writerFor()。

Answer 4

你没有。

Stream 是一次性的操作链，绝不意味着持久。即使将其存储到您的问题中的实例字段中，也表明对其目的存在误解。一旦对流应用了终端操作，它就毫无用处，并且无法克隆流。这样的话，记住字段中不可用的流是没有意义的。

由于Stream 提供的唯一操作是将更多操作链接到管道并最终对其进行评估，因此无法查询其状态以允许创建与其行为有关的等效流时间>。因此，没有任何持久化框架可以存储它。框架唯一能做的就是遍历流操作的结果元素并存储它们，但这意味着有效地存储一种对象集合而不是Stream。除此之外，Stream 的一次性使用性质还意味着遍历流以存储元素的存储框架具有同时使流不可用的副作用。

如果要存储元素，请使用普通的Collection。

另一方面，如果你真的想存储行为，你最终会存储一个对象实例，它的实际类实现了该行为。这仍然适用于Streams，因为您可以存储一个类的实例，该实例具有产生所需流的工厂方法。当然，您存储的并不是真正的行为，而是对它的符号引用，但是当您使用 OO 存储框架来存储行为而不是数据时，情况总是如此。