1.ftp和ftps
ftp文件传输协议是应用层协议，用于传输文件信息，linux上需要安装vsftpd才能使用(明文传输)
ftps为FTP协议和数据通道添加了SSL功能，可以对传输信息加密
2.ftp传输文件
引入maven依赖
<!-- /artifact/commons-net/commons-net --><dependency><groupId>commons-net</groupId><artifactId>commons-net</artifactId><version>3.6</version></dependency>
代码，此处将传入的文件参数改为MultipartFile类型，方便前端传递文件数据，再转为File对象(建立临时文件，上传完成会删除)，如果需要可以自己改为文件路径
package com.wyl.ppa.utils;import java.io.*;import java.util.TimeZone;import .ftp.FTPClient;import .ftp.FTPClientConfig;import .ftp.FTPFile;import .ftp.FTPReply;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.web.multipart.MultipartFile;public class Ftp {private FTPClient ftpClient;private String strIp;private int intPort;private String user;private String password;private static final Logger logger = LoggerFactory.getLogger(Ftp.class);/* ** Ftp构造函数*/public Ftp(String strIp, int intPort, String user, String Password) {this.strIp = strIp;this.intPort = intPort;this.user = user;this.password = Password;this.ftpClient = new FTPClient();}/*** 判断是否登入成功* */public void ftpLogin() {FTPClientConfig ftpClientConfig = new FTPClientConfig();ftpClientConfig.setServerTimeZoneId(TimeZone.getDefault().getID());this.ftpClient.setControlEncoding("GBK");this.ftpClient.configure(ftpClientConfig);try {if (this.intPort > 0) {this.ftpClient.connect(this.strIp, this.intPort);} else {this.ftpClient.connect(this.strIp);}// FTP服务器连接回答int reply = this.ftpClient.getReplyCode();if (!FTPReply.isPositiveCompletion(reply)) {this.ftpClient.disconnect();System.out.println();logger.error("登录FTP服务失败！");return;}this.ftpClient.login(this.user, this.password);// 设置传输协议this.ftpClient.enterLocalPassiveMode();this.ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);logger.info(this.user + "成功登陆FTP服务器");} catch (Exception e) {e.printStackTrace();logger.error(this.user + "登录FTP服务失败！" + e.getMessage());return;}this.ftpClient.setBufferSize(1024 * 2);this.ftpClient.setDataTimeout(30 * 1000);}/*** 退出关闭服务器链接* */public void ftpLogOut() {if (null != this.ftpClient && this.ftpClient.isConnected()) {try {boolean reuslt = this.ftpClient.logout();// 退出FTP服务器if (reuslt) {logger.info("成功退出服务器");}} catch (IOException e) {e.printStackTrace();logger.warn("退出FTP服务器异常！" + e.getMessage());} finally {try {this.ftpClient.disconnect();// 关闭FTP服务器的连接} catch (IOException e) {e.printStackTrace();logger.warn("关闭FTP服务器的连接异常！");}}}}/**** 上传multipartFile文件* @param multipartFile 上传的文件* @param romotUpLoadePath 上传服务器路径 - 应该以/结束* */public void uploadMultipartFile(MultipartFile multipartFile, String romotUpLoadePath) {File localFile = FileUtils.multipartFileToFile(multipartFile);BufferedInputStream inStream = null;boolean success;try {this.ftpClient.changeWorkingDirectory(romotUpLoadePath);// 改变工作路径inStream = new BufferedInputStream(new FileInputStream(localFile));logger.info(localFile.getName() + "开始上传.....");success = this.ftpClient.storeFile(localFile.getName(), inStream);if (success) {logger.info(localFile.getName() + "上传成功");}FileUtils.deleteTempFile(localFile);} catch (FileNotFoundException e) {e.printStackTrace();logger.error(localFile + "未找到");} catch (IOException e) {e.printStackTrace();} finally {if (inStream != null) {try {inStream.close();} catch (IOException e) {e.printStackTrace();}}}}/**** 上传multipartFile文件* @param localFile 上传的文件* @param romotUpLoadePath 上传服务器路径 - 应该以/结束* */private void uploadFile(File localFile, String romotUpLoadePath) {BufferedInputStream inStream = null;boolean success;try {this.ftpClient.changeWorkingDirectory(romotUpLoadePath);// 改变工作路径inStream = new BufferedInputStream(new FileInputStream(localFile));logger.info(localFile.getName() + "开始上传.....");success = this.ftpClient.storeFile(localFile.getName(), inStream);if (success) {logger.info(localFile.getName() + "上传成功");}} catch (FileNotFoundException e) {e.printStackTrace();logger.error(localFile + "未找到");} catch (IOException e) {e.printStackTrace();} finally {if (inStream != null) {try {inStream.close();} catch (IOException e) {e.printStackTrace();}}}}/**** 下载文件* @param remoteFileName 待下载文件名称* @param localDires 下载到当地那个路径下* @param remoteDownLoadPath remoteFileName所在的路径* */public void downloadFile(String remoteFileName, String localDires,String remoteDownLoadPath) {String strFilePath = localDires + remoteFileName;BufferedOutputStream outStream = null;boolean success = false;try {this.ftpClient.changeWorkingDirectory(remoteDownLoadPath);outStream = new BufferedOutputStream(new FileOutputStream(strFilePath));logger.info(remoteFileName + "开始下载....");success = this.ftpClient.retrieveFile(remoteFileName, outStream);if (success) {logger.info(remoteFileName + "成功下载到" + strFilePath);return;}} catch (Exception e) {e.printStackTrace();logger.error(remoteFileName + "下载失败");} finally {if (null != outStream) {try {outStream.flush();outStream.close();} catch (IOException e) {e.printStackTrace();}}}if (!success) {logger.error(remoteFileName + "下载失败!!!");}}/**** 上传文件夹* @param localDirectory* 当地文件夹* @param remoteDirectoryPath* Ftp 服务器路径 以目录"/"结束* */public void uploadDirectory(String localDirectory,String remoteDirectoryPath) {File src = new File(localDirectory);try {remoteDirectoryPath = remoteDirectoryPath + src.getName() + "/";this.ftpClient.makeDirectory(remoteDirectoryPath);// ftpClient.listDirectories();} catch (IOException e) {e.printStackTrace();logger.info(remoteDirectoryPath + "目录创建失败");}File[] allFile = src.listFiles();assert allFile != null;for (File file : allFile) {if (!file.isDirectory()) {String srcName = file.getPath();uploadFile(new File(srcName), remoteDirectoryPath);}}for (File file : allFile) {if (file.isDirectory()) {// 递归uploadDirectory(file.getPath(),remoteDirectoryPath);}}}/**** 下载文件夹* @param localDirectoryPath 本地地址* @param remoteDirectory 远程文件夹* */public void downLoadDirectory(String localDirectoryPath,String remoteDirectory) {try {String fileName = new File(remoteDirectory).getName();localDirectoryPath = localDirectoryPath + fileName + "//";boolean mkdirs = new File(localDirectoryPath).mkdirs();if(!mkdirs){logger.error("创建文件失败！");return;}FTPFile[] allFile = this.ftpClient.listFiles(remoteDirectory);for (FTPFile ftpFile : allFile) {if (!ftpFile.isDirectory()) {downloadFile(ftpFile.getName(), localDirectoryPath, remoteDirectory);}}for (FTPFile ftpFile : allFile) {if (ftpFile.isDirectory()) {String strremoteDirectoryPath = remoteDirectory + "/" + ftpFile.getName();downLoadDirectory(localDirectoryPath, strremoteDirectoryPath);}}} catch (IOException e) {e.printStackTrace();logger.info("下载文件夹失败");}}}
3.ftps
引入maven依赖<dependency>
<dependency> <groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.54</version></dependency>
代码中设置了私钥，但是我上传没有用到加密功能，需要的话可以自己下载openssl生成一个私钥和公钥，把把公钥放在服务器上，私钥设置在代码里上传就可以了
package com.wyl.ppa.utils;import com.jcraft.jsch.*;import java.io.*;import java.util.Properties;/*** Created by zhenghao on /9/18.*/public class SFtp {private ChannelSftp sftp;private Session session;/*** SFTP 登录用户名*/private String username;/*** SFTP 登录密码*/private String password;/*** 私钥*/private String privateKey;/*** SFTP 服务器地址IP地址*/private String host;/*** SFTP 端口*/private int port;/*** 构造基于密码认证的sftp对象*/public SFtp(String username, String password, String host, int port) {this.username = username;this.password = password;this.host = host;this.port = port;}/*** 构造基于秘钥认证的sftp对象*/public SFtp(String username, String host, int port, String privateKey) {this.username = username;this.host = host;this.port = port;this.privateKey = privateKey;}/*** 连接sftp服务器*/public void login() {try {JSch jsch = new JSch();if (privateKey != null) {jsch.addIdentity(privateKey);// 设置私钥}session = jsch.getSession(username, host, port);if (password != null) {session.setPassword(password);}Properties config = new Properties();config.put("StrictHostKeyChecking", "no");session.setConfig(config);session.connect();Channel channel = session.openChannel("sftp");channel.connect();sftp = (ChannelSftp) channel;} catch (JSchException e) {e.printStackTrace();}}/*** 关闭连接 server*/public void logout() {if (sftp != null) {if (sftp.isConnected()) {sftp.disconnect();}}if (session != null) {if (session.isConnected()) {session.disconnect();}}}/*** 将输入流的数据上传到sftp作为文件。文件完整路径=basePath+directory** @param directory 上传到该目录* @param sftpFileName sftp端文件名*/public boolean upload(String directory, String sftpFileName, InputStream input) throws SftpException {try {if (directory != null && !"".equals(directory)) {sftp.cd(directory);}sftp.put(input, sftpFileName); //上传文件return true;} catch (SftpException e) {return false;}}//上传文件测试public static void main(String[] args) throws SftpException, IOException {}}
