## ✌✌✌古人有云,好记性不如烂笔头,千里之行,始于足下,每日千行代码必不可少,每日总结写一写,目标大厂,满怀希望便会所向披靡,哈哈哈!!!✌✌✌
一、✌实现思想
压缩
> 获取输入流
> 获取压缩相关信息(反射)
> 获取输出流
> 流的对拷
> 关闭资源
解压缩
> 校验文件是否可以解压
> 获取输入流
> 获取输出流
> 流的对拷
> 关闭资源
二、✌代码实现
1.✌compress压缩方法
public static void compress(String fileName, String method) throws IOException, ClassNotFoundException {
//1、获取输入流
FileInputStream fis = new FileInputStream(new File(fileName));
//2、获取压缩相关信息
Class codecClass = Class.forName(method);
CompressionCodec codec = (CompressionCodec) ReflectionUtils.newInstance(codecClass, new Configuration());
//3、获取输出流
FileOutputStream fos = new FileOutputStream(new File(fileName + codec.getDefaultExtension()));
CompressionOutputStream cos = codec.createOutputStream(fos);
//4、流的对拷
IOUtils.copyBytes(fis, cos, 1024 * 1024, false);
//5、关闭资源
IOUtils.closeStream(cos);
IOUtils.closeStream(fos);
IOUtils.closeStream(fis);
}
2.✌decompress解压方法
public static void decompress(String fileName) throws IOException {
//1、校验文件是否可以解压
CompressionCodecFactory factory = new CompressionCodecFactory(new Configuration());
CompressionCodec codec = factory.getCodec(new Path(fileName));
if (codec == null) {
System.out.println("不能够解压");
return;
}
//2、获取输入流
CompressionInputStream cis = codec.createInputStream(new FileInputStream(new File(fileName)));
//3、获取输出流
FileOutputStream fos = new FileOutputStream(new File(fileName + ".decoded"));
//4、流的对拷
IOUtils.copyBytes(cis, fos, 1024 * 1024, false);
//5、关闭资源
IOUtils.closeStream(fos);
IOUtils.closeStream(cis);
}
、