1

我打算在我们的项目中使用 Messagepack。目前,我们在项目中使用 JSON,并且正在将序列化 JSON 文档写入 Cassandra。现在我们正在考虑使用 Messagepack,它是一种高效的二进制序列化格式。

我正在尝试找到一个很好的示例,该示例显示我在 JSON 文档上使用 Messagepack,但我还没有找到它。

下面是我的主要类代码,它将使用 Value 类使用 Jackson 制作 JSON 文档,然后使用 ObjectMapper 序列化 JSON。

public static void main(String[] args) {

    Map<String, Object> properties = new HashMap<String, Object>();
    properties.put("id", 123);
    properties.put("test", 200);
    properties.put("marks", 100);

    Value val = new Value();
    val.setProperties(properties);

    MessagePack msgpack = new MessagePack();
    // Serialize
    byte[] raw = msgpack.write(av);

    System.out.println(raw);

            // deserialize
    Value actual = new MessagePack().read(raw, Value.class);

    System.out.println(actual);
}

下面是我的 Value 类,它使用 Jackson 制作 JSON 文档,并将使用 ObjectMapper 序列化文档并使用 Messagepack。

@JsonPropertyOrder(value = { "v" })
@Message
public class Value {

    private Map<String, Object> properties;

    /**
     * Default constructor.
     */
    @JsonCreator
    public Value() {
        properties = new HashMap<String, Object>();
    }


    /**
     * Gets the properties of this attribute value.
     * @return the properties of this attribute value.
     */
    @JsonProperty("v")
    public Map<String, Object> getProperties() {
        return properties;
    }

    /**
     * Sets the properties of this attribute value.
     * @param v the properties of this attribute value to set
     */
    @JsonProperty("v")
    public void setProperties(Map<String, Object> v) {
        properties = v;
    }


    @Override
    public String toString() {
        try {
            return new ObjectMapper().writerWithDefaultPrettyPrinter().writeValueAsString(this);
        } catch (Exception e) {
            // log exception
        }

        return ToStringBuilder.reflectionToString(this);
    }    
}

但是,我不确定如何在这个 JSON 文档上使用 Messagepack?谁能给我一些例子吗?

但是我想,让我们尝试一下,每当我尝试在上面的代码中使用这样的 Messagepack 时-

    MessagePack msgpack = new MessagePack();
    // Serialize
    byte[] raw = msgpack.write(av);

我总是遇到如下异常-

Exception in thread "main" org.msgpack.MessageTypeException: Cannot find template for class java.lang.Object class.  Try to add @Message annotation to the class or call MessagePack.register(Type).

而且我相信 MessagePack 不允许用户序列化 java.lang.Object 类型的变量,但就我而言,不可能将属性类型替换为某些原始类型。

我在我的 HashMap 中使用 Object,我需要它是这样的..

4

1 回答 1

0

与其尝试MessagePack,您是否考虑过使用微笑,这是一种高效、100% 与 JSON API 兼容的二进制数据格式。它应该匹配或超过MessagePack速度,并产生更紧凑的输出。杰克逊在以下地点实施:

https://github.com/FasterXML/jackson-dataformat-smile

这将与对象格式“正常工作”。所以而不是:

String json = new ObjectMapper().writeValueAsString(value);

你会用

byte[] smileEncoded = new ObjectMapper(new SmileFactory()).writeValueAsBytes(value);

所有 Jackson 代码的工作方式都类似于 JSON,包括 JAX-RS 提供程序、数据类型(Guava、Joda、Hibernate 等)等。因此,您不会失去 JSON 的便利性(除了像所有二进制格式一样,Smile 不如 JSON 可读),而是获得存储和性能效率。

于 2013-09-17T03:54:13.480 回答