import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public WampClient(DataFormat dataFormat) {
	this.isBinary = dataFormat != DataFormat.JSON;
	this.result = new CompletableFutureWebSocketHandler();
	this.headers = new WebSocketHttpHeaders();

	switch (dataFormat) {
	case CBOR:
		this.jsonFactory = new ObjectMapper(new CBORFactory()).getFactory();
		this.headers.setSecWebSocketProtocol(WampSubProtocolHandler.CBOR_PROTOCOL);
		break;
	case MSGPACK:
		this.jsonFactory = new ObjectMapper(new MessagePackFactory()).getFactory();
		this.headers.setSecWebSocketProtocol(WampSubProtocolHandler.MSGPACK_PROTOCOL);
		break;
	case JSON:
		this.jsonFactory = new MappingJsonFactory(new ObjectMapper());
		this.headers.setSecWebSocketProtocol(WampSubProtocolHandler.JSON_PROTOCOL);
		break;
	case SMILE:
		this.jsonFactory = new ObjectMapper(new SmileFactory()).getFactory();
		this.headers.setSecWebSocketProtocol(WampSubProtocolHandler.SMILE_PROTOCOL);
		break;
	default:
		this.jsonFactory = null;
	}

}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Test
public void requestBodyConverter()
        throws IOException, InterruptedException
{
    ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());

    Pojo requestPojo = new Pojo(42, (float) Math.PI, "Hello");
    Pojo responsePojo = new Pojo(99, 1.23f, "World");
    server.enqueue(new MockResponse().setBody(
            new Buffer().write(objectMapper.writeValueAsBytes(responsePojo))));

    Response<Pojo> response = service.postPojo(requestPojo).execute();
    assertThat(response.body(), is(responsePojo));

    RecordedRequest recordedRequest = server.takeRequest();
    Pojo recordedPojo = objectMapper.readValue(recordedRequest.getBody().readByteArray(), Pojo.class);
    assertThat(recordedPojo, is(requestPojo));
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Override
public ServiceResponse<String> toJson(byte bytes[]) {

    ByteArrayOutputStream bos = new ByteArrayOutputStream();

    try {
        // read message pack
        ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());
        JsonNode node = objectMapper.readTree(bytes);

        // write json
        JsonFactory jsonFactory = new JsonFactory();
        JsonGenerator jsonGenerator = jsonFactory.createGenerator(bos);

        objectMapper.writeTree(jsonGenerator, node);
    } catch (IOException | NullPointerException e) {
        LOGGER.error("Exception converting message pack to JSON", e);
        return ServiceResponseBuilder.<String>error().build();
    }

    return ServiceResponseBuilder.<String>ok().withResult(new String(bos.toByteArray())).build();

}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Override
public ServiceResponse<byte[]> fromJson(String json) {

    ByteArrayOutputStream bos = new ByteArrayOutputStream();

    try {
        // read json
        ObjectMapper objectMapper = new ObjectMapper(new JsonFactory());
        JsonNode node = objectMapper.readTree(json);

        // write message pack
        MessagePackFactory messagePackFactory = new MessagePackFactory();
        JsonGenerator jsonGenerator = messagePackFactory.createGenerator(bos);

        objectMapper.writeTree(jsonGenerator, node);
    } catch (IOException e) {
        LOGGER.error("Exception converting message pack to JSON", e);
        return ServiceResponseBuilder.<byte[]>error().build();
    }

    return ServiceResponseBuilder.<byte[]>ok().withResult(bos.toByteArray()).build();

}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
protected Buffer(final Config config)
{
    this.config = config;
    if (config.getFileBackupDir() != null) {
        fileBackup = new FileBackup(new File(config.getFileBackupDir()), this, config.getFileBackupPrefix());
    }
    else {
        fileBackup = null;
    }

    objectMapper = new ObjectMapper(new MessagePackFactory());
    List<Module> jacksonModules = config.getJacksonModules();
    for (Module module : jacksonModules) {
        objectMapper.registerModule(module);
    }
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public CompletableFutureWebSocketHandler(int expectedNoOfResults) {
	this.jsonFactory = new MappingJsonFactory(new ObjectMapper());
	this.msgpackFactory = new ObjectMapper(new MessagePackFactory()).getFactory();
	this.cborFactory = new ObjectMapper(new CBORFactory()).getFactory();
	this.smileFactory = new ObjectMapper(new SmileFactory()).getFactory();
	this.timeout = getTimeoutValue();
	this.welcomeMessageFuture = new CompletableFuture<>();
	this.reset(expectedNoOfResults);
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public MsgPackJackson() {
	super(new ObjectMapper(new MessagePackFactory()));

	// Install MongoDB / BSON serializers
	// (Using JSON serializers)
	tryToAddSerializers("io.datatree.dom.adapters.JsonJacksonBsonSerializers", mapper);
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@SuppressWarnings("ConstantConditions") // Guarding public API nullability.
public static MessagePackConverterFactory create(ObjectMapper mapper)
{
    if (mapper == null) {
        throw new IllegalArgumentException("'mapper' is null");
    }

    if (!(mapper.getFactory() instanceof MessagePackFactory)) {
        throw new IllegalArgumentException("'mapper' doesn't have MessagePackFactory");
    }

    return new MessagePackConverterFactory(mapper);
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Test
public void serialize()
        throws JsonProcessingException
{
    long now = System.currentTimeMillis();
    EventTime eventTime = EventTime.fromEpoch((int) (now / 1000), 999999999);
    ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());
    byte[] bytes = objectMapper.writeValueAsBytes(eventTime);
    ByteBuffer byteBuffer = ByteBuffer.wrap(bytes);
    assertThat(byteBuffer.get(), is((byte) 0xD7));
    assertThat(byteBuffer.get(), is((byte) 0x00));
    assertThat(byteBuffer.getInt(), is((int) (now / 1000)));
    assertThat(byteBuffer.getInt(), is(999999999));
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Test
public void messagePack() throws IOException {
    ObjectMapper mapper = new ObjectMapper( new MessagePackFactory() );
    User user = mockUser();
    byte[] bytes = mapper.writeValueAsBytes( user );
    logger.debug( new String( bytes ) );
    mapper.readValue( bytes, User.class );
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public MsgPackJacksonCodec() {
    super(new ObjectMapper(new MessagePackFactory()));
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public void updateFromADFile(int attempt) {
    error = false;
    if (attempt > 2) {
        failCheckCount++;
        if (failCheckCount > 5) {

            KRFAM.log(codeName + " > Failed to read A.D > Abort");
            KRFAM.Toast("Failed to access '" + codeName + "' A.D.\nDid you allow KRFAM root access?");
            return;
        }
        KRFAM.delayAction(new Runnable() {
            @Override
            public void run() {
                updateFromADFile();
            }
        }, 200*failCheckCount);
        error = true;
        return;
    }
    if (installed == true) {
        if (adFile.exists()) {
            try {
                boolean flag1 = false;

                InputStream is = new FileInputStream(SaveFile);
                LittleEndianDataInputStream binaryReader = new LittleEndianDataInputStream(is);

                int num1 = binaryReader.readInt();
                int num2 = num1 & 0x7F;
                KRFAM.log("Save data Version: " + ((num1 & 65280) >> 8));
                int b = (binaryReader.readByte() & 0xff);
                int count1 = b - num2;

                byte[] iv = new byte[count1];
                KRFAM.log("IV Length: " + count1);
                binaryReader.read(iv, 0, count1);
                for (int index = 0; index < iv.length; ++index) iv[index] -= (byte) (96 + (int) (byte) index);
                String _iv = new String(iv);
                KRFAM.log("IV: " + _iv);
                int count2 = binaryReader.readInt();
                byte[] numArray = new byte[count2];
                binaryReader.read(numArray, 0, count2);

                if (!flag1)
                {
                    Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
                    SecretKeySpec skeySpec = new SecretKeySpec(this.EncryptKey.getBytes(), "AES");
                    cipher.init(Cipher.DECRYPT_MODE, skeySpec, new IvParameterSpec(iv));
                    byte[] decrypted = cipher.doFinal(numArray);


                    ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());
                    SaveData value = objectMapper.readValue(decrypted, SaveData.class);
                    accessToken = value.m_AccessToken;
                    uuid = value.m_UUID;
                    myCode = value.m_MyCode;
                    KRFAM.log("at: " + value.m_AccessToken);
                    KRFAM.log("uu: " + value.m_UUID);
                    KRFAM.log("mc: " + value.m_MyCode);
                }
                KRFAM.log(codeName + " > Updated from A.D File");
                failCheckCount = 0;
            } catch (Exception ex) {
                KRFAM.log(ex);
                KRFAM.log(codeName + " > Failed to Read A.D File - Attempting Fix");
                KRFAM.forcePermission(adFile);
                KRFAM.forcePermission(adFile.getParentFile());
                updateFromADFile(attempt + 1);
            }
        } else {
            KRFAM.log(codeName + " > No A.D File exists");
            uuid = "";
            accessToken = "";
            myCode = "";
        }
    } else {
        uuid = "";
        accessToken = "";
    }
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public boolean writeToGameEngineActivity(int attempt, String user, String pass, String code) {
    if (attempt > 5) {
        KRFAM.Toast("Failed to write to '" + codeName + "' A.D File.\nHave you allowed KRFAM to have root access?");
        return false;
    }
    if (installed == true) {

        SaveData value = new SaveData();
        value.m_UUID = user;
        value.m_AccessToken = pass;
        value.m_MyCode = code;
        value.m_ConfirmedVer = 0;

        String _iv = createPassword();
        byte[] iv = _iv.getBytes();

        KRFAM.log("iv " + _iv);
        try {


            MessagePack.PackerConfig config = new MessagePack.PackerConfig().withStr8FormatSupport(false);
            ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory(config));
            byte[] bytes = objectMapper.writeValueAsBytes(value);

            Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
            SecretKeySpec skeySpec = new SecretKeySpec(this.EncryptKey.getBytes(), "AES");
            cipher.init(Cipher.ENCRYPT_MODE, skeySpec, new IvParameterSpec(iv));
            byte[] encrypted = cipher.doFinal(bytes);

            OutputStream is = new FileOutputStream(SaveFile);
            LittleEndianDataOutputStream binaryWriter = new LittleEndianDataOutputStream(is);

            int num1 = new Random().nextInt();

            byte num2 = (byte) (num1 & 127);
            int num3 = (int) ((long) num1 & 4294902015L) | 65280 & 19 << 8; // 19 denotes 171101
            /* 16 - 20: _170404,  _170713,  _171101,  _latest, */

            binaryWriter.writeInt(num3);

            for (int index = 0; index < iv.length; ++index) iv[index] += (byte) (96 + (int) (byte) index);

            binaryWriter.writeByte((byte) ((int) iv.length + (int) num2));
            binaryWriter.write(iv);

            binaryWriter.writeInt(encrypted.length);
            binaryWriter.write(encrypted);

        }  catch (Exception ex) {
            KRFAM.log(ex);
            KRFAM.log(codeName + " > Failed to Write A.D File");
            KRFAM.forcePermission(adFile);
            KRFAM.forcePermission(adFile.getParentFile());
        }

        KRFAM.log("saved uu " + uuid);
        KRFAM.log("saved at " + accessToken);

        updateFromADFile();
        if (uuid.equals(user) && accessToken.equals(pass)) {
            return true;
        } else {
            KRFAM.forcePermission(adFile);
            KRFAM.forcePermission(adFile.getParentFile());
            return writeToGameEngineActivity(attempt + 1, user, pass, code);
        }
    } else {
        KRFAM.Toast(codeName + " not installed");
        return false;
    }
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Bean
public JsonFactory msgpackJsonFactory() {
	return new ObjectMapper(new MessagePackFactory()).getFactory();
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
private static ObjectMapper createMinimalObjectMapper() {
  ObjectMapper mapper = new ObjectMapper(new MessagePackFactory());
  mapper.setSerializationInclusion(JsonInclude.Include.NON_EMPTY);
  return mapper;
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
/**
 * Constructor for the {@link MessagePackSerialization} class. Generates {@link ObjectMapper}
 * and sets to include non-null.
 */
public MessagePackSerialization() {
	objectMapper = new ObjectMapper(new MessagePackFactory());
	objectMapper.setSerializationInclusion(Include.NON_NULL);
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Override
public ObjectMapper get() {
    ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());
    objectMapper.registerSubtypes(Command.class);
    return objectMapper;
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
public MessagePackParser(SecorConfig config) {
    super(config);
    mMessagePackObjectMapper = new ObjectMapper(new MessagePackFactory());
    mTypeReference = new TypeReference<HashMap<String, Object>>(){};
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
@Override
public void setUp() throws Exception {
    mConfig = Mockito.mock(SecorConfig.class);
    Mockito.when(mConfig.getMessageTimestampName()).thenReturn("ts");
    Mockito.when(mConfig.getTimeZone()).thenReturn(TimeZone.getTimeZone("UTC"));
    Mockito.when(TimestampedMessageParser.usingDateFormat(mConfig)).thenReturn("yyyy-MM-dd");
    Mockito.when(TimestampedMessageParser.usingHourFormat(mConfig)).thenReturn("HH");
    Mockito.when(TimestampedMessageParser.usingMinuteFormat(mConfig)).thenReturn("mm");
    Mockito.when(TimestampedMessageParser.usingDatePrefix(mConfig)).thenReturn("dt=");
    Mockito.when(TimestampedMessageParser.usingHourPrefix(mConfig)).thenReturn("hr=");
    Mockito.when(TimestampedMessageParser.usingMinutePrefix(mConfig)).thenReturn("min=");

    mMessagePackParser = new MessagePackParser(mConfig);
    mObjectMapper = new ObjectMapper(new MessagePackFactory());

    timestamp = System.currentTimeMillis();

    HashMap<String, Object> mapWithSecondTimestamp = new HashMap<String, Object>();
    mapWithSecondTimestamp.put("ts", 1405970352);
    mMessageWithSecondsTimestamp = new Message("test", 0, 0, null,
            mObjectMapper.writeValueAsBytes(mapWithSecondTimestamp), timestamp);

    HashMap<String, Object> mapWithMillisTimestamp = new HashMap<String, Object>();
    mapWithMillisTimestamp.put("ts", 1405970352123l);
    mapWithMillisTimestamp.put("isActive", true);
    mapWithMillisTimestamp.put("email", "[email protected]");
    mapWithMillisTimestamp.put("age", 27);
    mMessageWithMillisTimestamp = new Message("test", 0, 0, null,
            mObjectMapper.writeValueAsBytes(mapWithMillisTimestamp), timestamp);


    HashMap<String, Object> mapWithMillisFloatTimestamp = new HashMap<String, Object>();
    mapWithMillisFloatTimestamp.put("ts", 1405970352123.0);
    mapWithMillisFloatTimestamp.put("isActive", false);
    mapWithMillisFloatTimestamp.put("email", "[email protected]");
    mapWithMillisFloatTimestamp.put("age", 35);
    mMessageWithMillisFloatTimestamp = new Message("test", 0, 0, null,
            mObjectMapper.writeValueAsBytes(mapWithMillisFloatTimestamp), timestamp);

    HashMap<String, Object> mapWithMillisStringTimestamp = new HashMap<String, Object>();
    mapWithMillisStringTimestamp.put("ts", "1405970352123");
    mapWithMillisStringTimestamp.put("isActive", null);
    mapWithMillisStringTimestamp.put("email", "[email protected]");
    mapWithMillisStringTimestamp.put("age", 67);
    mMessageWithMillisStringTimestamp = new Message("test", 0, 0, null,
            mObjectMapper.writeValueAsBytes(mapWithMillisStringTimestamp), timestamp);
}
 

import org.msgpack.jackson.dataformat.MessagePackFactory; //导入依赖的package包/类
private static void msgPack(Object src) throws IOException {
    ByteArrayOutputStream out = new ByteArrayOutputStream();

    ObjectMapper objectMapper = new ObjectMapper(new MessagePackFactory());
    objectMapper.writeValue(out, src);

    byte[] bytes = out.toByteArray();

    System.out.println("MsgPack : " + src.toString() + " : " + bytes.length);
}