Java实现打包下载BLOB字段中的文件

概述

web项目的文件打包下载实现；servlet接收请求，spring工具类访问数据库及简化大字段内容获取，org.apache.tools.zip打包。

必要提醒：当前总结是继Java实现下载BLOB字段中的文件之后的总结，如有不解之处，请参考之。

核心代码

jdk提供了java.util.zip包，用于实现文件打包的功能，但是对中文名的文件没有很好的支持。org.apache.tools.zip包提供了几乎相同的接口，且额外提供了设置编码的接口。

public void write(OutputStream os, List fileList) throws IOException {
  org.apache.tools.zip.ZipOutputStream zos 
     = new org.apache.tools.zip.ZipOutputStream(os);
  zos.setEncoding(System.getProperty("sun.jnu.encoding"));
  
  byte[] buff = new byte[1024];
  for (int i = 0; i < fileList.size(); i++) {
     cn.com.hnisi.fzyw.xzfy.gz.download.domain.File file = 
          (cn.com.hnisi.fzyw.xzfy.gz.download.domain.File) fileList.get(i);
     String name = "file" + (i + 1) + "_" + file.getName();
     InputStream content = file.getIs();
  
     zos.putNextEntry(new org.apache.tools.zip.ZipEntry(name));
     for (int len = content.read(buff); len > 0;) {
       zos.write(buff, 0, len);
       len = content.read(buff);
     }
  
     content.close();
     zos.closeEntry();
  }
  
  zos.close();
}

上述代码实现了打包输出的功能：将指定的文件列表打包之后写到到指定的输出流。

代码优化

包图

各种包的作用与Java实现下载BLOB字段中的文件中相同。

类图

数据库访问支持组件

参考Java实现下载BLOB字段中的文件，没有变化。

File

参考Java实现下载BLOB字段中的文件，没有变化。

数据库访问组件

组件所包含的服务接口和实现类，添加了获取批量数据的相关方法；同时为了避免代码重复，原有方法的实现也稍有调整：

IDownloadService

package cn.com.hnisi.fzyw.xzfy.gz.download.service;
import java.util.List;
import cn.com.hnisi.fzyw.xzfy.gz.download.domain.File;
public interface IDownloadService {
    /**
     * 读取文件.<br>
     * 
     * @param sql
     *            查询sql语句，必须包含文件名字段和文件内容字段.
     * @param args
     *            参数 - 确保sql查询的结果只有一条.
     * @param colNameFileName
     *            存放文件名的字段名，大写.
     * @param colNameFileContent
     *            存放文件内容的字段名，大写.
     * @return
     */
    public File read(final String sql, final Object[] args,
            final String colNameFileName, final String colNameFileContent);
 
    /**
     * SINOBEST 文件下载 批量读取文件以供打包下载.
     * @param sql
     * @param colNameFileName
     * @param colNameFileContent
     * @return
     */
    public List batchRead(final String sql, final String colNameFileName,
            final String colNameFileContent);
}

DownloadServiceImpl

package cn.com.hnisi.fzyw.xzfy.gz.download.service;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.support.AbstractLobStreamingResultSetExtractor;
import org.springframework.jdbc.support.lob.DefaultLobHandler;
import org.springframework.jdbc.support.lob.LobHandler;
import cn.com.hnisi.baseservices.db.JdbcTemplateFactory;
import cn.com.hnisi.fzyw.xzfy.gz.download.domain.File;
public class DownloadServiceImpl implements IDownloadService {
    /**
     * SINOBEST common 文件下载实现.
     */
    public File read(final String sql, final Object[] args,
            final String colNameFileName, final String colNameFileContent) {
        String sql1 = sql.replaceFirst("\?", "'"+(String)args[0]+"'");
        List fileList = batchRead(sql1, colNameFileName, colNameFileContent);
        File file = (File)fileList.get(0);
        return file;
    }
 
    /**
     *  SINOBEST 批量读取BLOB类型数据
     */
    public List batchRead(String sql, final String colNameFileName,
            final String colNameFileContent) {
        JdbcTemplate jt = JdbcTemplateFactory.newInstance().getDefaultJT();
 
        final LobHandler lobHandler = new DefaultLobHandler();
 
        final List listFile = new ArrayList();
        jt.query(sql, new AbstractLobStreamingResultSetExtractor() {
            protected void streamData(ResultSet rs) throws SQLException,
                    IOException, DataAccessException {
                do{   //SINOBEST 文件下载 ，此处的rs初始化时已经指向第一条记录  
                    File file = new File();
                    file.setName(rs.getString(colNameFileName));
                    file.setIs(lobHandler.getBlobAsBinaryStream(rs,
                            colNameFileContent));
                    listFile.add(file);
                }while(rs.next());  
            }
        });
        return listFile;
    }
 
}

DownloadServiceFactory

参考Java实现下载BLOB字段中的文件，没有变化。

打包输出组件

