java實現(xiàn)sftp客戶端上傳文件以及文件夾的功能代碼
更新時間：2017年02月10日 14:28:51 作者：java.小菜鳥
本篇文章主要介紹了java實現(xiàn)sftp客戶端上傳文件以及文件夾的功能代碼，具有一定的參考價值，有興趣的可以了解一下。
1.依賴的jar文件 jsch-0.1.53.jar
2.登錄方式有密碼登錄,和密匙登錄
代碼:
主函數(shù):
import java.util.Properties;
import com.cloudpower.util.Login;
import com.util.LoadProperties;
public class Ftp {
public static void main(String[] args) {
Properties properties = LoadProperties.getProperties();
Login.login(properties);
}
}
登陸頁面的代碼:
package com.cloudpower.util;
import java.io.Console;
import java.util.Properties;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
public class Login {
public static void login(Properties properties) {
String ip = properties.getProperty("ip");
String user = properties.getProperty("user");
String pwd = properties.getProperty("pwd");
String port = properties.getProperty("port");
String privateKeyPath = properties.getProperty("privateKeyPath");
String passphrase = properties.getProperty("passphrase");
String sourcePath = properties.getProperty("sourcePath");
String destinationPath = properties.getProperty("destinationPath");
if (ip != null && !ip.equals("") && user != null && !user.equals("")
&& port != null && !port.equals("") && sourcePath != null
&& !sourcePath.equals("") && destinationPath != null
&& !destinationPath.equals("")) {
if (privateKeyPath != null && !privateKeyPath.equals("")) {
sshSftp2(ip, user, Integer.parseInt(port), privateKeyPath,
passphrase, sourcePath, destinationPath);
} else if (pwd != null && !pwd.equals("")) {
sshSftp(ip, user, pwd, Integer.parseInt(port), sourcePath,
destinationPath);
} else {
Console console = System.console();
System.out.print("Enter password:");
char[] readPassword = console.readPassword();
sshSftp(ip, user, new String(readPassword),
Integer.parseInt(port), sourcePath, destinationPath);
}
} else {
System.out.println("請先設(shè)置配置文件");
}
}
/**
* 密碼方式登錄
*
* @param ip
* @param user
* @param psw
* @param port
* @param sPath
* @param dPath
*/
public static void sshSftp(String ip, String user, String psw, int port,
String sPath, String dPath) {
System.out.println("password login");
Session session = null;
JSch jsch = new JSch();
try {
if (port <= 0) {
// 連接服務(wù)器，采用默認(rèn)端口
session = jsch.getSession(user, ip);
} else {
// 采用指定的端口連接服務(wù)器
session = jsch.getSession(user, ip, port);
}
// 如果服務(wù)器連接不上，則拋出異常
if (session == null) {
throw new Exception("session is null");
}
// 設(shè)置登陸主機(jī)的密碼
session.setPassword(psw);// 設(shè)置密碼
// 設(shè)置第一次登陸的時候提示，可選值：(ask | yes | no)
session.setConfig("StrictHostKeyChecking", "no");
// 設(shè)置登陸超時時間
session.connect(300000);
UpLoadFile.upLoadFile(session, sPath, dPath);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("success");
}
/**
* 密匙方式登錄
*
* @param ip
* @param user
* @param port
* @param privateKey
* @param passphrase
* @param sPath
* @param dPath
*/
public static void sshSftp2(String ip, String user, int port,
String privateKey, String passphrase, String sPath, String dPath) {
System.out.println("privateKey login");
Session session = null;
JSch jsch = new JSch();
try {
// 設(shè)置密鑰和密碼
// 支持密鑰的方式登陸，只需在jsch.getSession之前設(shè)置一下密鑰的相關(guān)信息就可以了
if (privateKey != null && !"".equals(privateKey)) {
if (passphrase != null && "".equals(passphrase)) {
// 設(shè)置帶口令的密鑰
jsch.addIdentity(privateKey, passphrase);
} else {
// 設(shè)置不帶口令的密鑰
jsch.addIdentity(privateKey);
}
}
if (port <= 0) {
// 連接服務(wù)器，采用默認(rèn)端口
session = jsch.getSession(user, ip);
} else {
// 采用指定的端口連接服務(wù)器
session = jsch.getSession(user, ip, port);
}
// 如果服務(wù)器連接不上，則拋出異常
if (session == null) {
throw new Exception("session is null");
}
// 設(shè)置第一次登陸的時候提示，可選值：(ask | yes | no)
session.setConfig("StrictHostKeyChecking", "no");
// 設(shè)置登陸超時時間
session.connect(300000);
UpLoadFile.upLoadFile(session, sPath, dPath);
System.out.println("success");
} catch (Exception e) {
e.printStackTrace();
}
}
}
文件上傳的代碼:
package com.cloudpower.util;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Scanner;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
public class UpLoadFile {
public static void upLoadFile(Session session, String sPath, String dPath) {
Channel channel = null;
try {
channel = (Channel) session.openChannel("sftp");
channel.connect(10000000);
ChannelSftp sftp = (ChannelSftp) channel;
try {
sftp.cd(dPath);
Scanner scanner = new Scanner(System.in);
System.out.println(dPath + ":此目錄已存在,文件可能會被覆蓋!是否繼續(xù)y/n?");
String next = scanner.next();
if (!next.toLowerCase().equals("y")) {
return;
}
} catch (SftpException e) {
sftp.mkdir(dPath);
sftp.cd(dPath);
}
File file = new File(sPath);
copyFile(sftp, file, sftp.pwd());
} catch (Exception e) {
e.printStackTrace();
} finally {
session.disconnect();
channel.disconnect();
}
}
public static void copyFile(ChannelSftp sftp, File file, String pwd) {
if (file.isDirectory()) {
File[] list = file.listFiles();
try {
try {
String fileName = file.getName();
sftp.cd(pwd);
System.out.println("正在創(chuàng)建目錄:" + sftp.pwd() + "/" + fileName);
sftp.mkdir(fileName);
System.out.println("目錄創(chuàng)建成功:" + sftp.pwd() + "/" + fileName);
} catch (Exception e) {
// TODO: handle exception
}
pwd = pwd + "/" + file.getName();
try {
sftp.cd(file.getName());
} catch (SftpException e) {
// TODO: handle exception
e.printStackTrace();
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
for (int i = 0; i < list.length; i++) {
copyFile(sftp, list[i], pwd);
}
} else {
try {
sftp.cd(pwd);
} catch (SftpException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
System.out.println("正在復(fù)制文件:" + file.getAbsolutePath());
InputStream instream = null;
OutputStream outstream = null;
try {
outstream = sftp.put(file.getName());
instream = new FileInputStream(file);
byte b[] = new byte[1024];
int n;
try {
while ((n = instream.read(b)) != -1) {
outstream.write(b, 0, n);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (SftpException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
outstream.flush();
outstream.close();
instream.close();
} catch (Exception e2) {
// TODO: handle exception
e2.printStackTrace();
}
}
}
}
}
讀取配置文件的代碼:
package com.util;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
public class LoadProperties {
public static Properties getProperties() {
File file = new File(Class.class.getClass().getResource("/").getPath()
+ "properties.properties");
InputStream inputStream = null;
try {
inputStream = new FileInputStream(file);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Properties properties = new Properties();
try {
properties.load(inputStream);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return properties;
}
}
代碼目錄結(jié)構(gòu):
測試運(yùn)行時配置文件放在項目的bin目錄下(打包成可運(yùn)行jar文件的時候要刪除,打包完成后將配置文件和jar包放在同級目錄下即可):
properties.properties
ip= user= pwd= port=22 privateKeyPath= passphrase= sourcePath= destinationPath=/home/dbbs/f
打包可運(yùn)行jar文件:
Export->java->Runnabe JAR file
完成后
在控制臺運(yùn)行java -jar 導(dǎo)出jar包的名字.jar 即可
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了如何使用Java實現(xiàn)上傳文件到服務(wù)器,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-04-04
這篇文章主要介紹了java和Spring中觀察者模式的應(yīng)用，，具有一定的參考價值，感興趣的可以了解一下，希望能夠給你帶來幫助2021-10-10
Springboot?jpa使用sum()函數(shù)返回結(jié)果如何被接收
這篇文章主要介紹了Springboot?jpa使用sum()函數(shù)返回結(jié)果如何接收，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-02-02
這篇文章主要介紹了JavaMail實現(xiàn)郵件發(fā)送的方法,實例分析了java實現(xiàn)郵件發(fā)送的相關(guān)技巧,非常具有實用價值,需要的朋友可以參考下2015-04-04
Mybatis Plus 實現(xiàn)批量插入的示例代碼
本文主要介紹了Mybatis Plus 實現(xiàn)批量插入的示例代碼，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-09-09
語法糖（Syntactic sugar），也叫做糖衣語法，是英國科學(xué)家發(fā)明的一個術(shù)語，通常來說使用語法糖能夠增加程序的可讀性，從而減少程序代碼出錯的機(jī)會.這篇文章主要介紹了Java 中的語法糖知識，需要的朋友可以參考下2020-12-12
這篇文章主要為大家詳細(xì)介紹了Java如何通過時間獲取8位驗證碼（每兩個小時生成一個）,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-11-11
這篇文章主要給大家介紹了關(guān)于Jar包反編譯修改代碼后重新打jar包的相關(guān)資料,JAR文件就是Java Archive(Java檔案文件),它是 Java的一種文檔格式,文中通過圖文介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07
RecyclerChart動態(tài)屬性圖標(biāo)聯(lián)動數(shù)據(jù)動態(tài)加載詳解
這篇文章主要為大家介紹了RecyclerChart動態(tài)屬性圖標(biāo)聯(lián)動數(shù)據(jù)動態(tài)加載詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-03-03
Maven導(dǎo)入Junit4后在test中無法引用問題
在使用Maven進(jìn)行項目管理時,可能會遇到導(dǎo)入依賴和打開項目結(jié)構(gòu)的問題,本文通過實際經(jīng)驗,提供了一些解決方法和技巧,希望能幫助遇到相同問題的開發(fā)者,此外,還鼓勵大家多多支持和分享個人經(jīng)驗,以便于共同進(jìn)步2024-10-10