Java - 将 MessagePack 时间戳转换为日期

Question

我正在从 Java 项目中的 Apache Beam 管道解码 MessagePack 消息。我正在使用 Maven 将 MessagePack 库作为依赖项导入：

<dependency>
  <groupId>org.msgpack</groupId>
  <artifactId>msgpack-core</artifactId>
  <version>0.8.16</version>
</dependency>

我可以使用它来将 MessagePack 消息解析为 Map 中的键/值对，如下所示：

    @ProcessElement
    public void processElement(ProcessContext c) 
    {
        try 
        {           
            Map<Value, Value> map = MessagePack.newDefaultUnpacker(c.element().getPayload()).unpackValue().asMapValue().map();

该映射包含 MessagePack 'Timestamp' 'extension' 类型的键/值对，如下所示，表示日期/时间（有关 MessagePack 扩展类型的说明，请参见底部的“注释” ):

UTC=(-1,0x5b-161d46)

我可以通过从地图中获取键 UTC 的值来获取此“时间戳”值。我将其作为 MessagePack ExtensionValue 检索，如下所示：

 Value date = map.get(ValueFactory.newString("UTC")).asExtensionValue();

date 是一个具有 2 个属性的对象：

`type` = 1
`data` = `0x5b-161d46`

如何将data 转换为有意义的日期表示？ “数据”应转换为“当前”日期，大约在 2018 年 11 月 16 日左右。这不像将十六进制值转换为十进制那么简单。我是否需要以某种方式单独解压这个data？我怀疑5b-161d46 可能需要被视为一个字节数组，然后以某种方式进行转换。

我可以这样做以将扩展类型的 data 部分作为字节数组获取：

byte[] date = map.get(ValueFactory.newString("UTC")).asExtensionValue().getData();

这给了我[91, -22, 29, 70]

...我可以尝试这样解压：

MessagePack.newDefaultUnpacker(date).unpackValue()

...然而，这只是给了我第一个字节（5b）转换为long，即91

如果我尝试其中任何一个，我会得到org.msgpack.core.MessageTypeCastException，可能是因为unpackValue 只给了我一个long 号码

MessagePack.newDefaultUnpacker(date).unpackValue().asIntegerValue();
MessagePack.newDefaultUnpacker(date).unpackValue().asMapValue();
MessagePack.newDefaultUnpacker(date).unpackValue().asRawValue();

我还尝试了以下方法：

MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(date);
    while(unpacker.hasNext()) {
        MessageFormat f = unpacker.getNextFormat();
            switch(f) {
                case POSFIXINT:
                case NEGFIXINT: {
                    int v = unpacker.unpackInt();
                    break;
                }
             }
    }

数组中的值被识别为POSFIXINT 或NEGFIXINT，因此我可以使用它来提取数组中每个字节的十进制整数值，但是这只允许我提取@987654348 中的元素@array 作为整数，我仍然不知道如何将其转换为日期。

我需要如何解释/解包这些日期？

---

注意 - 扩展值是 MessagePack 值的特殊类型，表示为 -1 定义扩展类型的元组。 -1 是 MessagePack timestamp 的保留扩展名，其余的 给出一个十六进制值（0x5b-161d46）：

https://github.com/msgpack/msgpack/blob/master/spec.md#timestamp-extension-type

Answer 1

我想通了！一、简版（Java中如何将MessagePack时间戳值转换为有意义的数字）：

import java.nio.ByteBuffer

byte[] timestampValues = myTimestampExtensionValue.asExtensionValue().getData();                            
ByteBuffer wrapped = ByteBuffer.wrap(timestampValues);
Long dateValue = wrapped.getLong();

---

在我自己的情况下，我收到日期作为时间戳扩展值作为映射中键/值对的一部分，如下所示：

UTC=(-1,0x5b-e28-35)

这可能是各种格式，这非常令人困惑，例如：

(-1,0x5b-1b6f-24)
(-1,0x5b-1b7056)
(-1,0x5b-1b58-4)

我发现如果我这样做：

byte[] date = map.get(ValueFactory.newString("UTC")).asExtensionValue().getData();

... 它总是给我一个 32 位字节数组。对于我的示例UTC=(-1,0x5b-e28-35)，我得到：

[91, -14, 40, -53]

这也让我感到困惑 - 我看不出这怎么可能是一个整数。要认识到这些是 有符号字节，其中负值是 从该字节的最大值中减去的值，即 255。

我不确定为什么会发生这种情况（可能是为了通过减少每个字节内的空间来节省内存）。无论如何，上面的例子转换成十进制如下：

[91, 241, 40, 202]

在 Java 中有一种简单的方法可以将原始字节数组 [91, -14, 40, -53] 转换为整数，方法是导入 java.nio.ByteBuffer 并使用：

ByteBuffer wrapped = ByteBuffer.wrap(date);
Integer num = wrapped.getInt();

在我的示例中，这给了我们1542596811，结果是 自 Unix 纪元以来的秒数。因此，如果我们将其转换为毫秒，我们现在有1542596811000，或者日期为Mon 19 November 2018, 14:06:51。简单！