Skip to content

Fix msgpack core usage example #350

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
naritta merged 1 commit into from
Feb 24, 2016
Merged

Fix msgpack core usage example #350

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 12 additions & 19 deletions msgpack-core/src/test/java/org/msgpack/core/example/MessagePackExample.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,27 +15,23 @@
//
package org.msgpack.core.example;

import org.msgpack.core.MessageFormat;
import org.msgpack.core.MessagePack;
import org.msgpack.core.*;
import org.msgpack.core.MessagePack.PackerConfig;
import org.msgpack.core.MessagePack.UnpackerConfig;
import org.msgpack.core.MessagePacker;
import org.msgpack.core.MessageUnpacker;
import org.msgpack.value.ArrayValue;
import org.msgpack.value.ExtensionValue;
import org.msgpack.value.FloatValue;
import org.msgpack.value.IntegerValue;
import org.msgpack.value.Value;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.math.BigInteger;

/**
* This class describes the usage of MessagePack v07
* This class describes the usage of MessagePack
*/
public class MessagePackExample
{
Expand All @@ -51,19 +47,19 @@ private MessagePackExample()
public static void basicUsage()
throws IOException
{
// Serialize with MessagePacker
ByteArrayOutputStream out = new ByteArrayOutputStream();
MessagePacker packer = MessagePack.newDefaultPacker(out);
// Serialize with MessagePacker.
// MessageBufferPacker is an optimized version of MessagePacker for packing data into a byte array
MessageBufferPacker packer = MessagePack.newDefaultBufferPacker();
packer
.packInt(1)
.packString("leo")
.packArrayHeader(2)
.packString("xxx-xxxx")
.packString("yyy-yyyy");
packer.close();
packer.close(); // Never forget to close (or flush) the buffer

// Deserialize with MessageUnpacker
MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(out.toByteArray());
MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(packer.toByteArray());
int id = unpacker.unpackInt(); // 1
String name = unpacker.unpackString(); // "leo"
int numPhones = unpacker.unpackArrayHeader(); // 2
Expand Down Expand Up @@ -97,8 +93,7 @@ public static void packer()
throws IOException
{
// Create a MesagePacker (encoder) instance
ByteArrayOutputStream out = new ByteArrayOutputStream();
MessagePacker packer = MessagePack.newDefaultPacker(out);
MessageBufferPacker packer = MessagePack.newDefaultBufferPacker();

// pack (encode) primitive values in message pack format
packer.packBoolean(true);
Expand Down Expand Up @@ -181,8 +176,7 @@ public static void readAndWriteFile()
// Here is a list of message pack data format: https://github.com/msgpack/msgpack/blob/master/spec.md#overview
MessageFormat format = unpacker.getNextFormat();

// Alternatively you can use ValueHolder to extract a value of any type
// NOTE: Value interface is in a preliminary state, so the following code might change in future releases
// You can also use unpackValue to extract a value of any type
Value v = unpacker.unpackValue();
switch (v.getValueType()) {
case NIL:
Expand Down Expand Up @@ -245,17 +239,16 @@ else if (iv.isInLongRange()) {
public static void configuration()
throws IOException
{
ByteArrayOutputStream out = new ByteArrayOutputStream();
MessagePacker packer = new PackerConfig()
MessageBufferPacker packer = new PackerConfig()
.withSmallStringOptimizationThreshold(256) // String
.newPacker(out);
.newBufferPacker();

packer.packInt(10);
packer.packBoolean(true);
packer.close();

// Unpack data
byte[] packedData = out.toByteArray();
byte[] packedData = packer.toByteArray();
MessageUnpacker unpacker = new UnpackerConfig()
.withStringDecoderBufferSize(16 * 1024) // If your data contains many large strings (the default is 8k)
.newUnpacker(packedData);
Expand Down