java获取sftp某路径下的所有zip文件并获得zip文件内容

需求&＃xff1a;

需要获得某个sftp上的某些增量的zip文件&＃xff0c;并将zip文件中的txt中的内容保存到数据库。

txt中文件的内容是以 |  隔开。

zip文件每天新增一个&＃xff0c;以前保存到数据库的zip中的数据不能重复保存。

package com.tmnch.tmnchpinan.ftpUtil;import com.jcraft.jsch.*;
import com.tmnch.tmnchpinan.entity.policyCount;
import com.tmnch.tmnchpinan.entity.sftpNameHistoryList;
import com.tmnch.tmnchpinan.ftpUtil.ftpConstant.constant;
import com.tmnch.tmnchpinan.service.FtpService;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.*;
import java.util.zip.*;/***  * Description:* 获取sftp某个路径下的所有zip文件 并获得每个zip文件中的内容*  **  * &＃64;author thw*  * &＃64;date 2020/9/23 15:15*  */&＃64;Configuration
&＃64;EnableScheduling
public class ftpServices {private static Session sshSession;&＃64;Autowiredprivate FtpService ftpService;//首先批量跑历史的zip文件
/*&＃64;Test
*/&＃64;Scheduled(cron &＃61; "0/25 * * * * ?")//定时public void runHistoryZip() {ZipEntry zipEntry &＃61; null;String historyZip &＃61; "";historyZip &＃61; getHistoryZipName(historyZip); //取出历史已经写入的zip文件try {ChannelSftp sftp &＃61; sftpConnection(constant.ftp_host, constant.ftp_port, constant.ftp_userNmae, constant.ftp_password);Vector v &＃61; sftp.ls(constant.ftpPath); //路径下所有文件if (v.size() > 0) {Iterator it &＃61; v.iterator();while (it.hasNext()) { //遍历某路径下的所有文件ChannelSftp.LsEntry entry &＃61; (ChannelSftp.LsEntry) it.next();String fileNameZip &＃61; entry.getFilename();//路径下某个文件名称名称if (fileNameZip.contains(constant.fileType)) {//获取所有zip文件对象System.out.println(fileNameZip);/*** 该处需要做特殊处理&＃xff0c;去除掉以前曾经已经跑过的zip文件*/if (historyZip.length() > 0) {if (historyZip.contains(fileNameZip)) {continue;}}InputStream in &＃61; sftp.get(constant.ftpPath &＃43; fileNameZip);//获取文件内容ZipInputStream zin &＃61; new ZipInputStream(in);while ((zipEntry &＃61; zin.getNextEntry()) !&＃61; null) {//遍历该zip文件内容String line &＃61; "";String fileNmae &＃61; null;String[] fileNmaeLIst &＃61; null;String tableNmae &＃61; null;BufferedReader bufferedReader &＃61; new BufferedReader(new InputStreamReader(zin, "UTF-8"));while ((line &＃61; bufferedReader.readLine()) !&＃61; null) {//读取该zip内文件的内容fileNmae &＃61; zipEntry.getName();//&＃xff1b;路径名称fileNmaeLIst &＃61; fileNmae.split(constant.speatorTable);tableNmae &＃61; fileNmaeLIst[2];String[] sort &＃61; null;switch (tableNmae) {case "ProDclause":sort &＃61; line.split(constant.speator);System.out.println(sort[4]);continue;case "ProDClauseKind":sort &＃61; line.split(constant.speator);System.out.println(sort[5]);continue;}}}//特殊处理&＃xff0c;保存过得zip需要将文件名存入记录表ftpService.insrtGistoryZip(fileNameZip);in.close();}}}sftpClose(sftp);sessionClose();} catch (Exception e) {e.printStackTrace();}//用于保存数据
/*List result &＃61;ftpService.getFtpTest("R51130600005");
*/}/*** &＃64;param host* &＃64;param password* &＃64;param port* &＃64;param userName* &＃64;return 连接对象* &＃64;description连接sftp**/public static ChannelSftp sftpConnection(String host, int port, String userName, String password) throws Exception {JSch jsch &＃61; new JSch();ChannelSftp channelSftp;jsch.getSession(userName, host, port);sshSession &＃61; jsch.getSession(userName, host, port);sshSession.setPassword(password);Properties properties &＃61; new Properties();properties.put("StrictHostKeyChecking", "no");sshSession.setConfig(properties);sshSession.connect();Channel channel &＃61; sshSession.openChannel("sftp");channel.connect();channelSftp &＃61; (ChannelSftp) channel;return channelSftp;}/*** &＃64;param* &＃64;return* &＃64;description 退出Sftp服务器登录**/public static void sftpClose(ChannelSftp channelSftp) {if (channelSftp !&＃61; null) {if (channelSftp.isConnected()) {channelSftp.disconnect();}}}/*** 关闭session*/public static void sessionClose() {if (sshSession !&＃61; null) {if (sshSession.isConnected()) {sshSession.disconnect();sshSession &＃61; null;}}}/*** 列出目录下的文件** &＃64;param directory&＃xff1a;要列出的目录* &＃64;param sftp* &＃64;return* &＃64;throws SftpException*/public Vector listFiles(String directory, ChannelSftp sftp) throws SftpException {return sftp.ls(directory);}public String getHistoryZipName(String historyZip) {List sftpNameHistoryList &＃61; ftpService.selectZiphistory(historyZip);if (sftpNameHistoryList.size() > 0) {for (sftpNameHistoryList sftp : sftpNameHistoryList) {historyZip &＃61; historyZip &＃43; constant.speatorTable &＃43; sftp.getName();}}return historyZip;}
}

constant.java 

//生产需要修改public static final String ftpPath &＃61; "/bin/";//文件路径public static final String ftp_host &＃61; "192.1.1.1";public static final int ftp_port &＃61; 22;public static final String ftp_userNmae &＃61; "root";public static final String ftp_password &＃61; "root";public static final String speator &＃61; "[|]";//文件内容隔离方式public static final String speatorTable &＃61; "/";//文件名隔离方式public static final String fileType &＃61; ".zip";//文件格式//1.000040\Acc\ProCInsureAcc