2023年8月3日发(作者：)

java怎么解压sftp的⽂件_java使⽤sftp与linux之间进⾏⽂件传输解压最近有个需求是上传⼀个压缩包到服务器并实现解压缩，⽹上找了⼏个使⽤ftp上传的例⼦但是没有实现，各⽅⾯总结加上⾃⼰的理解编写，最后使⽤sftp进⾏涉及，最后实现了⽂件的上传、下载、删除、解压缩以及⽂件夹的创建。特此记录下⼀下，以便不时之需。1.简单了解 ftp和sftp的区别在linux系统中，最长使⽤到的⽂件传输的⽅式莫过于ftp和(File Transfer Protocol)，即⽂件传输协议，⽤于Internet上控制⽂件的双向传输。FTP在linux系统中，传输默认的端⼝为21端⼝，通常以ASCII码和⼆进制的⽅式传输数据，⽀持主动模式和被动模式两种⽅式。但Linux默认是不提供ftp的，需要你额外安装FTP服务器。SFTP(Secure File Transfer Protocol)，即⽂件加密传输协议，SFTP在linux系统中，传输默认的端⼝为22端⼝，这种传输⽅式更为安全，传输双⽅既要进⾏密码安全验证，还要进⾏基于密钥的安全验证，有效的防⽌了“中间⼈”的威胁和攻击。在使⽤linux的centos服务器系统中，两个⽐较起来，ftp传输会⽐sftp传输速率快，毕竟sftp牺牲了⼀定的效率，以保证传输过程的安全。2.简单了解ChannelSftp类ChannelSftp类是JSch实现SFTP核⼼类，它包含了所有SFTP的⽅法，如：put()： ⽂件上传get()： ⽂件下载cd()： 进⼊指定⽬录ls()： 得到指定⽬录下的⽂件列表rename()： 重命名指定⽂件或⽬录rm()： 删除指定⽂件mkdir()： 创建⽬录rmdir()： 删除⽬录还有很多⽅法，有需要去看源码2.代码直接贴代码，⾥⾯有注释SFTPInfolinux的环境参数package 2linux;/*** @version: 1.0* @Description:⽂件上传的环境配置* @author: zshuai* @date: 2019年4⽉9⽇*/public class SFTPInfo {public static final String SFTP_REQ_HOST = "192.168.189.138"; //ippublic static final String SFTP_REQ_USERNAME = "root"; //usernamepublic static final String SFTP_REQ_PASSWORD = "rootzs"; //passwordpublic static final int SFTP_DEFAULT_PORT = 22; //端⼝}SFTPUtilpackage 2linux;import ;import putStream;import ist;import ;import ties;import ;import ;import Factory;import l;import lSftp;import y;import ;import ception;import n;import ception;import ;/*** @version: 1.0* @Description:⽂件上传/删除/解压缩* @author: zshuai* @date: 2019年4⽉9⽇*/public class SFTPUtil {private static final Logger LOG = ger();/** @Description: 获取⽂件上传的安全通道* @param session* @return*/public static Channel getChannel(Session session) {Channel channel = null;try {channel = annel("sftp");t();n("获取连接成功");("get Channel success!");} catch (JSchException e) {("get Channel fail!", e);}return channel;}/** @Description:获取连接信息，返回session，在session中获取安全通道* @param host：连接主机ip* @param port:端⼝号，⼀般sftp依托于ssh。端⼝号22* @param username：⽤户名* @param password：密码* @return*/public static Session getSession(String host, int port, String username, final String password) {Session session = null;try {JSch jsch = new JSch();sion(username, host, port);session = sion(username, host, port);sword(password);Properties sshConfig = new Properties();("StrictHostKeyChecking", "no");fig(sshConfig);t();("Session connected!");} catch (JSchException e) {("get Channel failed!", e);}return session;}/** @Description:创建⽂件夹* @param sftp* @param dir : 创建的⽂件夹名字*/public static Boolean mkdir(String dir) {Session s = getSession(_REQ_HOST, _DEFAULT_PORT, _REQ_USERNAME,_REQ_PASSWORD);Channel channel = getChannel(s);ChannelSftp sftp = (ChannelSftp) channel;Boolean result = false;try {("/");//相当于在linux命令⾏执⾏cd / ，然后在打开的⽬录下创建(dir);n("创建⽂件夹成功！");result = true;} catch (SftpException e) {n("创建⽂件夹失败！");result =false;tackTrace();}return result;}/** @Description: ⽂件上传的⽅法* @param sftp : 客户端* @param dir : 指定上传⽂件的⽬录* @param file : 上传的⽂件* @return :*/public static Boolean uploadFile(String dir, File file) {Session s = getSession(_REQ_HOST, _DEFAULT_PORT, _REQ_USERNAME,_REQ_PASSWORD);Channel channel = getChannel(s);ChannelSftp sftp = (ChannelSftp) channel;Boolean result =false;try {("/"+dir);n("打开⽬录");if (file != null) {(new FileInputStream(file), e());result = true;} else {result = false;}} catch (Exception e) {("上传失败！", e);result = false;}closeAll(sftp, channel, s); // 关闭连接return result;}/*** @Description: ⽂件下载* @param directory 下载⽬录* @param downloadFile 下载的⽂件* @param saveFile 存在本地的路径* @param sftp*/public static Boolean download(String directory, String downloadFile, String saveFile) {Session s = getSession(_REQ_HOST, _DEFAULT_PORT, _REQ_USERNAME,_REQ_PASSWORD);Channel channel = getChannel(s);ChannelSftp sftp = (ChannelSftp) channel;Boolean result =false;try {("/"+directory);(downloadFile, saveFile);result = true;} catch (Exception e) {result = false;("下载失败！", e);;}return result;}/*** @Description: ⽂件删除* @param directory 要删除⽂件所在⽬录* @param deleteFile 要删除的⽂件* @param sftp*/public static Boolean delete(String directory, String deleteFile ) {Session s = getSession(_REQ_HOST, _DEFAULT_PORT, _REQ_USERNAME,_REQ_PASSWORD);Channel channel = getChannel(s);ChannelSftp sftp = (ChannelSftp) channel;Boolean result = false;try {("/"+directory);(deleteFile);result = true;} catch (Exception e) {result = false;("删除失败！", e);}return result;}private static void closeChannel(Channel channel) {if (channel != null) {if (ected()) {nect();}}}private static void closeSession(Session session) {if (session != null) {if (ected()) {nect();}}}public static void closeAll(ChannelSftp sftp, Channel channel, Session session) {try {closeChannel(sftp);closeChannel(channel);closeSession(session);} catch (Exception e) {("closeAll", e);}}}ExtractUtilspackage 2linux;import edReader;import ption;import tream;import treamReader;import riter;import lCondition;import tion;import n;import Gobbler;/*** @version: 1.0* @Description: 远程解压缩指定⽬录下的指定名字的⽂件* @author: zshuai* @date: 2019年4⽉9⽇*/public class ExtractUtils {/** @Description:远程解压缩指定⽬录下的指定名字的⽂件* @param path:指定解压⽂件的⽬录* @param fileName:需要解压的⽂件名字* @param decpath :解压完成后的存放路径*/public static Boolean remoteZipToFile(/*String path, */String fileName /*, String decpath/**/) {String path = "zshuaipath";String decpath = "zshuai";Boolean result =false;try {Connection connection = new Connection(_REQ_HOST);// 创建⼀个连接实例t();// Now connectboolean isAuthenticated = ticateWithPassword(_REQ_USERNAME,_REQ_PASSWORD);// Authenticateif (isAuthenticated == false)throw new IOException("user and password error");Session sess = ssion();// Create a n("start ");tPTY("bash");hell();InputStream stdout = new StreamGobbler(out());InputStream stderr = new StreamGobbler(err());BufferedReader stdoutReader = new BufferedReader(new InputStreamReader(stdout));BufferedReader stderrReader = new BufferedReader(new InputStreamReader(stderr));PrintWriter out = new PrintWriter(in());n("cd /" + path + "/");n("ll");// n("unzip -o " + fileName + " -d /" + decpath + "/");//解压zip格式n("tar zxvf " + fileName + " -C /" + decpath + "/");//解压tar格式n("ll");n("exit");();rCondition( | | _STATUS, 30000);n("下⾯是从stdout输出:");while (true) {String line = ne();if (line == null)break;n(line);}n("下⾯是从stderr输出:");while (true) {String line = ne();if (line == null)break;n(line);}n("ExitCode: " + tStatus());();/* Close this session */();/* Close the connection */result = true;} catch (IOException e) {tackTrace();result =false;(2);}return result;}}TestFtppackage ;import ;import ;import tUtils;import il;public class TestFtp {@Test//测试⽂件上传public void testuploadfile() {File file = new File("D://");long startTime = tTimeMillis();//获取当前时间Boolean uploadFile = File("zshuaipath", file);Boolean remoteZipToFile = false;if (uploadFile) {n("上传成功，开始解压");remoteZipToFile = ZipToFile("");}long endTime = tTimeMillis();n("程序运⾏时间："+(endTime-startTime)+"ms");n(remoteZipToFile);}@Test//测试⽂件下载public void testdownloadfile() {long startTime = tTimeMillis();//获取当前时间Boolean download = ad("zshuaipath","", "D://1");long endTime = tTimeMillis();n("程序运⾏时间："+(endTime-startTime)+"ms");n(download);}@Test//测试⽂件删除public void testdeletefile() {long startTime = tTimeMillis();//获取当前时间Boolean delete = ("zshuaipath","");long endTime = tTimeMillis();n("程序运⾏时间："+(endTime-startTime)+"ms");n(delete);}@Test//测试⽂件夹的创建public void testmkdir() {long startTime = tTimeMillis();//获取当前时间Boolean mkdir = ("zshuaipath");long endTime = tTimeMillis();n("程序运⾏时间："+(endTime-startTime)+"ms");n(mkdir);}@Test//测试指定⽬录下的指定⽂件的解压缩public void testExtract() {long startTime = tTimeMillis();//获取当前时间Boolean remoteZipToFile = ZipToFile("");long endTime = tTimeMillis();n("程序运⾏时间："+(endTime-startTime)+"ms");n(remoteZipToFile);}}主要的pom⽂件frameworkspring-test${n}smaven-compiler-plugin3.21.81.8UTF-8