Comment puis-je convertir ZipInputStream à InputStream?

J'ai le code, où ZipInputSream est converti en byte[], mais je ne sais pas comment je peux convertir 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 ?                    
    }
}
Qu'est-ce exactement que vous essayez de faire? Décompresser une seule entrée dans le flux?
Oui, je veux seul fichier à partir de flux de données en tant InputStream si c'est possible.
Double de Convertir InputStream de tableau d'octets en Java

OriginalL'auteur newbie | 2011-10-21

  2. 2

    Voici comment j'ai résolu ce problème. Maintenant, je peux avoir des fichiers à partir de ZipInputStream à la mémoire comme 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;
}
    pouvez-vous svp préciser où ZipEntry entrée, de codage de la Chaîne sont utilisés et pourquoi?
    Que vous devriez éviter pour cela, il sera la cause de OutOfMemoryError sur des fichiers volumineux. Au lieu de cela, vous pouvez utiliser le ZipInputStream. Voir stackoverflow.com/questions/20020982/...
    Quelles sont les deuxième et troisième arguments pour? Ils ne sont pas utilisés du tout.
    while ((count = en.read(buffer)) > 0) {out.write(BUFFER, 0, compteur);}

    OriginalL'auteur newbie

  3. 0

    Veuillez trouver ci-dessous un exemple de fonction qui va extraire tous les fichiers de l'archive ZIP. Cette fonction ne fonctionne pas avec les fichiers dans des sous-dossiers:

    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();
            }
    }
}
    Pas ce qui était demandé.

    OriginalL'auteur vad

  4. -1

    ZipInputStream permet de lire ZIP contenu directement: itérer à l'aide de getNextEntry() jusqu'à ce que vous trouviez l'entrée que vous souhaitez lire et puis il suffit de lire à partir de la ZipInputStream.

    Si vous ne voulez pas de simplement lire ZIP contenu, mais vous avez besoin d'appliquer un supplément de transformer le flux avant de passer à l'étape suivante, vous pouvez utiliser PipedInputStream et PipedOutputStream. L'idée serait similaire à ceci (écrit à partir de la mémoire, pourrait même ne pas compiler):

    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);
    ...
}

    OriginalL'auteur gpeche

  5. -1

    Le code postal est assez facile, mais j'ai eu des problèmes avec le retour des ZipInputStream comme Inputstream. Pour une raison quelconque, une partie des fichiers contenus dans le zip a les caractères d'être supprimé. Le ci-dessous a été ma solution et pour l'instant sa fonctionne.

    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;
}

    OriginalL'auteur EdwinR