这篇“Java如何实现批量导出导入数据及附件文件zip包”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Java如何实现批量导出导入数据及附件文件zip包”文章吧。
某系统在不同单位使用时存在两套生产环境，他们的数据不是互通的，所以这些单位的上一级领导部门在统计数据的时候希望将A系统的数据和附件信息导出到一个压缩包里，然后把这个压缩包一键导入到B系统，这样B系统就包含了全部的数据，上级领导就能看到全部的业务信息，便于统计分析。
String path = profile + "/temp/" + DateUtils.dateTimeNow();
File file = new File(path);
if (file.mkdirs()) {
System.out.println("文件夹创建成功！创建后的文件目录为：" + file.getPath());
}
//1. 输出Excel文件
HSSFWorkbook workbook = new HSSFWorkbook();
HSSFSheet sheet = workbook.createSheet("sheet");
String fileName="XX数据导出.xls";
String savePath= file.getPath() + File.separator +fileName;
OutputStream os = new FileOutputStream(savePath);
//响应到客户端(即浏览器端直接弹出下载连接的方式)需要用response获取流
//this.setResponseHeader(response, filename);
//OutputStream os = response.getOutputStream();
List<HashMap> dataList = new ArrayList<>();
try{
// 表头
this.createExcelTitle(workbook, sheet);
// 查询条件
HashMap param = this.buildQueryParams(params);
dataList = shareRegisterMapper.shareList(param);
if (CollectionUtils.isEmpty(dataList)){
return;
}
this.dealAssetData(dataList, sheet);
// 处理子表数据
this.dealAssetDetailData(dataList,workbook);
workbook.write(os);
os.flush();
os.close();
}catch(Exception e) {
e.printStackTrace();
}finally {
if (os != null) {
os.flush();
os.close();
}
workbook.close();
}在上一步生成的Excel文件路径下新建files文件夹，里面存放附件
public void downloadFile(List<HashMap> dataList) throws Exception {
String urlPrefix = request.getScheme() + "://" + request.getServerName() + ":" + request.getServerPort() + request.getContextPath();
String savePath = file.getPath() + File.separator + "/files";
OutputStream os = null;
InputStream is = null;
int i=0;
try {
for (HashMap data : dataList) {
if (data == null || data.get("FILES") == null){
continue;
}
List<ZsglFileEntity> entityList = new ArrayList<>();
String[] fileArray = data.get("FILES").toString().split(",");
List idList = Arrays.asList(fileArray);
entityList.addAll(fileMapper.selectByIds(idList));
if (CollectionUtils.isNotEmpty(entityList)){
for (ZsglFileEntity file : entityList){
if ( file.getFssFileId() == null){
continue;
}
String fileUrl = urlPrefix + "/fss/download/" + file.getFssFileId();
// 构造URL
URL url = new URL(fileUrl);
// 打开连接
URLConnection con = url.openConnection();
//设置请求超时为5s
con.setConnectTimeout(5 * 1000);
// 输入流
is = con.getInputStream();
File tempFile = new File(savePath + "/"+file.getFileName());
// 校验文件夹目录是否存在，不存在就创建一个目录
if (!tempFile.getParentFile().exists()) {
tempFile.getParentFile().mkdirs();
}
os = new FileOutputStream(tempFile);
is = con.getInputStream();
con.getHeaderFields();
IOUtils.copy(is, os);
System.out.println("下载完成");
}
entityList.clear();
}
}
}catch (IOException e){
System.err.println(e);
}finally {
IOUtils.closeQuietly(is);
IOUtils.closeQuietly(os);
}
} response.setCharacterEncoding("UTF-8");
response.setContentType("multipart/form-data");
response.setHeader("content-disposition", "attachment;filename=" + "XX数据导出.zip");
ZipOutputStream zos = new ZipOutputStream(response.getOutputStream());
try {
File[] sourceFiles = file.listFiles();
if (null == sourceFiles || sourceFiles.length < 1) {
System.out.println("待压缩的文件目录：" + "里面不存在文件，无需压缩.");
} else {
for (int i = 0; i < sourceFiles.length;i++){
File srcFile = sourceFiles[i];
if (srcFile.isDirectory()){
File[] imageSourceFiles = srcFile.listFiles();
if (null == imageSourceFiles || imageSourceFiles.length < 1){
continue;
}
for (File imageFile : imageSourceFiles){
compress(zos,imageFile,srcFile.getName()+"/");
}
} else {
compress(zos,srcFile,"");
}
}
}
}catch (Exception e){
e.printStackTrace();
} finally {
//关闭流
try {
if(null != zos) {
zos.close();
}
} catch (IOException e){
e.printStackTrace();
}
}其中的压缩方法如下：
public void compress(ZipOutputStream out,File sourceFile,String base) throws Exception
{
out.putNextEntry( new ZipEntry(base+sourceFile.getName()) );
FileInputStream fos = new FileInputStream(sourceFile);
BufferedInputStream bis = new BufferedInputStream(fos);
int tag;
System.out.println(base);
//将源文件写入到zip文件中
while((tag=bis.read())!=-1) {
out.write(tag);
out.flush();
}
out.closeEntry();
bis.close();
fos.close();
}public void deleteDirectory(File file) {
File[] list = file.listFiles(); //无法做到list多层文件夹数据
if (list != null) {
for (File temp : list) { //先去递归删除子文件夹及子文件
deleteDirectory(temp); //注意这里是递归调用
}
}
if (!file.delete()) { //再删除自己本身的文件夹
logger.error("文件删除失败 : %s%n", file);
}
}这里开始想着在不解压的情况下读取里面的文件，结果没有走通。因为zip里面包含了子文件夹里面的附件信息需要解析。不解压直接解析文件适用于只需要解析zip包中第一层文件的场景，如果子文件夹下的文件也需要处理的话，最好解压后再处理。
public void unzip(ZipInputStream zipIn, String destDirectory) throws IOException {
File destDir = new File(destDirectory);
if (!destDir.exists()) {
destDir.mkdirs();
}
ZipEntry entry = zipIn.getNextEntry();
// 遍历Zip文件中的条目
while (entry != null) {
String filePath = destDirectory + File.separator + entry.getName();
if (!entry.isDirectory()) {
int index = entry.getName().indexOf("/");
if (index > -1 && entry.getName().length() > index){
File tempFile = new File(destDirectory + File.separator +entry.getName().substring(0,index));
if (!tempFile.exists()){
tempFile.mkdir();
}
}
File checkFile = new File(filePath);
if (!checkFile.exists()) {
checkFile.createNewFile();// 创建目标文件
}
// 如果条目是文件直接解压
BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filePath));
byte[] bytesIn = new byte[1024];
int read = 0;
while ((read = zipIn.read(bytesIn)) != -1) {
bos.write(bytesIn, 0, read);
}
bos.close();
} else {
File dir = new File(filePath);
if (!dir.exists()){
dir.mkdirs();
}
}
zipIn.closeEntry();
entry = zipIn.getNextEntry();
}
zipIn.close();
}这里解压遇到了一个问题，之前导出生成的zip包直接导入没问题，但是我把导出的包手动解压后修改了部分数据重新压缩后再导入报错：ZipInputStream解压远程文件报错，java.lang.IllegalArgumentException: MALFORMED
原因：文件名含有中文，zip解析出错
解决方案，如下行代码，在生成ZipInputStream的时候指定编码格式。
ZipInputStream zis = new ZipInputStream(new BufferedInputStream(inputStream), Charset.forName(“GBK”));
public List<HashMap> readLocalFile() throws Exception {
File file= new File(destDirectory+"/files");
List<HashMap> fssList = new ArrayList<>();
if (file.exists()) {
File[] sourceFiles = file.listFiles();
if (null == sourceFiles || sourceFiles.length < 1) {
System.out.println(file.getName()+"目录里面不存在文件，无需处理.");
return fssList;
} else {
for (int i = 0; i < sourceFiles.length;i++){
File srcFile = sourceFiles[i];
FileItemFactory factory = new DiskFileItemFactory(16, null);
FileItem item = factory.createItem(srcFile.getName(), "text/plain", true, srcFile.getName());
int bytesRead = 0;
byte[] buffer = new byte[8192];
try {
FileInputStream fis = new FileInputStream(srcFile);
OutputStream os = item.getOutputStream();
while ((bytesRead = fis.read(buffer, 0, 8192)) != -1) {
os.write(buffer, 0, bytesRead);
}
os.close();
fis.close();
} catch (IOException e) {
e.printStackTrace();
}
MultipartFile mfile = new CommonsMultipartFile(item);
AjaxResult fileResult = this.fssFileService.uploadFile(mfile);
String filePath = fileResult.get("url") == null ? "" : fileResult.get("url").toString();
if (fileResult.get("fileId") != null){
HashMap tempMap = new HashMap();
String fileId = this.fileService.saveFileInfo(fileResult.get("fileId").toString(),mfile, filePath, "");
tempMap.put(srcFile.getName(), fileId);
fssList.add(tempMap);
}
}
}
}
return fssList;
}注意：这里有个小难点就是File转换成MultipartFile的方法，因为项目中已经有的上传文件是MultipartFile格式的，转换一下就不用在实现一遍上传方法了。
我是用EasyExcel导入Excel文件的，代码很简单，需要注意用EasyExcel导入的Excel文件如果包含多个sheet页，需要写多个导入监听文件。
这一步实现方法跟导出时相同，去掉临时文件。
以上就是关于“Java如何实现批量导出导入数据及附件文件zip包”这篇文章的内容，相信大家都有了一定的了解，希望小编分享的内容对大家有帮助，若想了解更多相关的知识内容，请关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
