XZ and DeflaterInflater compression is added. | Jai

Author: Jai Prakash

build.gradle

@@ -13,4 +13,5 @@ dependencies {
     testCompile group: 'junit', name: 'junit', version: '4.12'
     compile group: 'org.bouncycastle', name: 'bcprov-jdk15on', version: '1.59'
     compile group: 'org.xerial.snappy', name: 'snappy-java', version: '1.1.7.1'
+    compile group: 'org.tukaani', name: 'xz', version: '1.8'
 }

src/main/java/compression/DeflaterInflater.java

@@ -0,0 +1,44 @@
+package compression;
+
+import sun.misc.BASE64Decoder;
+import sun.misc.BASE64Encoder;
+
+import java.util.zip.Deflater;
+import java.util.zip.Inflater;
+
+public class DeflaterInflater {
+
+    private static int compressedDataLength;
+    private static final int MAX_BYTE_SIZE = 8192;
+
+    public static String compress(String inputString) throws Exception {
+        byte[] inputBytes = inputString.getBytes("UTF-8");
+
+        byte[] compressedData = new byte[MAX_BYTE_SIZE];
+        Deflater compresser = new Deflater();
+        compresser.setInput(inputBytes);
+        compresser.finish();
+        compressedDataLength = compresser.deflate(compressedData);
+        compresser.end();
+        return new BASE64Encoder().encode(compressedData);
+    }
+
+    public static String decompress(String compressedDataString) throws Exception {
+        byte[] compressedStrBytes = new BASE64Decoder().decodeBuffer(compressedDataString);
+        byte[] result = new byte[MAX_BYTE_SIZE];
+        Inflater decompresser = new Inflater();
+        decompresser.setInput(compressedStrBytes, 0, compressedDataLength);
+        int resultLength = decompresser.inflate(result);
+        decompresser.end();
+
+
+        String outputString = new String(result, 0, resultLength, "UTF-8");
+        return outputString;
+
+    }
+
+    private static String getFile(String filename) {
+        ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
+        return classLoader.getResource(filename).getPath();
+    }
+}

src/main/java/compression/GZIPCompression.java

@@ -9,6 +9,7 @@
 import java.util.zip.GZIPOutputStream;
 
 public class GZIPCompression {
+
     public static String compress(final String str) throws IOException {
         if ((str == null) || (str.length() == 0)) {
             return null;

src/main/java/compression/Main.java

@@ -6,21 +6,35 @@
 public class Main {
     public static void main(String[] args) {
         try {
-            System.out.println("Gzip Compression.....");
+
             String fileContent = ReadFile.readTextFile(getFile("sample.txt"));
+            String input = "Hello snappy-java! Snappy-java is a JNI-based wrapper of "
+                    + "Snappy, a fast compresser/decompresser.\n Really";
+
+            System.out.println("Gzip Compression.....");
             String compressedData = GZIPCompression.compress(fileContent);
             System.out.println("Compressed: " + compressedData.toString());
             String decompressedData = GZIPCompression.decompress(compressedData);
             System.out.println("Decompressed: "+decompressedData);
 
             System.out.println("Snappy data compression library.....");
-            String input = "Hello snappy-java! Snappy-java is a JNI-based wrapper of "
-                    + "Snappy, a fast compresser/decompresser.\n Really";
             byte[] compressed = Snappy.compress(input.getBytes("UTF-8"));
             byte[] uncompressed = Snappy.uncompress(compressed);
+            System.out.println("Snappy compressed: " + compressed);
+            System.out.println("Snappy decompressed: " + uncompressed);
+
+
+            System.out.println("Deflater Inflater..");
+            String comp = DeflaterInflater.compress(input);
+            String uncomp = DeflaterInflater.decompress(comp);
+            System.out.println("Deflater decompress:" + uncomp);
 
-            String result = new String(uncompressed, "UTF-8");
-            System.out.println(result);
+            System.out.println("XZ or LZMA2 library.....");
+            byte[] xzCompressed = XZ_LZMA2.compress(input);
+            System.out.println(input);
+            System.out.println("XZ Compressed : "+ xzCompressed);
+            String xzDecompressed = XZ_LZMA2.decompress(xzCompressed);
+            System.out.println("XZ Decompressed : "+ xzDecompressed);
 
         }
         catch (Exception ex) {

src/main/java/compression/XZ_LZMA2.java

@@ -0,0 +1,34 @@
+package compression;
+
+import org.tukaani.xz.LZMA2Options;
+import org.tukaani.xz.XZInputStream;
+import org.tukaani.xz.XZOutputStream;
+
+import java.io.*;
+
+public class XZ_LZMA2 {
+
+    public static  byte[] compress(String inputString) throws IOException {
+        if ((inputString == null) || (inputString.length() == 0)) {
+            return null;
+        }
+        ByteArrayOutputStream xzOutput = new ByteArrayOutputStream();
+        XZOutputStream xzStream = new XZOutputStream(xzOutput, new LZMA2Options(LZMA2Options.PRESET_MAX));
+        xzStream.write(inputString.getBytes());
+        xzStream.close();
+        return xzOutput.toByteArray();
+    }
+
+    public static  String decompress(byte[] compressedData) throws IOException {
+        if ((compressedData == null) || (compressedData.length == 0)) {
+            return "";
+        }
+        XZInputStream xzInputStream = new XZInputStream(new ByteArrayInputStream(compressedData));
+        byte firstByte = (byte) xzInputStream.read();
+        byte[] buffer = new byte[xzInputStream.available()];
+        buffer[0] = firstByte;
+        xzInputStream.read(buffer, 1, buffer.length - 2);
+        xzInputStream.close();
+        return new String(buffer);
+    }
+}