<!--sftp操作工具类--><dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.54</version></dependency>

package com.example.demo.util;import com.jcraft.jsch.*;
import lombok.extern.slf4j.Slf4j;import java.io.*;
import java.util.Properties;/*** 基于JSch的Sftp工具类** @author gblfy* @date 2020-10-12*/
@Slf4j
public class SftpUtil {/*** Session*/private Session session = null;/*** Channel*/private ChannelSftp channel = null;/*** SFTP服务器IP地址*/private String host;/*** SFTP服务器端口*/private int port;/*** 连接超时时间，单位毫秒*/private int timeout;/*** 用户名*/private String username;/*** 密码*/private String password;/*** SFTP 安全文件传送协议** @param host     SFTP服务器IP地址* @param port     SFTP服务器端口* @param timeout  连接超时时间，单位毫秒* @param username 用户名* @param password 密码*/public SftpUtil(String host, int port, int timeout, String username, String password) {this.host = host;this.port = port;this.timeout = timeout;this.username = username;this.password = password;}/*** 登陆SFTP服务器** @return boolean*/public boolean login() {try {JSch jsch = new JSch();session = jsch.getSession(username, host, port);if (password != null) {session.setPassword(password);}Properties config = new Properties();config.put("StrictHostKeyChecking", "no");session.setConfig(config);session.setTimeout(timeout);session.connect();log.debug("sftp session connected");log.debug("opening channel");channel = (ChannelSftp) session.openChannel("sftp");channel.connect();log.debug("connected successfully");return true;} catch (JSchException e) {log.error("sftp login failed", e);return false;}}/*** 登出sftp*/public void logout() {if (channel != null) {channel.quit();channel.disconnect();}if (session != null) {session.disconnect();}log.debug("logout successfully");}/*** 单个文件上传 (sftp目录不存在则创建后上传)** @param remotePath     远程目录* @param remoteFileName 远程文件名* @param localPath      应用本地目录* @param localFileName  应用本地文件名* @return*/public boolean uploadFile(String remotePath, String remoteFileName, String localPath, String localFileName) {FileInputStream in = null;try {System.out.println(remotePath);createDir(remotePath);File file = new File(localPath + localFileName);in = new FileInputStream(file);channel.put(in, remoteFileName);return true;} catch (FileNotFoundException e) {e.printStackTrace();} catch (SftpException e) {e.printStackTrace();} finally {if (in != null) {try {in.close();} catch (IOException e) {e.printStackTrace();}}}return false;}/*** 批量上传 (sftp目录不存在则创建后上传)** @param remotePath* @param localPath* @param isDel      是否上传完成后删除 true-删除 false-不删除* @return*/public boolean bacthUploadFile(String remotePath, String localPath, boolean isDel) {try {File file = new File(localPath);File[] files = file.listFiles();for (int i = 0; i < files.length; i++) {if (files[i].isFile()&& files[i].getName().indexOf("bak") == -1) {synchronized (remotePath) {createDir(remotePath);if (this.uploadFile(remotePath, files[i].getName(),localPath, files[i].getName()) && isDel) {deleteFile(localPath + files[i].getName());}}}}return true;} catch (Exception e) {e.printStackTrace();} finally {channel.disconnect();}return false;}/*** 单个文件下载 (应用目录不存在则创建后下载)** @param remotePath* @param remoteFileName* @param localPath* @param localFileName* @return*/public boolean downloadFile(String remotePath, String remoteFileName, String localPath, String localFileName) {try {channel.cd(remotePath);File file = new File(localPath + localFileName);mkdirs(localPath + localFileName);channel.get(remoteFileName, new FileOutputStream(file));return true;} catch (FileNotFoundException e) {e.printStackTrace();} catch (SftpException e) {e.printStackTrace();}return false;}/*** 判断目录存不存在，不存在则创建** @param createpath* @return*/public boolean createDir(String createpath) {try {if (isDirExist(createpath)) {channel.cd(createpath);log.info(createpath);return true;}String pathArry[] = createpath.split("/");StringBuffer filePath = new StringBuffer("/");for (String path : pathArry) {if (path.equals("")) {continue;}filePath.append(path + "/");createpath = filePath.toString();if (isDirExist(createpath)) {channel.cd(createpath);} else {channel.mkdir(createpath);channel.cd(createpath);}}channel.cd(createpath);return true;} catch (SftpException e) {e.printStackTrace();}return false;}/*** 判断目录是否存在** @param directory* @return*/public boolean isDirExist(String directory) {boolean isDirExistFlag = false;try {SftpATTRS sftpATTRS = channel.lstat(directory);isDirExistFlag = true;return sftpATTRS.isDir();} catch (Exception e) {if (e.getMessage().toLowerCase().equals("no such file")) {isDirExistFlag = false;}}return isDirExistFlag;}/*** 删除应用服务器文件(用于应用服务器上传SFTP文件服务器完成后)** @param filePath* @return*/public boolean deleteFile(String filePath) {File file = new File(filePath);if (!file.exists()) {return false;}if (!file.isFile()) {return false;}return file.delete();}/*** 创建目录** @param path*/public void mkdirs(String path) {File f = new File(path);String fs = f.getParent();f = new File(fs);if (!f.exists()) {f.mkdirs();}}
}