本篇文章主要介绍了java实现sftp客户端上传文件以及文件夹的功能代码，具有一定的参考价值，有兴趣的可以了解一下。
1.依赖的jar文件 jsch-0.1.53.jar
2.登录方式有密码登录,和密匙登录
代码:
主函数:
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("请先设置配置文件");
}
}
/**
* 密码方式登录
*
* @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) {
// 连接服务器，采用默认端口
session = jsch.getsession(user, ip);
} else {
// 采用指定的端口连接服务器
session = jsch.getsession(user, ip, port);
}
// 如果服务器连接不上，则抛出异常
if (session == null) {
throw new exception("session is null");
}
// 设置登陆主机的密码
session.setpassword(psw);// 设置密码
// 设置第一次登陆的时候提示，可选值：(ask | yes | no)
session.setconfig("stricthostkeychecking", "no");
// 设置登陆超时时间
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 {
// 设置密钥和密码
// 支持密钥的方式登陆，只需在jsch.getsession之前设置一下密钥的相关信息就可以了
if (privatekey != null && !"".equals(privatekey)) {
if (passphrase != null && "".equals(passphrase)) {
// 设置带口令的密钥
jsch.addidentity(privatekey, passphrase);
} else {
// 设置不带口令的密钥
jsch.addidentity(privatekey);
}
}
if (port <= 0) {
// 连接服务器，采用默认端口
session = jsch.getsession(user, ip);
} else {
// 采用指定的端口连接服务器
session = jsch.getsession(user, ip, port);
}
// 如果服务器连接不上，则抛出异常
if (session == null) {
throw new exception("session is null");
}
// 设置第一次登陆的时候提示，可选值：(ask | yes | no)
session.setconfig("stricthostkeychecking", "no");
// 设置登陆超时时间
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 + ":此目录已存在,文件可能会被覆盖!是否继续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("正在创建目录:" + sftp.pwd() + "/" + filename);
sftp.mkdir(filename);
system.out.println("目录创建成功:" + 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("正在复制文件:" + 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;
}
}
代码目录结构:
测试运行时配置文件放在项目的bin目录下(打包成可运行jar文件的时候要删除,打包完成后将配置文件和jar包放在同级目录下即可):
properties.properties
ip=
user=
pwd=
port=22
privatekeypath=
passphrase=
sourcepath=
destinationpath=/home/dbbs/f
打包可运行jar文件:
export->java->runnabe jar file
完成后
在控制台运行java -jar 导出jar包的名字.jar 即可
以上就是java实现sftp客户端上传文件以及文件夹的功能代码的详细介绍的内容。