ZipInputSreamがbyte[]に変換されるコードがありますが、それをinputstreamに変換する方法がわかりません。
private void convertStream(String encoding, ZipInputStream in) throws IOException,
UnsupportedEncodingException
{
final int BUFFER = 1;
@SuppressWarnings("unused")
int count = 0;
byte data[] = new byte[BUFFER];
while ((count = in.read(data, 0, BUFFER)) != -1)
{
// How can I convert data to InputStream here ?
}
}
ZipInputStreamは、InputStreamのサブクラスです。
http://download.oracle.com/javase/6/docs/api/java/util/zip/ZipInputStream.html
これが私がこの問題を解決した方法です。これで、ZipInputStreamからメモリに単一のファイルをInputStreamとして取得できます。
private InputStream convertZipInputStreamToInputStream(ZipInputStream in, ZipEntry entry, String encoding) throws IOException
{
final int BUFFER = 2048;
int count = 0;
byte data[] = new byte[BUFFER];
ByteArrayOutputStream out = new ByteArrayOutputStream();
while ((count = in.read(data, 0, BUFFER)) != -1) {
out.write(data);
}
InputStream is = new ByteArrayInputStream(out.toByteArray());
return is;
}
以下のZIPアーカイブからすべてのファイルを抽出する関数の例を見つけてください。この関数は、サブフォルダー内のファイルでは機能しません。
private static void testZip() {
ZipInputStream zipStream = null;
byte buff[] = new byte[16384];
int readBytes;
try {
FileInputStream fis = new FileInputStream("./test.zip");
zipStream = new ZipInputStream(fis);
ZipEntry ze;
while((ze = zipStream.getNextEntry()) != null) {
if(ze.isDirectory()) {
System.out.println("Folder : "+ze.getName());
continue;//no need to extract
}
System.out.println("Extracting file "+ze.getName());
//at this moment zipStream pointing to the beginning of current ZipEntry, e.g. archived file
//saving file
FileOutputStream outFile = new FileOutputStream(ze.getName());
while((readBytes = zipStream.read(buff)) != -1) {
outFile.write(buff, 0, readBytes);
}
outFile.close();
}
} catch (Exception e) {
System.err.println("Error processing zip file : "+e.getMessage());
} finally {
if(zipStream != null)
try {
zipStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
ZipInputStreamZIPコンテンツを直接読み取ることができます。getNextEntry()読み取りたいエントリが見つかるまでを繰り返してから、から読み取りますZipInputStream。
ZIPコンテンツだけを読みたくないが、次のステップに進む前にストリームに追加の変換を適用する必要がある場合は、とを使用できPipedInputStreamますPipedOutputStream。アイデアはこれに似ています（メモリから書き込まれ、コンパイルさえされない可能性があります）：
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
public abstract class FilterThread extends Thread {
private InputStream unfiltered;
public void setUnfilteredStream(InputStream unfiltered) {
this.unfiltered = unfiltered;
}
private OutputStream threadOutput;
public void setThreadOutputStream(OutputStream threadOutput) {
this.threadOutput = threadOutput;
}
// read from unfiltered stream, filter and write to thread output stream
public abstract void run();
}
...
public InputStream getFilteredStream(InputStream unfiltered, FilterThread filter) {
PipedInputStream filteredInputStream = new PipedInputStream();
PipedOutputStream threadOutputStream = new PipedOutputStream(filteredInputStream);
filter.setUnfilteredStream(unfiltered);
filter.setThreadOuptut(threadOutputStream);
filter.start();
return filteredInputStream;
}
...
public void clientCode() {
...
ZipInputStream zis = ...;// get ZIP stream
FilterThread filter = ...; // assign your implementation of FilterThread that transforms your ZipInputStream
InputStream filteredZipInputStream = getFilteredStream(zis, filter);
...
}
郵便番号はかなり簡単ですが、ZipInputStreamをInputstreamとして返す際に問題が発生しました。何らかの理由で、zip内に含まれているファイルの一部で文字が削除されていました。以下は私の解決策であり、これまでのところ機能しています。
private Map<String, InputStream> getFilesFromZip(final DataHandler dhZ,
String operation) throws ServiceFault
{
Map<String, InputStream> fileEntries = new HashMap<String, InputStream>();
try
{
DataSource dsZ = dhZ.getDataSource();
ZipInputStream zipIsZ = new ZipInputStream(dhZ.getDataSource()
.getInputStream());
try
{
ZipEntry entry;
while ((entry = zipIsZ.getNextEntry()) != null)
{
if (!entry.isDirectory())
{
Path p = Paths.get(entry.toString());
fileEntries.put(p.getFileName().toString(),
convertZipInputStreamToInputStream(zipIsZ));
}
}
}
finally
{
zipIsZ.close();
}
}
catch (final Exception e)
{
faultLocal(LOGGER, e, operation);
}
return fileEntries;
}
private InputStream convertZipInputStreamToInputStream(
final ZipInputStream in) throws IOException
{
ByteArrayOutputStream out = new ByteArrayOutputStream();
IOUtils.copy(in, out);
InputStream is = new ByteArrayInputStream(out.toByteArray());
return is;
}