JSch是SSH2的纯Java实现 。JSch允许您连接到sshd服务器并使用端口转发，X11转发，文件传输等，您可以将其功能集成到您自己的Java程序中。本文主要介绍利用JSch实现sftp通过ssh上传下载文件和一些相关配置。
2 编码使用
2.1 JSch的引用
1）项目中导入jsch-0.1.53.jar包
下载地址：https://sourceforge.net/projects/jsch/files/jsch/0.1.53/jsch-0.1.53.zip/download
2）Maven中引用的pom.xml配置
<dependency>
<groupId>com.jcraft</groupId>
<artifactId>jsch</artifactId>
<version>0.1.53</version>
</dependency>
gradle: compile group: 'com.jcraft', name: 'jsch', version: '0.1.53'
2.2 JSch连接配置代码
public class SFTP{
private Session session;//会话
private Channel channel;//连接通道
private ChannelSftp sftp;// sftp操作类
public Session getSession() {
return session;
}
public void setSession(Session session) {
this.session = session;
}
public Channel getChannel() {
return channel;
}
public void setChannel(Channel channel) {
this.channel = channel;
}
public ChannelSftp getSftp() {
return sftp;
}
public void setSftp(ChannelSftp sftp) {
this.sftp = sftp;
}
}
public static void getConnect(SFTP s) throws Exception {
/** 密钥的密码 */
// String privateKey ="key";
// /** 密钥文件路径 */
// String passphrase ="path";
/** 主机 */
String host ="127.0.0.1";
/** 端口 */
int port =22;
/** 用户名 */
String username ="test";
/** 密码 */
String password ="test";
Session session = null;
Channel channel = null;
ChannelSftp sftp = null;// sftp操作类
JSch jsch = new JSch();
//设置密钥和密码
//支持密钥的方式登陆，只需在jsch.getSession之前设置一下密钥的相关信息
// if (privateKey != null && !"".equals(privateKey)) {
// if (passphrase != null && "".equals(passphrase)) {
// //设置带口令的密钥
// jsch.addIdentity(privateKey, passphrase);
// } else {
// //设置不带口令的密钥
// jsch.addIdentity(privateKey);
// }
// }
session = jsch.getSession(username, host, port);
session.setPassword(password);
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no"); // 不验证 HostKey
session.setConfig(config);
try {
session.connect();
} catch (Exception e) {
if (session.isConnected())
session.disconnect();
}
channel = session.openChannel("sftp");
try {
channel.connect();
} catch (Exception e) {
if (channel.isConnected())
channel.disconnect();
}
sftp = (ChannelSftp) channel;
s.setChannel(channel);
s.setSession(session);
s.setSftp(sftp);
}
/*断开连接*/
public static void disConn(Session session,Channel channel,ChannelSftp sftp)throws Exception{
if(null != sftp){
sftp.disconnect();
sftp.exit();
sftp = null;
}
if(null != channel){
channel.disconnect();
channel = null;
}
if(null != session){
session.disconnect();
session = null;
}
}
2.3 使用JSch上传下载删除文件代码
1）上传文件代码
/**
* 上传文件
* @param directory 上传的目录-相对于SFPT设置的用户访问目录，
* 为空则在SFTP设置的根目录进行创建文件（除设置了服务器全磁盘访问）
*/
public static void upload(String directory,InputStream in,String name) throws Exception {
SFTP s=new SFTP();
getConnect(s);//建立连接
Session session = s.getSession();
Channel channel = s.getChannel();
ChannelSftp sftp = s.getSftp();// sftp操作类
try{
sftp.cd(directory); //进入目录
}catch(SftpException sException){
if(sftp.SSH_FX_NO_SUCH_FILE == sException.id){ //指定上传路径不存在
sftp.mkdir(directory);//创建目录
sftp.cd(directory); //进入目录
}
}
sftp.put(in, name);
in.close();
disConn(session,channel,sftp);
}
2）下载文件代码
/**
* 下载文件
* @param directory 下载目录 根据SFTP设置的根目录来进行传入
* @param downloadFile 下载的文件
* @param saveFile 存在本地的路径
*/
public static void download(String directory, String downloadFile,String saveFile) throws Exception {
SFTP s=new SFTP();
getConnect(s);//建立连接
Session session = s.getSession();
Channel channel = s.getChannel();
ChannelSftp sftp = s.getSftp();// sftp操作类
try {
sftp.cd(directory); //进入目录
File file = new File(saveFile);
boolean bFile;
bFile = false;
bFile = file.exists();
if (!bFile) {
bFile = file.mkdirs();//创建目录
}
OutputStream out=new FileOutputStream(new File(saveFile,downloadFile));
sftp.get(downloadFile, out);
out.flush();
out.close();
} catch (Exception e) {
throw new Exception(e.getMessage(),e);
} finally {
disConn(session,channel,sftp);
}
}
3）删除文件代码
/**
* 删除文件
* @param directory 要删除文件所在目录
* @param deleteFile 要删除的文件
*/
public static void delete(String directory, String deleteFile) throws Exception {
SFTP s=new SFTP();
getConnect(s);//建立连接
Session session = s.getSession();
Channel channel = s.getChannel();
ChannelSftp sftp = s.getSftp();// sftp操作类
try {
sftp.cd(directory); //要删除的目录的上一级
sftp.rm(deleteFile);//删除目录
} catch (Exception e) {
throw new Exception(e.getMessage(),e);
} finally {
disConn(session,channel,sftp);
}
}
2.4 拓展功能java使用命令操作linux
#添加用户
useradd -d /home/test -m fgb
#-d 目录 指定用户主目录，如果此目录不存在，则同时使用-m选项，可以创建主目录。
创建fgb用户 指定主目录为/home/test
#修改用户密码
echo password | passwd --stdin username
示例：把root用户的密码修改成123456
echo "123456" | passwd --stdin root
#删除用户
userdel -r username
示例：把fgb用户删除
userdel -r fgb
#给用户赋予某个文件夹权限
chown 700 fgb /usr/local/test
给fgb用户赋予/usr/local/test目录700权限
首先pom文件导入依赖
<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>262</version>
</dependency>
工具类
public class SshBasic{
//连接，登陆
public Connection login(String hostname,int port,String username,String password){
//获取连接
Connection conn = new Connection(hostname, port);
try {
//连接
conn.connect();
//输入账号密码登陆
boolean isAuthenticated = conn.authenticateWithPassword(username, password);
//登陆失败，返回错误
if(isAuthenticated == false){
throw new IOException("isAuthentication failed.");
}
} catch (IOException e) {
e.printStackTrace();
}
return conn;
}
//获取Session
public Session getSession(Connection conn){
Session sess = null;
try {
sess = conn.openSession();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return sess;
}
}
代码调用
public static void main(String[] args) {
SshBasic m = new SshBasic();
//连接并登陆
Connection conn = m.login("132.122.1.51", 22, "srglweb", "srglweb123");
//获取Session
Session sess = m.getSession(conn);
//执行命令 下面命令是删除用户fgb
try{
sess.execCommand("userdel -r fgb")
}catch(IOException e){
e.printStackTrace();
}
//判断会话是否成功
int result = sess.getExitStatus();//如果成功返回0
System.out.println("result:"+result);
//释放资源
sess.close();
conn.close();
}
}
