我正在一个Java项目中解码Apache管道中的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‘时间戳’扩展‘类型的键/值对,它表示日期/时间(有关MessagePack扩展类型的解释,请参见底部的“注意”):
UTC=(-1,0x5b-161d46)通过使用UTC键从地图中获取值,我可以得到这个‘时间戳’值。我将其检索为MessagePack ExtensionValue,如下所示:
Value date = map.get(ValueFactory.newString("UTC")).asExtensionValue();然后,date是一个具有两个属性的对象:
`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,因此我可以使用它提取数组中每个字节的十进制整数值,但是这只允许我将date数组中的元素提取为整数,而且我仍然不知道如何将其转换为日期。
我需要如何解释/解压这些日期?
Note -扩展值是MessagePack值的特殊类型,表示为元组,其中
-1定义扩展类型。-1是MessagePacktimestamp的保留扩展名,其余部分给出了十六进制值(0x5b-161d46): https://github.com/msgpack/msgpack/blob/master/spec.md#timestamp-extension-type
发布于 2018-11-19 03:29:28
我想出来了!首先,简短的版本(如何将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的日期。很简单!
https://stackoverflow.com/questions/53331266
复制相似问题