Deflate ve Inflate Java dize ben deflate ve baz 64 kodlamasının bir dize şişirmek için kod yazıyorum ama aşağıdaki hatayı alıyorum

Question

:

Exception in thread "main" java.util.zip.ZipException: incorrect header check 
    at java.util.zip.InflaterOutputStream.write(InflaterOutputStream.java:284) 
    at java.io.FilterOutputStream.write(FilterOutputStream.java:108) 
    at serializer.test.SerializerTest.main(SerializerTest.java:43) 

Benim kodudur:

XsltObject Xslt = new XsltObject(); 
      Xslt.setXslt(readFile("C:\\codebase\\OverallSystem\\EBE_TEMPERED_XMLS\\bank_timestamp-0.xml")); 
      System.out.println("Original String Length: "+ Xslt.getXslt().length()); 
      //JSONObject jsonObj = new JSONObject(Xslt); 
      // System.out.println(jsonObj); 
      //System.out.println("Json Length:" + jsonObj); 

      DeflaterOutputStream outputStream; 

      for (int i = 1; i <= 9; ++i) { 
       ByteArrayOutputStream arrayOutputStream = new ByteArrayOutputStream(); 
       outputStream = new DeflaterOutputStream(arrayOutputStream, new Deflater(i, true)); 
       outputStream.write(Xslt.getXslt().getBytes()); 
       outputStream.close(); 
       //System.out.println("Deflate (lvl=" + i + ");" + arrayOutputStream.toString("ISO-8859-1")); 
       System.out.println("Deflate (lvl=" + i + ");" + arrayOutputStream.toString("ISO-8859-1").length()); 

       String temp = DatatypeConverter.printBase64Binary(arrayOutputStream.toString("UTF-8").getBytes()); 
       System.out.println(temp); 
       System.out.println("Base 64 len: " + temp.length()); 

       byte[] data =DatatypeConverter.parseBase64Binary(temp); 
       ByteArrayOutputStream inflateArrayOutputStream = new ByteArrayOutputStream(); 
       InflaterOutputStream iis = new InflaterOutputStream(inflateArrayOutputStream, new Inflater()); 
       iis.write(data); 
       iis.close(); 
       System.out.println("Inflate (lvl=" + i + ");" + inflateArrayOutputStream.toString("ISO-8859-1")); 
       System.out.println("Inflate (lvl=" + i + ");" + inflateArrayOutputStream.toString("ISO-8859-1").length()); 

Neyi yanlış yapıyorum?

Answer 1

Hepsi benim sorunlar giderildi ve tüm JDK kullanım şöyledir:

package serializer.test; 

import java.io.BufferedReader; 
import java.io.FileReader; 
import java.io.IOException; 
import java.io.UnsupportedEncodingException; 
import java.util.Arrays; 
import java.util.zip.*; 

import javax.xml.bind.DatatypeConverter; 

public class DeflationApp 
{ 
    private String compressBase64(String stringToCompress, int level) 
      throws UnsupportedEncodingException 
    { 
     byte[] compressedData = new byte[1024]; 
     byte[] stringAsBytes = stringToCompress.getBytes("UTF-8"); 

     Deflater compressor = new Deflater(level, false); 
     compressor.setInput(stringAsBytes); 
     compressor.finish(); 
     int compressedDataLength = compressor.deflate(compressedData); 

     byte[] bytes = Arrays.copyOf(compressedData, compressedDataLength); 
     return DatatypeConverter.printBase64Binary(bytes); 
    } 

    private String decompressToStringBase64(String base64String) 
      throws UnsupportedEncodingException, DataFormatException 
    { 
     byte[] compressedData = DatatypeConverter 
       .parseBase64Binary(base64String); 

     Inflater deCompressor = new Inflater(); 
     deCompressor.setInput(compressedData, 0, compressedData.length); 
     byte[] output = new byte[100000]; 
     int decompressedDataLength = deCompressor.inflate(output); 
     deCompressor.end(); 

     return new String(output, 0, decompressedDataLength, "UTF-8"); 
    } 

    public static void main(String[] args) throws DataFormatException, 
      IOException 
    { 
     DeflationApp m = new DeflationApp(); 
     String strToBeCompressed = readFile(
       "C:\\codebase\\OverallSystem\\MappingMapToEBECommon.xslt") 
       .trim(); 
     for (int i = 1; i <= 9; ++i) 
     { 
      String compressedData = m.compressBase64(strToBeCompressed, i); 
      String deCompressedString = m.decompressToStringBase64(compressedData); 

      System.out.println("Base 64:"); 
      System.out.println("Original Length with level("+i+"): " + strToBeCompressed.length()); 
      System.out.println("Compressed with level("+i+"): " + compressedData.toString()); 
      System.out.println("Compressed with level("+i+") Length: " + compressedData.toString().length()); 
      System.out.println("Decompressed with level("+i+"): " + 
        + deCompressedString.length()); 
      System.out.println("Decompressed with level("+i+"): " + deCompressedString); 
     } 

     for (int i = 1; i <= 9; ++i) 
     { 
      byte[] compressedData = m.compress(strToBeCompressed, i); 
      String deCompressedString = m.decompressToString(compressedData); 

      System.out.println("Without Base 64:"); 
      System.out.println("Original Length with level("+i+"): " + strToBeCompressed.length()); 
      System.out.println("Compressed with level("+i+"): " + new String(compressedData)); 
      System.out.println("Compressed with level("+i+") Length: " + new String(compressedData).length()); 
      System.out.println("Decompressed with level("+i+"): " + 
        + deCompressedString.length()); 
      System.out.println("Decompressed with level("+i+"): " + deCompressedString); 
     } 

    } 

    private byte[] compress(String stringToCompress, int level) throws UnsupportedEncodingException 
    { 
     byte[] compressedData = new byte[1024]; 
     byte[] stringAsBytes = stringToCompress.getBytes("UTF-8"); 

     Deflater compressor = new Deflater(level, false); 
     compressor.setInput(stringAsBytes); 
     compressor.finish(); 
     int compressedDataLength = compressor.deflate(compressedData); 

     return Arrays.copyOf(compressedData, compressedDataLength); 
    } 

    private String decompressToString(byte[] compressedData) throws UnsupportedEncodingException, DataFormatException 
    { 
     Inflater deCompressor = new Inflater(); 
     deCompressor.setInput(compressedData, 0, compressedData.length); 
     byte[] output = new byte[100000]; 
     int decompressedDataLength = deCompressor.inflate(output); 
     deCompressor.end(); 

     return new String(output, 0, decompressedDataLength, "UTF-8"); 
    } 

    public static String readFile(String file) throws IOException 
    { 
     BufferedReader reader = new BufferedReader(new FileReader(file)); 
     String line = null; 
     StringBuilder stringBuilder = new StringBuilder(); 
     String ls = System.getProperty("line.separator"); 

     try 
     { 
      while ((line = reader.readLine()) != null) 
      { 
       stringBuilder.append(line); 
       stringBuilder.append(ls); 
      } 

      return stringBuilder.toString(); 
     } 
     finally 
     { 
      reader.close(); 
     } 
    } 

} 

Answer 2

Ben de DeflaterOutputStream ile bellek sorunları vardı - Eğer varsayılan kurucu kullanmasına izin eğer çalışır.

for (Entry<String, String> entry : valueMap.entrySet()) { 
    String key = entry.getKey(); 
    String value = entry.getValue();      
    ByteArrayOutputStream baos = new ByteArrayOutputStream(); 
    DeflaterOutputStream dos = new DeflaterOutputStream(baos); 
    try { 
     dos.write(value.getBytes()); 
     dos.flush(); 
     dos.close(); 
    } 
    catch (IOException e) { 
     throw new RuntimeException(e); 
    } 
    byte[] zipData = baos.toByteArray(); 
    zipValueMap.put(key, zipData); 
} 

Ama o değiştirin:: Bu iyi çalışır

ByteArrayOutputStream baos = new ByteArrayOutputStream(); 
Deflater deflater = new Deflater(Deflater.BEST_SPEED); 
DeflaterOutputStream dos = new DeflaterOutputStream(baos, deflater); 

Ve bu 80g kaplıyor ve benim nane sistem çöker JVM C kodunda bana bellek sızıntısı verir. o kadar kötü başarısız içinde kendi deflatörü geçmesi varken neden varsayılan yapıcı çalışmaları ve henüz olacaktır:

public void close() throws IOException { 
    if (!closed) { 
     finish(); 
     if (usesDefaultDeflater) 
      def.end(); 
     out.close(); 
     closed = true; 
    } 
} 

I:

Kod Çözme DeflaterOutputStream (java 1.8_40) Ben yakın yönteminde bazı özel kodunu bulmak Bunu deflater ile geçici çözüm sorununa koydular.

iyi çözüm

döngüde açıkça çağırmak oldu:

try { 
    dos.write(value.getBytes()); 
    dos.flush(); 
    dos.close(); 
    deflater.end(); 
} 

Ve artık bellek sızıntısı. Kötü bir bellek sızıntısı da var, çünkü C tarafı olduğundan, bir JVM hatası atmadı, sadece 40 gramlık ramı çiğnedim ve sonra takas alanına başladım. Kutunun içine ssh ve öldürmeliydim.