package de.tutorials;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
public class StringCompressionExample {
final static CountDownLatch latch = new CountDownLatch(1);
final static String msg = "A very long message 111222h34jk324hjk4hdfhhfsjkahjkfhjkh34jkhuiz4897489jhkdjkljadiljda97234073j3lj3klj3lj3io13j290uds90dasjdklsjkljdsklj34907404830324sdjasdklköm·…cm,.mc,.cm lökpüi90429044j4j43jk4hjkhrzhsdiz8ousdojkljdkladjkldjaduew8ou89eu894324hjkdhsjkhdjkasdh78974389334jk4hjkhjkhsd89dz891234h111222h34jk324hjk4hdfhhfsjkahjkfhjkh34jkhuiz4897489jhkdjkljadiljda97234073j3lj3klj3lj3io13j290uds90dasjdklsjkljdsklj34907404830324sdjasdklköm·…cm,.mc,.cm lökpüi90429044j4j43jk4hjkhrzhsdiz8ousdojkljdkladjkldjaduew8ou89eu894324hjkdhsjkhdjkasdh78974389334jk4hjkhjkhsd89dz891234h111222h34jk324hjk4hdfhhfsjkahjkfhjkh34jkhuiz4897489jhkdjkljadiljda97234073j3lj3klj3lj3io13j290uds90dasjdklsjkljdsklj34907404830324sdjasdklköm·…cm,.mc,.cm lökpüi90429044j4j43jk4hjkhrzhsdiz8ousdojkljdkladjkldjaduew8ou89eu894324hjkdhsjkhdjkasdh78974389334jk4hjkhjkhsd89dz891234h111222h34jk324hjk4hdfhhfsjkahjkfhjkh34jkhuiz4897489jhkdjkljadiljda97234073j3lj3klj3lj3io13j290uds90dasjdklsjkljdsklj34907404830324sdjasdklköm·…cm,.mc,.cm lökpüi90429044j4j43jk4hjkhrzhsdiz8ousdojkljdkladjkldjaduew8ou89eu894324hjkdhsjkhdjkasdh78974389334jk4hjkhjkhsd89dz891234h";
/**
* @param args
*/
public static void main(String[] args) throws Exception {
benchmark();
ExecutorService executorService = Executors.newFixedThreadPool(2);
executorService.execute(new Server());
executorService.execute(new Client());
executorService.shutdown();
}
private static void benchmark() throws UnsupportedEncodingException {
System.out.println("Raw message bytes (UTF-8): " + msg.getBytes("UTF-8").length);
byte[] compressedMsgBytes = compress(msg);
System.out.println("Compressed message bytes: " + compressedMsgBytes.length);
String decompressedMessage = decompress(compressedMsgBytes);
System.out.println(msg.equals(decompressedMessage));
}
static class Server implements Runnable {
public void run() {
try {
ServerSocket serverSocket = new ServerSocket(4711);
latch.countDown();
Socket socket = serverSocket.accept();
socket.getInputStream().read();
socket
.getOutputStream()
.write(
compress(msg));
socket.getOutputStream().flush();
socket.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
static class Client implements Runnable {
public void run() {
try {
latch.await();
Socket socket = new Socket("localhost", 4711);
socket.getOutputStream().write(1);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte[] buffer = new byte[1024];
InputStream in = socket.getInputStream();
for (int bytesRead; (bytesRead = in.read(buffer)) != -1;) {
baos.write(buffer, 0, bytesRead);
}
System.out.println("Received: "
+ decompress(baos.toByteArray()));
socket.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
private static byte[] compress(String s) {
byte[] result = null;
try {
byte[] bytesUTF8 = s.getBytes("UTF-8");
ByteArrayOutputStream baos = new ByteArrayOutputStream();
GZIPOutputStream zipOut = new GZIPOutputStream(baos);
zipOut.write(bytesUTF8);
zipOut.close();
result = baos.toByteArray();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
private static String decompress(byte[] compressedBytes) {
String result = null;
try {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
GZIPInputStream zipIn = new GZIPInputStream(
new ByteArrayInputStream(compressedBytes));
byte[] buffer = new byte[1024];
for (int bytesRead; (bytesRead = zipIn.read(buffer)) != -1;) {
baos.write(buffer, 0, bytesRead);
}
result = new String(baos.toByteArray(), "UTF-8");
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}
