Java使用SSH从远程服务器下载文件


前言

Telnet、FTP、POP3在网络传输的过程中都是采用明文，容易被监听或者遭到到man-in-the-middle的攻击方式攻击。而SSH为远程登陆会话和其他的网络服务提供安全协议，通过加密数据防止传输过程中信息泄漏。
C/C++可以调用OpenSSH来实现SSH，Java也有相应的开源类库JSch，它是SSH2的一个纯Java实现。

CentOS 下SSH无密码登录的配置

Linux下实现SSH无密码验证登陆

Ubuntu和CentOS如何配置SSH使得无密码登陆

源代码

类SftpDownloader的源代码：

package cn.aofeng;

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.util.Properties;

import org.apache.commons.io.IOUtils;
import org.apache.log4j.Logger;

import cn.aofeng.dto.SftpConnectInfo;
import cn.aofeng.util.ConsoleProgressBar;

import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
import com.jcraft.jsch.SftpProgressMonitor;

/**
* 使用SFTP从远程主机下载文件。
*
* @author 傲风 <aofengblog@163.com>
*/
public class SftpDownloader {

private final static Logger logger = Logger.getLogger(SftpDownloader.class);

/**
* 使用SFTP从远程主机下载文件。
*
* @param connectInfo SFTP连接信息
* @param localPath 本地文件路径
* @param remotePath 远程文件路径
*/
public void download(SftpConnectInfo connectInfo, String localPath, final String remotePath) {
JSch jsch = new JSch();
Session session = null;
ChannelSftp channel = null;
OutputStream outs = null;
try {
session = jsch.getSession(connectInfo.getUsername(), connectInfo.getHost(), connectInfo.getPort());
session.setPassword(connectInfo.getPassword());
Properties props = new Properties();
props.put("StrictHostKeyChecking", "no");
session.setConfig(props);
session.connect(5000); // 毫秒
channel = (ChannelSftp) session.openChannel("sftp");
channel.connect(5000);
outs = new BufferedOutputStream(
new FileOutputStream(
new File(localPath)));
channel.get(remotePath, outs, new SftpProgressMonitor() {

ConsoleProgressBar progress = null;

private long current = 0;

@Override
public void init(int op, String src, String dest, long max) {
progress = new ConsoleProgressBar(0, max, 50);
}

@Override
public void end() {
if (logger.isInfoEnabled()) {
logger.debug( String.format("download file:%s complete", remotePath) );
}
}

@Override
public boolean count(long count) {
current += count;
progress.show(current);

return true;
}
});
} catch (JSchException e) {
logger.error( String.format("connect remote host[%s:%d] occurs error", connectInfo.getHost(), connectInfo.getPort()), e);
} catch (SftpException e) {
logger.error( String.format("get remote file:%s occurs error", remotePath), e);
} catch (FileNotFoundException e) {
logger.error( String.format("can not find local file:%s", localPath), e);
} finally {
IOUtils.closeQuietly(outs);
if (null != channel) {
channel.disconnect();
}
if (null != session) {
session.disconnect();
}
}
}
}

注：进度条ConsoleProgressBar的源代码查看文章Java实现在控制终端显示的字符进度条 

 

更多详情见请继续阅读下一页的精彩内容：

  • 1
  • 2
  • 下一页

相关内容