这是一个新的组件，用以打包、输出到指定的输出流。

IZipService

打包服务的接口。

package cn.com.hnisi.fzyw.xzfy.gz.download.service;
import java.io.IOException;
import java.io.OutputStream;
import java.util.List;
/**
 * SINONBEST 文件打包接口.
 * 
 * @author lijinlong
 * 
 */
public interface IZipService {
    /**
     * SINOBEST 文件打包 将指定的多个文件打包成一个压缩文件，输出到指定的输出流.<br>
     * 
     * @param os
     *            指定的输出流
     * @param fileList
     *            指定的文件列表，每个元素都包含了文件名和输入流格式的文件内容
     */
    public void write(OutputStream os, List fileList) throws IOException;
    /**
     * SINOBEST 文件打包 将数据库中查询到的多个文件压缩之后输出到指定的输出流.<br>
     * 
     * @param sql 文件查询语句，包括文件名、文件内容（BLOB）两个字段.
     * @param colNameFileName 存放文件名的字段名.
     * @param colNameFileContent 存放文件内容的字段名.
     * @param os 指定的输出流.
     */
    public void write(final String sql, final String colNameFileName,
            final String colNameFileContent, final OutputStream os) throws IOException;
}

ZipServiceImpl

打包服务实现类。

package cn.com.hnisi.fzyw.xzfy.gz.download.service;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.List;
public class ZipServiceImpl implements IZipService {
    public void write(OutputStream os, List fileList) throws IOException {
        // 使用java.util.zip不支持设置编码格式
        org.apache.tools.zip.ZipOutputStream zos 
            = new org.apache.tools.zip.ZipOutputStream(os);
        zos.setEncoding(System.getProperty("sun.jnu.encoding"));
        byte[] buff = new byte[1024];
        for (int i = 0; i < fileList.size(); i++) {
            cn.com.hnisi.fzyw.xzfy.gz.download.domain.File file = 
                    (cn.com.hnisi.fzyw.xzfy.gz.download.domain.File) fileList.get(i);
            String name = "file" + (i + 1) + "_" + file.getName();
            InputStream content = file.getIs();
            zos.putNextEntry(new org.apache.tools.zip.ZipEntry(name));
            for (int len = content.read(buff); len > 0;) {
                zos.write(buff, 0, len);
                len = content.read(buff);
            }
            content.close();
            zos.closeEntry();
        }
        zos.close();
    }
    public void write(String sql, String colNameFileName,
            String colNameFileContent, OutputStream os) throws IOException {
        IDownloadService ids = DownloadServiceFactory.newInstance()
                .createDownloadService();
        List fileList = ids.batchRead(sql, colNameFileName, colNameFileContent);
        write(os, fileList);
    }
}

ZipServiceFactory

package cn.com.hnisi.fzyw.xzfy.gz.download.service;
public class ZipServiceFactory {
    private static ZipServiceFactory instance;
    private ZipServiceFactory() {
 
    }
 
    public static final synchronized ZipServiceFactory newInstance() {
        if (instance == null)
            instance = new ZipServiceFactory();
 
        return instance;
    }
 
    public IZipService create() {
        IZipService service = new ZipServiceImpl();
        return service;
    }
}

Servlet

BatchDownloadFileServlet

package cn.com.hnisi.fzyw.xzfy.gz.test.servlet;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import cn.com.hnisi.fzyw.xzfy.gz.download.service.IZipService;
import cn.com.hnisi.fzyw.xzfy.gz.download.service.ZipServiceFactory;
public class BatchDownloadFileServlet extends HttpServlet {
    private static final long serialVersionUID = -1288924386578872984L;
     
    /**
     * SINOBEST 文件打包下载 测试servlet.<br>
     */
    public void service(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        /* 1. 设置响应内容类型 */
        response.setContentType("Application/Octet-stream;charset=utf-8");
         
        /* 2. 将文件名加入响应头 */
        String zipName = "打包下载" + System.currentTimeMillis() + ".zip";
        zipName = new String(zipName.getBytes(), "ISO-8859-1");
        response.addHeader("Content-Disposition",
                "attachment; filename=" + zipName);
         
        /* 3. 输出文件内容 */
        String systemids = request.getParameter("systemids"); // systemids是多个systemid以逗号分隔拼接而成的字符序列
        systemids = ("'" + systemids + "'").replaceAll(",", "','");
        String sql = "select CLMC, SQCL from V_FZYWGZ_JK_XZFYSQXX_CL where SYSTEMID in (?)"
                .replaceFirst("\?", systemids);
        String colNameFileName = "CLMC";
        String colNameFileContent = "SQCL";
        IZipService service = ZipServiceFactory.newInstance().create();
        service.write(sql, colNameFileName, colNameFileContent, response.getOutputStream());
         
        /* 4. 关闭流 */
        response.getOutputStream().flush();
        response.getOutputStream().close();
    }
}