如何将MicroProfile REST流响应直接写入Zip文件并避免内存占用

我们需要从REST服务获取大型XML文件流并直接写入Zip文件，无需解析内容，核心目标是避免将全部内容存入内存（如转为String）。现有Java代码如下：

public void process(URL url, ZipOutputStream outputStream) {

    // Build REST client based on subscription URL.
    DispatchService dispatchService = RestClientBuilder.newBuilder().baseUrl( url ).build( DispatchService.class );

    try (DispatchService autoCloseableClient = dispatchService) {

        Response response = autoCloseableClient.get( );

        // how shall I write a new entry to the ZIP outputStream by means of the DispatchService?

        LOG.info( "object handled" );
    }
    catch ( Exception ex ) {
        LOG.debug( "an exception occurred while sending the message" );
    }
}

@Path( "" )
public interface DispatchService extends AutoCloseable {

    @POST
    @Produces( MediaType.APPLICATION_XML  )
    Response get();
}

疑问列表 #

• 使用Response是否可行？
• 如何从Response中获取流？
• 是否需要采用响应式（异步、Mutiny）结构？若要向同一Zip写入多个条目该如何操作？

问题解答 #

1. 使用Response是否可行？
   完全可行。JAX-RS的Response对象支持直接获取底层响应流，刚好契合流式处理、避免内存占用的需求，无需将整个响应体加载到内存中。注意原代码里的DispatchService存在注解错误：get()方法标注了@POST，但方法名是get，不符合REST语义，建议改为@GET，否则会发送POST请求获取数据，大概率不符合目标服务的设计。

2. 如何从Response中获取流？
   通过Response.readEntity(InputStream.class)即可获取响应输入流，再借助IO工具将流直接写入ZipOutputStream，全程无需缓存数据到内存。具体步骤：

• 给Zip输出流创建新条目：outputStream.putNextEntry(new ZipEntry("目标文件名.xml"));
• 从Response中读取输入流：InputStream inputStream = response.readEntity(InputStream.class);
• 将输入流转写入Zip输出流：Java 9+可直接用inputStream.transferTo(outputStream)，低版本可使用Apache Commons IO的IOUtils.copy(inputStream, outputStream)
• 关闭当前Zip条目：outputStream.closeEntry();

3. 是否需要采用响应式（异步、Mutiny）结构？若要向同一Zip写入多个条目该如何操作？
   响应式结构并非必须——同步流式处理已经能满足低内存占用的需求，仅在需要提升并发性能（如基于Quarkus等支持Mutiny的框架）时才建议使用。

若要写入多个Zip条目：

• 同步方式：循环调用REST接口（或同一接口传不同参数），每次获取流后重复「创建Zip条目→复制流→关闭条目」的流程，全程保持ZipOutputStream处于打开状态，所有条目处理完成后再关闭它。
• 响应式方式：将每个获取流并写入Zip的操作包装为Uni，通过Uni.join().all().unis(...)或Multi实现串行/并行处理。注意ZipOutputStream不是线程安全的，并行处理时需加锁，或优先选择串行处理以避免并发问题。

修正后的代码示例 #

import java.io.InputStream;
import java.net.URL;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.Response;
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ZipStreamProcessor {

    private static final Logger LOG = LoggerFactory.getLogger(ZipStreamProcessor.class);

    public void process(URL url, ZipOutputStream outputStream) {
        // 构建REST客户端
        DispatchService dispatchService = ResteasyClientBuilder.newBuilder()
                .baseUrl(url)
                .build(DispatchService.class);

        try (DispatchService autoCloseableClient = dispatchService) {
            Response response = autoCloseableClient.get();

            // 创建Zip条目并写入流
            outputStream.putNextEntry(new ZipEntry("large-xml-data.xml"));
            try (InputStream inputStream = response.readEntity(InputStream.class)) {
                inputStream.transferTo(outputStream);
            }
            outputStream.closeEntry();

            LOG.info("XML文件已写入Zip");
        } catch (Exception ex) {
            LOG.debug("处理过程中发生异常", ex);
        }
    }

    @Path("")
    public interface DispatchService extends AutoCloseable {

        @GET // 修正为GET请求，符合REST语义
        @Produces(MediaType.APPLICATION_XML)
        Response get();
    }
}

内容的提问来源于stack exchange，提问作者Sjaak