2016-09-26 76 views
3

Flow获取http请求,java组件创建zip文件并返回。压缩文件得到下载,但当我解压缩时,我得到错误说'压缩文件夹无效'。 java在临时位置创建的临时zip工作正常。问题是如何将zip文件设置为有效内容?Mule ESB:java组件提供zip文件但无法解压

public Object onCall(MuleEventContext eventContext) throws Exception { 
    MuleMessage message = eventContext.getMessage(); 

    message.setOutboundProperty("Content-type", "application/zip"); 
    message.setOutboundProperty("Content-Disposition", "attachment;filename=\"my_Logs.zip\""); 
    File tempZip = File.createTempFile("LOGS", ".zip"); 
    FileOutputStream fos = new FileOutputStream(tempZip); 
    ZipOutputStream zipOut = new ZipOutputStream(fos); 

    File logDir = new File("C:/Temp/logs"); 
    zipOut.setMethod(ZipOutputStream.DEFLATED); 
    zipOut.setLevel(9); 
    FileInputStream in =null; 
    int len =0; 
    byte[] buf = new byte[1024]; 
    for(File file : logDir.listFiles()){ 
     String filename = file.getName(); 
     in = new FileInputStream(file); 
     zipOut.putNextEntry(new ZipEntry(filename)); 
     while ((len = in.read(buf))>0){ 
      zipOut.write(buf,0,len); 
     } 
     zipOut.closeEntry(); 
     in.close(); 
    } 
    zipOut.close(); 
    message.setPayload(tempZip); 
    return message; 
} 

流量

<http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/> 
<flow name="httppayloadFlow"> 
    <http:listener config-ref="HTTP_Listener_Configuration" path="*" doc:name="HTTP"/> 
    <message-filter doc:name="Filter favicon"> 
     <not-filter> 
      <wildcard-filter pattern="/favicon.ico" caseSensitive="true"/> 
     </not-filter> 
    </message-filter> 
    <component class="com.home.zipper.ZipLogs" doc:name="Java"/> 
</flow> 

我在做什么错在这里?感谢任何帮助

回答

0

你可以尝试这个完美的压缩和提供文件。

Mule Zip File and send zipped file towards FTP server

只要改变

在ZipTransformer构造,已被弃用以下。

registerSourceType(InputStream.class); 
registerSourceType(byte[].class); 

使用这个代替:

registerSourceType(DataTypeFactory.create(InputStream.class)); 
registerSourceType(DataTypeFactory.create(byte[].class)); 

希望这有助于。

0

我替换了以下代码 message.setPayload(tempZip); 与 message.setPayload(org.apache.commons.io.FileUtils.readFileToByteArray(tempZip));