iSharkFly-Demo
/
serialize-deserialize-demo-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

在 Map 中不使用 String 为 Key 的序列化

This commit is contained in:
YuCheng Hu 2019-08-09 20:53:09 -04:00
parent 4d6fdc6933
commit 7883336039
1 changed files with 53 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
src/test/java/com/insight/demo/serialize/MessagePackSerializer.java
View File

@ -5,6 +5,7 @@ import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.insight.demo.serialize.model.msgpack.MessageData;
import com.insight.demo.utils.MockDataUtils;
import org.junit.Assert;
@ -13,6 +14,7 @@ import org.msgpack.core.MessagePack;
import org.msgpack.core.MessagePacker;
import org.msgpack.core.MessageUnpacker;
import org.msgpack.jackson.dataformat.MessagePackFactory;
import org.msgpack.jackson.dataformat.MessagePackKeySerializer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -143,7 +145,6 @@ public class MessagePackSerializer {
e.printStackTrace();
}
}
/**
@ -204,6 +205,57 @@ public class MessagePackSerializer {
}
}
/**
* testMessagePackSerializationMapKey
*/
@Test
@JsonSerialize(keyUsing = MessagePackKeySerializer.class)
public void testMessagePackSerializationMapKey() {
logger.debug("testMessagePackSerializationNotCloseInputStream");
byte[] bytes = new byte[0];
Integer uuid_a = 101;
Integer uuid_b = 102;
// Instantiate ObjectMapper for MessagePack
ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());
Map<Integer, MessageData> map = new HashMap<>();
MessageData messageData = new MessageData();
// Element A in MAP
messageData.setUuid(UUID.randomUUID().toString());
messageData.setName("CWIKI.US - A");
map.put(uuid_a, messageData);
// Element B in MAP
messageData = new MessageData();
messageData.setUuid(UUID.randomUUID().toString());
messageData.setName("CWIKI.US - B");
map.put(uuid_b, messageData);
try {
// Serialize a Java object to byte array
bytes = objectMapper.writeValueAsBytes(map);
logger.debug("Length of Bytes: [{}]", bytes.length);
// Deserialize the byte array to a MAP
Map<String, MessageData> deserialized = objectMapper.readValue(bytes, new TypeReference<Map<Integer, MessageData>>() {
});
logger.debug("Deserialized MAP Count: [{}]", deserialized.size());
logger.debug("MAP index 0: [{}]", deserialized.get(uuid_a).getName());
assertEquals("CWIKI.US - A", deserialized.get(uuid_a).getName());
} catch (JsonProcessingException ex) {
logger.error("Serialize Error", ex);
} catch (IOException e) {
e.printStackTrace();
}
}
@Test
public void testMessagePackSerialization() {
ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());