Как обслуживать ZipOutputStream для сети в JAVA

Question

Я пишу сервер в JAVA, где клиент просит загрузить несколько файлов, а сервер создаст ZipOutputStream и немедленно подаст заявку. С другой стороны, другой поток будет записываться в ZipOutputStream. Я использовал piped input/output stream.

Код

PipedInputStream in = new PipedInputStream(); 
PipedOutputStream out = new PipedOutputStream(); 
in.connect(out); 
ZipOutputStream zout = new ZipOutputStream(out); 
new Thread{ 
    public void run(){ 
     while(condition){ 
      more logic.. 
      zout.write(data,0,length); 
      zout.flush() 
     } 
     zout.close(); 
     out.close(); 
    } 
}.start(); 
return in; 

Но когда я нажимаю кнопку загрузки его загрузки (закончить сразу) небольшой файл (поврежден), а мой почтовый создания задания по-прежнему работает. Как синхронизировать эти два задания?

Answer 1

Вы должны flush, а затем закрыть ZipOutputStream. И лучше использовать ZipEntry для создания архива

ZipOutputStream zout = new ZipOutputStream(out); 
    new Thread { 
     public void run() { 
      while (condition) { 
       // logic ... 
       zipEntry = new ZipEntry("name"); 
       zout.putNextEntry(zipEntry); 
       zout.write(data); 
       zout.flush(); 
       zout.closeEntry(); 
      } 
      zout.flush(); 
      zout.close(); 
     } 
    }.start(); 

    return in;