1、依賴

<dependency>
	<groupId>org.anarres.lzo</groupId>
	<artifactId>lzo-core</artifactId>
	<version>1.0.0</version>
</dependency>
<dependency>
<span style="white-space:pre">	</span><groupId>org.anarres.lzo</groupId>
<span style="white-space:pre">	</span><artifactId>lzo-hadoop</artifactId>
<span style="white-space:pre">	</span><version>1.0.0</version>
</dependency>
<dependency>
	<groupId>org.apache.hadoop</groupId>
	<artifactId>hadoop-core</artifactId>
	<version>1.0.3</version>
</dependency>
 

（1）壓縮

OutputStream out = new FileOutputStream(new File("D:\\log\\123.lzo"));
LzoAlgorithm algorithm = LzoAlgorithm.LZO1X;
LzoCompressor compressor = LzoLibrary.getInstance().newCompressor(algorithm, null);
LzoOutputStream stream = new LzoOutputStream(out, compressor, 256);
stream.write("我是中國人".getBytes("UTF-8"));
stream.close();
 

<span style="white-space:pre">	</span>InputStream in = new FileInputStream(new File("D:\\log\\123.lzo"));
    	LzoAlgorithm algorithm = LzoAlgorithm.LZO1X;
    	LzoDecompressor decompressor = LzoLibrary.getInstance().newDecompressor(algorithm, null);
    	LzoInputStream stream = new LzoInputStream(in, decompressor);
    	OutputStream outputStream = new FileOutputStream(new File("D:\\log\\data.txt"));
    	int read = 0;
		byte[] bytes = new byte[1024];

		while ((read = stream.read(bytes)) != -1) {
			outputStream.write(bytes, 0, read);
		}
		outputStream.close();
    	stream.close();