本文整理了Java中com.jme3.network.message.ZIPCompressedMessage类的一些代码示例，展示了ZIPCompressedMessage类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZIPCompressedMessage类的具体详情如下：
包路径：com.jme3.network.message.ZIPCompressedMessage
类名称：ZIPCompressedMessage

ZIPCompressedMessage介绍

[英]Compress a message using this ZIPCompressedMessage class
[中]使用ZIPCompressedMessage类压缩消息

代码示例

代码示例来源：origin: jMonkeyEngine/jmonkeyengine

@SuppressWarnings("unchecked")
public <T> T readObject(ByteBuffer data, Class<T> c) throws IOException {
  try
  {
    ZIPCompressedMessage result = new ZIPCompressedMessage();
    byte[] byteArray = new byte[data.remaining()];
    data.get(byteArray);
    ZipInputStream in = new ZipInputStream(new ByteArrayInputStream(byteArray));
    in.getNextEntry();
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    byte[] tmp = new byte[9012];
    int read;
    while (in.available() > 0 && ((read = in.read(tmp)) > 0)) {
      out.write(tmp, 0, read);
    }
    in.closeEntry();
    out.flush();
    in.close();
    result.setMessage((Message)Serializer.readClassAndObject(ByteBuffer.wrap(out.toByteArray())));
    return (T)result;
  }
  catch (Exception e) {
    e.printStackTrace();
    throw new IOException(e.toString());
  }
}

代码示例来源：origin: jMonkeyEngine/jmonkeyengine

public void writeObject(ByteBuffer buffer, Object object) throws IOException {
    if (!(object instanceof ZIPCompressedMessage)) return;

    ZIPCompressedMessage zipMessage = (ZIPCompressedMessage)object;
    Message message = zipMessage.getMessage();
    ByteBuffer tempBuffer = ByteBuffer.allocate(512000);
    Serializer.writeClassAndObject(tempBuffer, message);

    ByteArrayOutputStream byteArrayOutput = new ByteArrayOutputStream();
    ZipOutputStream zipOutput = new ZipOutputStream(byteArrayOutput);
    zipOutput.setLevel(zipMessage.getLevel());

    ZipEntry zipEntry = new ZipEntry("zip");

    zipOutput.putNextEntry(zipEntry);
    tempBuffer.flip();
    zipOutput.write(tempBuffer.array(), 0, tempBuffer.limit());
    zipOutput.flush();
    zipOutput.closeEntry();
    zipOutput.close();

    buffer.put(byteArrayOutput.toByteArray());
  }
}

代码示例来源：origin: jMonkeyEngine/jmonkeyengine

public ZIPCompressedMessage(Message msg, int level) {
  super(msg);
  setLevel(level);
}

代码示例来源：origin: info.projectkyoto/mms-engine

public void writeObject(ByteBuffer buffer, Object object) throws IOException {
    if (!(object instanceof ZIPCompressedMessage)) return;

    ZIPCompressedMessage zipMessage = (ZIPCompressedMessage)object;
    Message message = zipMessage.getMessage();
    ByteBuffer tempBuffer = ByteBuffer.allocate(512000);
    Serializer.writeClassAndObject(tempBuffer, message);

    ByteArrayOutputStream byteArrayOutput = new ByteArrayOutputStream();
    ZipOutputStream zipOutput = new ZipOutputStream(byteArrayOutput);
    zipOutput.setLevel(zipMessage.getLevel());

    ZipEntry zipEntry = new ZipEntry("zip");

    zipOutput.putNextEntry(zipEntry);
    zipOutput.write(tempBuffer.array());
    zipOutput.flush();
    zipOutput.closeEntry();
    zipOutput.close();

    buffer.put(byteArrayOutput.toByteArray());
  }
}

代码示例来源：origin: org.jmonkeyengine/jme3-networking

@SuppressWarnings("unchecked")
public <T> T readObject(ByteBuffer data, Class<T> c) throws IOException {
  try
  {
    ZIPCompressedMessage result = new ZIPCompressedMessage();
    byte[] byteArray = new byte[data.remaining()];
    data.get(byteArray);
    ZipInputStream in = new ZipInputStream(new ByteArrayInputStream(byteArray));
    in.getNextEntry();
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    byte[] tmp = new byte[9012];
    int read;
    while (in.available() > 0 && ((read = in.read(tmp)) > 0)) {
      out.write(tmp, 0, read);
    }
    in.closeEntry();
    out.flush();
    in.close();
    result.setMessage((Message)Serializer.readClassAndObject(ByteBuffer.wrap(out.toByteArray())));
    return (T)result;
  }
  catch (Exception e) {
    e.printStackTrace();
    throw new IOException(e.toString());
  }
}

代码示例来源：origin: org.jmonkeyengine/jme3-networking

public ZIPCompressedMessage(Message msg, int level) {
  super(msg);
  setLevel(level);
}

代码示例来源：origin: org.jmonkeyengine/jme3-networking

public void writeObject(ByteBuffer buffer, Object object) throws IOException {
    if (!(object instanceof ZIPCompressedMessage)) return;

    ZIPCompressedMessage zipMessage = (ZIPCompressedMessage)object;
    Message message = zipMessage.getMessage();
    ByteBuffer tempBuffer = ByteBuffer.allocate(512000);
    Serializer.writeClassAndObject(tempBuffer, message);

    ByteArrayOutputStream byteArrayOutput = new ByteArrayOutputStream();
    ZipOutputStream zipOutput = new ZipOutputStream(byteArrayOutput);
    zipOutput.setLevel(zipMessage.getLevel());

    ZipEntry zipEntry = new ZipEntry("zip");

    zipOutput.putNextEntry(zipEntry);
    tempBuffer.flip();
    zipOutput.write(tempBuffer.array(), 0, tempBuffer.limit());
    zipOutput.flush();
    zipOutput.closeEntry();
    zipOutput.close();

    buffer.put(byteArrayOutput.toByteArray());
  }
}

代码示例来源：origin: info.projectkyoto/mms-engine

@SuppressWarnings("unchecked")
public <T> T readObject(ByteBuffer data, Class<T> c) throws IOException {
  try
  {
    ZIPCompressedMessage result = new ZIPCompressedMessage();
    byte[] byteArray = new byte[data.remaining()];
    data.get(byteArray);
    ZipInputStream in = new ZipInputStream(new ByteArrayInputStream(byteArray));
    in.getNextEntry();
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    byte[] tmp = new byte[9012];
    int read;
    while (in.available() > 0 && ((read = in.read(tmp)) > 0)) {
      out.write(tmp, 0, read);
    }
    in.closeEntry();
    out.flush();
    in.close();
    result.setMessage((Message)Serializer.readClassAndObject(ByteBuffer.wrap(out.toByteArray())));
    return (T)result;
  }
  catch (Exception e) {
    e.printStackTrace();
    throw new IOException(e.toString());
  }
}

代码示例来源：origin: info.projectkyoto/mms-engine

public ZIPCompressedMessage(Message msg, int level) {
  super(msg);
  setLevel(level);
}