Java 使用线程把数据库导出为excel

@Component//被spring容器管理publicclassMyApplicationRunnerimplementsApplicationRunner {
@Overridepublicvoidrun(ApplicationArgumentsargs) throwsException {
System.out.println("-------------->"+"项目启动，now="+newDate());
ExcelThread.startExcelThread();
    }
}

publicclassQueueUtil {
publicstaticBlockingQueue<Object>queue=newLinkedBlockingQueue<>();
publicstaticObjectget() throwsException{
//        return queue.poll(2, TimeUnit.SECONDS); //不阻塞returnqueue.take(); //阻塞    }
publicstaticvoidput(Objectobj) throwsException{
queue.put(obj);
    }
}

@RequestMapping(value= {"/export/{tableName}"})
publicvoidexport(@PathVariableStringtableName ,Stringname){
//        System.out.println(tableName+"---"+name.length());  user---0if (name.length()==0){
service.exportZIP(tableName);
        }else {
service.exportZIP(tableName, name);
        }
    }

publicvoidexportZIP(StringtableName){
try {
QueueUtil.put(tableName);
    }catch (Exceptione){
e.printStackTrace();
System.out.println("存入数据失败");
    }
}
publicvoidexportZIP(StringtableName,Stringname){
try {
QueueUtil.put(tableName+":"+name);
    }catch (Exceptione){
e.printStackTrace();
System.out.println("存入数据失败");
    }
}

publicclassExcelThreadextendsThread{
privatestaticStringPATH="/file/";
privatestaticStringExcelName="用户信息表";
privatestaticStringTYPE=".xlsx";
//    @Value("${zip.name}")privatestaticStringZIP_NAME="用户信息";
privatestaticintSIZE=5000 ;
privateBlockingQueuequeue=QueueUtil.queue;
publicstaticExcelThreadexcelThread=null;
privateFilesServicefilesservice= (FilesService) ApplicationContextUtil.getBean("filesServiceImpl");
publicstaticvoidstartExcelThread(){
if (excelThread==null){
excelThread=newExcelThread();
        }
excelThread.start();
    }
@Overridepublicvoidrun() {
try {
while (true) {
Stringstr= (String) QueueUtil.get(); //《============String[] split=str.split(":");
zip(split);
            }
        } catch (Exceptione) {
e.printStackTrace();
        }
    }
publicvoidzip(String[] str) {
OutputStreamoutputStream;
ZipOutputStreamzipOutputStream;
Serviceservice= (Service) ApplicationContextUtil.getBean(str[0]+"ServiceImpl");
longdate=System.currentTimeMillis();
ZIP_NAME+=date;
Stringpath=System.getProperty("user.dir") +PATH+ZIP_NAME+".zip";
filesservice.alter();
intid=filesservice.save(newFiles(ZIP_NAME,newDate(date)));
try {
outputStream=newFileOutputStream(path);
zipOutputStream=newZipOutputStream(outputStream);
intcount=0;
if (str.length>1){
count=service.count(str[1]);
            }else {
count=service.count();
            }
count=count/SIZE+(count%SIZE==0?0:1);
for (Integeri=0; i<count; i++) {
byte[] buf=newbyte[1024];
List<User>userList;
if (str.length>1){
userList=service.selectPage(i+1,5000,str[1]);
                }else {
userList=service.selectPage(i+1,5000).getRecords();
                }
byte[] content=newFileUtil().excelTableStream(userList).toByteArray(); //返回一个excel文件ByteArrayInputStreamis=newByteArrayInputStream(content);
BufferedInputStreambis=newBufferedInputStream(is);
zipOutputStream.putNextEntry(newZipEntry(ExcelName+(i+1)+TYPE)); //压缩文件条目intlen;
while ((len=bis.read(buf)) >0) {
zipOutputStream.write(buf, 0, len);
                }
zipOutputStream.closeEntry();
bis.close();
is.close();
zipOutputStream.flush();
System.out.println(ExcelName+(i+1)+TYPE+"导出完成");
            }
zipOutputStream.close();
outputStream.close();
        } catch (Exceptione) {
e.printStackTrace();
        }finally {
filesservice.updateState(id,PATH+ZIP_NAME+".zip");
        }
    }
publicstaticvoidmain(String[] args) {
Datenow=newDate(); // 创建一个Date对象，获取当前时间// 指定格式化格式SimpleDateFormatf=newSimpleDateFormat("yyyy年MM月dd日 HH点mm分ss秒");
System.out.println(f.format(now)); // 将当前时间袼式化为指定的格式    }
}

publicByteArrayOutputStreamexcelTableStream(List<User>userList) {
try {
ByteArrayOutputStreambyteArrayOutputStream=newByteArrayOutputStream();
EasyExcel.write(byteArrayOutputStream, User.class)
//.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) 自动列宽  数字不起作用                .sheet("用户信息")
                .doWrite(() -> {
// 查询数据returnuserList;
                });
returnbyteArrayOutputStream;
    } catch (Exceptione) {
e.printStackTrace();
    }
returnnull;
}