pako.js 前端压缩解压的库（包含 zlib 和gzip 两种实现，这里只介绍 zlib）
pako 2.0.4 API documentation
Java8+ 原生支持 zlib 和 gzip
业务场景- 因为数据太大，网络环境不可控。故前端需要将数据 A 先压缩 变为 a，然后才将 a 发送到 Java 服务器端后处理或存储。
- 后端 Java 也可以调取存储的压缩结果进行解压，重新发往前端
这里介绍 pako.js 的zlib 接口 与 Java 的互通。
首先是前端：由于 pako.js 库的压缩后的结果 是 Uint8Array
Uint8Array 数组类型表示一个8位无符号整型数组，创建时内容被初始化为0。创建完后，可以以对象的方式或使用数组下标索引的方式引用数组中的元素。
由于 它的 toString() 不包含特殊字符，故可以被 http 直接传输 （无需 转换为 base64）。
故发送到服务端的串 ，大致形式为 ： 123,12,99,1,34
然后是 Java 的服务端Java 原生支持 zlib 压缩和解压方式，百度上很多例子。这里不赘述。
略微麻烦的地方在于，
接受端：前端发送过来的上述的那种格式，需要转变为 java 的压缩解压接口的参数的固定格式。
发送端：发送给前端的数据（显然是 zlib 压缩后的数据），同样需要转换为 上述格式。
这里强调下，为什么前端解压后端的压缩数据时，一定要让后端发送给前端的数据格式，去和前端库发送给后端的数据格式保持一致呢？（不要吐槽我的逗号断句，这句实在太绕了）
因为 在前后端分离的开发模式下，对于前端开发人员，是不应该关注后端的技术实现。显然，后端努力去迎合 前端库的特有数据格式（因伟大而落泪）。
下面直接贴上 代码：
前端代码：（用 jquery 库）
// 首先你需要引入 pako.js 库，这里就不贴了
// 这里要压缩的内容
let content = "我是张三 **@*￥）*￥*）@#*#*@+—— ~kdfkda55d4 fd";
// 前端压缩
let clientData = pako.deflate(content);
// 变成 串
clientData = clientData.toString()
console.log("client 压缩后>>",clientData)
$.post("http://localhost:10003/demo/test2CompresAndUncompress",{
data:clientData
},function(data){
console.log("接受 server 压缩原文:",data);
let b = data.split(',').map(function (x) { return parseInt(x); });
// console.log("client 解压后split:",b);
let c = pako.inflate(b,{to :"string"});
// 完毕 撒花
console.log("client 解压后:",c);
});
后端代码（这里用的是 springboot 框架）：
Controller:
@RequestMapping(value = "/test2CompresAndUncompress")
@ResponseBody
public String test2CompresAndUncompress(@RequestParam String data) throws IOException {
System.out.println("接収 client 原文<<"+data);
byte[] clientBytes = PakoUtil.receive(data);
byte[] bytes = ZlibUtil.decompress(clientBytes);
System.out.println("server 解压后<<"+new String(bytes));
//重新压缩，打算向服务器 发送 压缩后的代码
byte[] encodingStr = ZlibUtil.compress(bytes);
System.out.println("我自己尝试解压后1>>"+new String(encodingStr));
System.out.println("我自己尝试解压后2>>"+new String(ZlibUtil.decompress(encodingStr)));
return PakoUtil.send(encodingStr);
}
上面代码涉及的工具类（ZlibUtil.java 和 PakoUtil.java）：
ZlibUtil.java:
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.util.Arrays;
import java.util.zip.Deflater;
import java.util.zip.DeflaterOutputStream;
import java.util.zip.Inflater;
import java.util.zip.InflaterInputStream;
public class ZlibUtil {
public static byte[] compress(byte[] data) {
byte[] output = new byte[0];
Deflater compresser = new Deflater();
compresser.reset();
compresser.setInput(data);
compresser.finish();
ByteArrayOutputStream bos = new ByteArrayOutputStream(data.length);
try {
byte[] buf = new byte[1024];
while (!compresser.finished()) {
int i = compresser.deflate(buf);
bos.write(buf, 0, i);
}
output = bos.toByteArray();
} catch (Exception e) {
output = data;
e.printStackTrace();
} finally {
try {
bos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
compresser.end();
return output;
}
public static void compress(byte[] data, OutputStream os) {
DeflaterOutputStream dos = new DeflaterOutputStream(os);
try {
dos.write(data, 0, data.length);
dos.finish();
dos.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
public static byte[] decompress(byte[] data) {
byte[] output = new byte[0];
Inflater decompresser = new Inflater();
decompresser.reset();
decompresser.setInput(data);
ByteArrayOutputStream o = new ByteArrayOutputStream(data.length);
try {
byte[] buf = new byte[1024];
while (!decompresser.finished()) {
int i = decompresser.inflate(buf);
o.write(buf, 0, i);
}
output = o.toByteArray();
} catch (Exception e) {
output = data;
e.printStackTrace();
} finally {
try {
o.close();
} catch (IOException e) {
e.printStackTrace();
}
}
decompresser.end();
return output;
}
public static byte[] decompress(InputStream is) {
InflaterInputStream iis = new InflaterInputStream(is);
ByteArrayOutputStream o = new ByteArrayOutputStream(1024);
try {
int i = 1024;
byte[] buf = new byte[i];
while ((i = iis.read(buf, 0, i)) > 0) {
o.write(buf, 0, i);
}
} catch (IOException e) {
e.printStackTrace();
}
return o.toByteArray();
}
public static void main(String[] args) throws UnsupportedEncodingException {
String data = "aadfklafdafla我是中国人的啦啦啦";
System.out.println("原文："+data);
// 报错
// String a = base64Util.encode(ZlibUtil.compress(data.getBytes()));
//
// String b = new String(ZlibUtil.decompress(base64Util.decode(a)));
byte[] a = ZlibUtil.compress(data.getBytes("UTF-8"));
System.out.println(">>"+Arrays.toString(a));
byte[] b = ZlibUtil.decompress(a);
// System.out.println("压缩后："+a);
System.out.println("jieya后："+new String(b));
}
void a(){
// try {
// // Encode a String into bytes
// String inputString = "Pehla nasha Pehla khumaar Naya pyaar hai naya intezaar Kar loon main kya apna haal Aye dil-e-bekaraar Mere dil-e-bekaraar Tu hi bata Pehla nasha Pehla khumaar Udta hi firoon in hawaon mein kahin Ya main jhool jaoon in ghataon mein kahin Udta hi firoon in hawaon mein kahin Ya main jhool jaoon in ghataon mein kahin Ek kar doon aasmaan zameen Kaho yaaron kya karoon kya nahin Pehla nasha Pehla khumaar Naya pyaar hai naya intezaar Kar loon main kya apna haal Aye dil-e-bekaraar Mere dil-e-bekaraar Tu hi bata Pehla nasha Pehla khumaar Usne baat ki kuchh aise dhang se Sapne de gaya vo hazaaron range ke Usne baat ki kuchh aise dhang se Sapne de gaya vo hazaaron range ke Reh jaoon jaise main haar ke Aur choome vo mujhe pyaar se Pehla nasha Pehla khumaar Naya pyaar hai naya intezaar Kar loon main kya apna haal Aye dil-e-bekaraar Mere dil-e-bekaraar";
// byte[] input = inputString.getBytes("UTF-8");
// // Compress the bytes
// byte[] output1 = new byte[input.length];
// Deflater compresser = new Deflater();
// compresser.setInput(input);
// compresser.finish();
// int compressedDataLength = compresser.deflate(output1);
// compresser.end();
// String str = base64.encode(output1);
// System.out.println("Deflated String:" + str);
// byte[] output2 = base64.decode(str);
// // Decompress the bytes
// Inflater decompresser = new Inflater();
// decompresser.setInput(output2);
// byte[] result = str.getBytes();
// int resultLength = decompresser.inflate(result);
// decompresser.end();
// // Decode the bytes into a String
// String outputString = new String(result, 0, resultLength, "UTF-8");
// System.out.println("Deflated String:" + outputString);
// } catch (UnsupportedEncodingException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// } catch (DataFormatException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
}
}
PakoUtil.java:
public class PakoUtil {
public static byte[] receive(String arrInt){
String[] a = arrInt.split(",");
byte[] clientBytes = new byte[a.length];
int i = 0;
for (String e : a) {
clientBytes[i] = Integer.valueOf(e).bytevalue();
i++;
}
return clientBytes;
}
public static String send(byte[] bytes) {
String[] ints = new String[bytes.length];
int j=0;
for(byte e:bytes) {
int t = e;
if(t<0) {
t = 256+t;
}
ints[j++] = String.valueOf(t);
}
return String.join(",", ints);
}
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）