2 changed files with 78 additions and 0 deletions
@ -0,0 +1,32 @@ |
|||
<?xml version="1.0" encoding="UTF-8"?> |
|||
<project xmlns="http://maven.apache.org/POM/4.0.0" |
|||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
|||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
|||
<modelVersion>4.0.0</modelVersion> |
|||
|
|||
<groupId>org.example</groupId> |
|||
<artifactId>unzip</artifactId> |
|||
<version>1.0-SNAPSHOT</version> |
|||
<dependencies> |
|||
<dependency> |
|||
<groupId>com.github.chrislusf</groupId> |
|||
<artifactId>seaweedfs-client</artifactId> |
|||
<version>1.5.3</version> |
|||
<scope>compile</scope> |
|||
</dependency> |
|||
<dependency> |
|||
<groupId>com.github.chrislusf</groupId> |
|||
<artifactId>seaweedfs-hadoop2-client</artifactId> |
|||
<version>1.5.3</version> |
|||
<scope>compile</scope> |
|||
</dependency> |
|||
<dependency> |
|||
<groupId>org.apache.hadoop</groupId> |
|||
<artifactId>hadoop-common</artifactId> |
|||
<version>2.9.2</version> |
|||
<scope>compile</scope> |
|||
</dependency> |
|||
</dependencies> |
|||
|
|||
|
|||
</project> |
@ -0,0 +1,46 @@ |
|||
package com.example.test; |
|||
|
|||
import seaweed.hdfs.SeaweedInputStream; |
|||
import seaweedfs.client.FilerClient; |
|||
import seaweedfs.client.FilerGrpcClient; |
|||
|
|||
import java.io.FileInputStream; |
|||
import java.io.IOException; |
|||
import java.io.InputStream; |
|||
import java.util.zip.ZipEntry; |
|||
import java.util.zip.ZipInputStream; |
|||
|
|||
public class Example { |
|||
|
|||
public static FilerClient filerClient = new FilerClient("localhost", 18888); |
|||
public static FilerGrpcClient filerGrpcClient = new FilerGrpcClient("localhost", 18888); |
|||
|
|||
public static void main(String[] args) throws IOException { |
|||
|
|||
// 本地模式,速度很快 |
|||
parseZip("/Users/chris/tmp/test.zip"); |
|||
|
|||
// swfs读取,慢 |
|||
SeaweedInputStream seaweedInputStream = new SeaweedInputStream( |
|||
filerGrpcClient, |
|||
new org.apache.hadoop.fs.FileSystem.Statistics(""), |
|||
"/", |
|||
filerClient.lookupEntry("/", "test.zip") |
|||
); |
|||
parseZip(seaweedInputStream); |
|||
|
|||
} |
|||
|
|||
public static void parseZip(String filename) throws IOException { |
|||
FileInputStream fileInputStream = new FileInputStream(filename); |
|||
parseZip(fileInputStream); |
|||
} |
|||
|
|||
public static void parseZip(InputStream is) throws IOException { |
|||
ZipInputStream zin = new ZipInputStream(is); |
|||
ZipEntry ze; |
|||
while ((ze = zin.getNextEntry()) != null) { |
|||
System.out.println(ze.getName()); |
|||
} |
|||
} |
|||
} |
Reference in new issue
xxxxxxxxxx