java实现ServUFTP和SFTP上传下载

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;import javax.swing.*;
import java.io.*;
import java.net.SocketException;public class FtpUtil {private static FTPClient ftpClient &＃61; new FTPClient();/*** 获取FTPClient对象** &＃64;param ftpHost FTP主机服务器* &＃64;param ftpPassword FTP 登录密码* &＃64;param ftpUserName FTP登录用户名* &＃64;param ftpPort FTP端口 默认为21* &＃64;return*/public FTPClient getFTPClient(String ftpHost, String ftpUserName,String ftpPassword, int ftpPort) {try {ftpClient.connect(ftpHost, ftpPort);// 连接FTP服务器ftpClient.login(ftpUserName, ftpPassword);// 登陆FTP服务器if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {System.out.println("未连接到FTP&＃xff0c;用户名或密码错误。");ftpClient.disconnect();} else {System.out.println("FTP连接成功。");}} catch (SocketException e) {e.printStackTrace();System.out.println("FTP的IP地址可能错误&＃xff0c;请正确配置。");} catch (IOException e) {e.printStackTrace();System.out.println("FTP的端口错误,请正确配置。");}return ftpClient;}/*** 从FTP服务器下载文件* &＃64;param ftpPath FTP服务器中文件所在路径* &＃64;param localPath 下载到本地的位置* &＃64;param fileName 文件名称*/public void downloadFtpFile( String ftpPath, String localPath,String fileName) {try {ftpClient.setControlEncoding("UTF-8"); // 中文支持
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);ftpClient.enterLocalPassiveMode();ftpClient.changeWorkingDirectory(ftpPath);File localFile &＃61; new File(localPath &＃43; File.separatorChar &＃43; fileName);OutputStream os &＃61; new FileOutputStream(localFile);ftpClient.retrieveFile(fileName, os);os.close();ftpClient.logout();} catch (FileNotFoundException e) {System.out.println("没有找到" &＃43; ftpPath &＃43; "文件");e.printStackTrace();} catch (SocketException e) {System.out.println("连接FTP失败.");e.printStackTrace();} catch (IOException e) {e.printStackTrace();System.out.println("文件读取错误。");e.printStackTrace();}}/*** Description: 向FTP服务器上传文件* &＃64;param ftpPath FTP服务器中文件所在路径 格式&＃xff1a; ftptest/aa* &＃64;param fileName ftp文件名称* &＃64;param input 文件流* &＃64;return 成功返回true&＃xff0c;否则返回false*/public boolean uploadFile( String ftpPath,String fileName,InputStream input) {boolean success &＃61; false;try {int reply;reply &＃61; ftpClient.getReplyCode();if (!FTPReply.isPositiveCompletion(reply)) {ftpClient.disconnect();return success;}ftpClient.setControlEncoding("UTF-8"); // 中文支持
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);ftpClient.enterLocalPassiveMode();ftpClient.changeWorkingDirectory(ftpPath);ftpClient.storeFile(fileName, input);input.close();ftpClient.logout();success &＃61; true;} catch (IOException e) {e.printStackTrace();} finally {if (ftpClient.isConnected()) {try {ftpClient.disconnect();} catch (IOException ioe) {}}}return success;}public static void main(String args[]){String ftpHost &＃61; "127.0.0.1";String ftpUserName &＃61; "servUFtp";String ftpPassword &＃61; "14oioppii";Integer port &＃61; 21;String ftpPath &＃61; "/";String localPath &＃61; "F:\\";String fileName &＃61; "text.jpg";//上传一个文件try{FileInputStream in&＃61;new FileInputStream(new File(localPath));FtpUtil ftpUtil &＃61; new FtpUtil();ftpUtil.getFTPClient(ftpHost, ftpUserName, ftpPassword, port);// 上传文件boolean flag &＃61; ftpUtil.uploadFile( ftpPath, fileName,in);// 下载文件ftpUtil.downloadFtpFile( "/000.jpg", localPath, fileName);if(flag){System.out.println("文件上传ftp成功&＃xff0c;请检查ftp服务器。");}else{System.out.println("文件上传ftp异常。请重试&＃xff01;");}} catch (FileNotFoundException e){e.printStackTrace();System.out.println(e);}}}

import com.jcraft.jsch.*;import java.io.*;
import java.util.Properties;/*** &＃64;Author : guoyanan* &＃64;Title : Sftp工具类* &＃64;Time : 2019/04/18 14:52* &＃64;Document : 提供文件上传功能*/
public class SFtpUtils {// 初始化单例对象private static SFtpUtils sFtpUtils &＃61; new SFtpUtils();private String host;//服务器连接ipprivate String username;//用户名private String password;//密码private int port &＃61; 22;//端口号private ChannelSftp sftp &＃61; null;private Session sshSession &＃61; null;/*** 初始化sftp的单例对象* &＃64;return*/public static SFtpUtils getInstance(){return sFtpUtils;}/*** 初始化sft链接信息&＃xff0c;必须先做这个* &＃64;param host 远程主机ip* &＃64;param port 端口号* &＃64;param username 账号* &＃64;param password 密码*/public void init(String host, int port, String username, String password){this.host &＃61; host;this.username &＃61; username;this.password &＃61; password;this.port &＃61; port;}/*** 通过SFTP连接服务器*/public void connect(){try{JSch jsch &＃61; new JSch();jsch.getSession(username, host, port);sshSession &＃61; jsch.getSession(username, host, port);sshSession.setPassword(password);Properties sshConfig &＃61; new Properties();sshConfig.put("StrictHostKeyChecking", "no");sshSession.setConfig(sshConfig);sshSession.connect();Channel channel &＃61; sshSession.openChannel("sftp");channel.connect();sftp &＃61; (ChannelSftp) channel;}catch (Exception e){e.printStackTrace();}}/*** 关闭连接*/public void disconnect(){if (this.sftp !&＃61; null){if (this.sftp.isConnected()){this.sftp.disconnect();}}if (this.sshSession !&＃61; null){if (this.sshSession.isConnected()){this.sshSession.disconnect();}}}/*** sftp下载文件* &＃64;param remoteFielPath 远程文件路径* &＃64;param localFilePath 本地下载路径* &＃64;return* &＃64;throws SftpException* &＃64;throws FileNotFoundException*/public boolean downLoadFile(String remoteFielPath,String localFilePath) throws SftpException, FileNotFoundException {// 检查文件是否存在SftpATTRS sftpATTRS &＃61; sftp.lstat(remoteFielPath);if(!sftpATTRS.isReg()){// 不是一个文件&＃xff0c;返回falsereturn false;}// 下载文件到本地
sftp.get(remoteFielPath,localFilePath);return true;}/*** 下载文件放回文件数据* &＃64;param remoteFielPath* &＃64;return* &＃64;throws SftpException* &＃64;throws IOException*/public boolean downLoadFileTwo(String remoteFielPath, String localFilePath) throws SftpException, IOException {// 检查文件是否存在SftpATTRS sftpATTRS &＃61; sftp.lstat(remoteFielPath);// 判断是否是一个文件if(sftpATTRS.isReg()){// 下载文件到本地InputStream inputStream &＃61; sftp.get(remoteFielPath);/**今天想写下从sftp下载文件到本地&＃xff0c;虽然sftp提供了get(String remotePath,String LocalPath)方法&＃xff0c;将远程文件写入到本地。* 但还是想属性下从远程获取InputStream对象写入到本地的方式。* 遇到的问题&＃xff1a;刚开始只想这实现&＃xff0c;就是获取byte对象写入到本地文件&＃xff0c;先用ByteArrayInputStream怎么转都无法获取到bytes对象* 放入到FileOutputStream对象中。搞了老半天都没有搞定&＃xff0c;或许有ByteArrayInputStream对象下载的方式但没有找到。* 正解&＃xff1a;如下*/// 通过BufferedInputStream对象缓存输入流对象获取远程的输入流BufferedInputStream bufferedInputStream &＃61; new BufferedInputStream(inputStream);// 创建本地文件信息File file &＃61; new File("F:\\456.jpg");// 将本地文件放入到 本地文件输出流FileOutputStream fileOutputStream &＃61; new FileOutputStream(file);// 将本地文件输出流 放入到 缓存输出流对象BufferedOutputStream bufferedOutputStream &＃61; new BufferedOutputStream(fileOutputStream);// 声明每次获取的byte长度int len &＃61; 2048;// 初始化byte[]byte[] bytes &＃61; new byte[len];/**通过BufferedInputStream对象获取 远程文件 InputStream的bytes字节信息&＃xff0c;并循环添加到BufferedOutputStream缓存输出流对象中&＃xff0c;* 将远程bytes数据写入到本地文件中* 遇到的问题&＃xff1a;这里我一直纠结于为什么这样写会实现想要的效果&＃xff0c;是如何写入到本地的* 其实这不是开发中遇到的问题的事情了&＃xff0c;是自己困于自己设定的一个纠结情绪中了。也就是俗称的牛角尖。* 切记&＃xff0c;一定不可以钻牛角尖。因为开发都是有语言规则的。按照规则来就能实现效果&＃xff0c;脱离规则即使神仙也无能为力。* */while ((len &＃61; bufferedInputStream.read(bytes)) !&＃61; -1){bufferedOutputStream.write(bytes,0,len);}bufferedOutputStream.flush();bufferedInputStream.close();bufferedOutputStream.close();fileOutputStream.close();inputStream.close();return true;}return false;}/*** 上传单个文件&＃xff0c;通过文件路径上传* &＃64;param remotePath&＃xff1a;远程保存目录* &＃64;param remoteFileName&＃xff1a;保存文件名* &＃64;param localPath&＃xff1a;本地上传目录(以路径符号结束)* &＃64;param localFileName&＃xff1a;上传的文件名* &＃64;return*/public boolean uploadFile(String remotePath, String remoteFileName,String localPath, String localFileName){FileInputStream in &＃61; null;try{ // 创建目录
createDir(remotePath);File file &＃61; new File(localPath &＃43; localFileName);in &＃61; new FileInputStream(file);sftp.put(in, remoteFileName);return true;}catch (FileNotFoundException e){e.printStackTrace();}catch (SftpException e){e.printStackTrace();}finally{if (in !&＃61; null){try{in.close();}catch (IOException e){e.printStackTrace();}}}return false;}/*** 上传文件到sftp&＃xff0c;通过输入流上传* &＃64;param remotePath* &＃64;param remoteFileName* &＃64;param inputStream* &＃64;return*/public boolean uploadFile(String remotePath, String remoteFileName,InputStream inputStream){FileInputStream in &＃61; null;try{ // 创建目录
createDir(remotePath);sftp.put(inputStream, remoteFileName);return true;}catch (SftpException e){e.printStackTrace();}finally{if (in !&＃61; null){try{in.close();}catch (IOException e){e.printStackTrace();}}}return false;}/*** 创建目录* &＃64;param createpath* &＃64;return*/public boolean createDir(String createpath){try{if (isDirExist(createpath)){// 有时候&＃xff0c;开发在填写路径的时候第一个位置会忘记加"/"的根路径// 这回引发cd操作是发生&＃xff1a;NO Such File 异常&＃xff0c;所以这里处理下if(!(createpath.substring(0,1)&＃61;&＃61;"/")){createpath&＃61;"/"&＃43;createpath;}this.sftp.cd(createpath);return true;}String pathArry[] &＃61; createpath.split("/");StringBuffer filePath &＃61; new StringBuffer("/");for (String path : pathArry){if (path.equals("")){continue;}filePath.append(path &＃43; "/");if (isDirExist(filePath.toString())){sftp.cd(filePath.toString());}else{// 建立目录
sftp.mkdir(filePath.toString());// 进入并设置为当前目录
sftp.cd(filePath.toString());}}this.sftp.cd(createpath);return true;}catch (SftpException e){e.printStackTrace();}return false;}/*** 判断目录是否存在,linux目录必须最前方带有"/"* &＃64;param directory* &＃64;return*/public boolean isDirExist(String directory){boolean isDirExistFlag &＃61; false;try{// 有时候&＃xff0c;开发在填写路径的时候第一个位置会忘记加"/"的根路径// 这回引发cd操作是发生&＃xff1a;NO Such File 异常&＃xff0c;所以这里处理下if(!(directory.substring(0,1)&＃61;&＃61;"/")){directory&＃61;"/"&＃43;directory;}SftpATTRS sftpATTRS &＃61; sftp.lstat(directory);isDirExistFlag &＃61; true;return sftpATTRS.isDir();}catch (Exception e){if (e.getMessage().toLowerCase().equals("no such file")){isDirExistFlag &＃61; false;}}return isDirExistFlag;}public static void main(String arg[]) throws IOException, SftpException {// 获取图片的InputStream对象&＃xff0c;并将图片生成到sftp上SFtpUtils sFtpUtils&＃61; SFtpUtils.getInstance();sFtpUtils.init("127.0.0.1",22, "sftpuser", "UIOPOopi");sFtpUtils.connect();// 上传文件/*File file &＃61; new File("F:\\OK.jpg");InputStream in &＃61; new FileInputStream(file);boolean flag &＃61; sFtpUtils.uploadFile("/app/xwapp/Test","1111.jpg",in);*/// 下载文件到本地方法1// boolean flag &＃61; sFtpUtils.downLoadFile("/app/xwapp/Test/1111.jpg","F:\\OKbak.jpg");// 下载文件到本地方法2boolean flag &＃61; sFtpUtils.downLoadFileTwo("/app/xwapp/Test/1111.jpg","F:\\OKbak.jpg");if(flag){System.out.println("处理成功");}else {System.out.println("处理失败");}sFtpUtils.disconnect();}
}