sftp文件上传和下载

浏览数：85 / 时间：2015年06月09日

sftp是Secure File Transfer Protocol的缩写，安全文件传送协议。可以为传输文件提供一种安全的加密方法。sftp 与 ftp 有着几乎一样的语法和功能。SFTP 为 SSH的一部份，是一种传输档案至 Blogger 伺服器的安全方式。其实在SSH软件包中，已经包含了一个叫作SFTP(Secure File Transfer Protocol)的安全文件传输子系统，SFTP本身没有单独的守护进程，它必须使用sshd守护进程（端口号默认是22）来完成相应的连接操作，所以从某种意义上来说，SFTP并不像一个服务器程序，而更像是一个客户端程序。SFTP同样是使用加密传输认证信息和传输的数据，所以，使用SFTP是非常安全的。但是，由于这种传输方式使用了加密/解密技术，所以传输效率比普通的FTP要低得多，如果您对网络安全性要求更高时，可以使用SFTP代替FTP。

下面是java 代码sftp文件上传和下载具体实现

1.连接服务器类

package Test;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;

/*
* @author lixiongjun
*
* 利用JSch包实现创建ChannelSftp通信对象的工具类
* 2015-1-27 上午10:03:21
*/

public class SftpUtil {

private static String ip = null; // ip 主机IP
private static int port = -1; // port 主机ssh2登陆端口，如果取默认值，传-1
private static String user = null; // user 主机登陆用户名
private static String psw = null; // psw 主机登陆密码
private static String servicePath = null; // 服务存储文件路径
private static Properties prop = null;

private static Session session = null;
private static Channel channel = null;

// 读取配置文件的参数
static {
prop = new Properties();
ClassLoader cl = SftpUtil.class.getClassLoader();
InputStream is = cl
.getResourceAsStream("Test/Sftp_UpDownload.properties");
try {
prop.load(is);
} catch (IOException e) {
// System.out.println("读取配置文件出错！");
e.printStackTrace();
}
ip = prop.getProperty("ip");
port = Integer.parseInt(prop.getProperty("port"));
user = prop.getProperty("user");
psw = prop.getProperty("psw");
servicePath = prop.getProperty("servicePath");

}

/**
* 获取 sftp通信
*
* @return 获取到的ChannelSftp
* @throws Exception
*/

public static ChannelSftp getSftp() throws Exception {

ChannelSftp sftp = null;
JSch jsch = new JSch();
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(30000);
try {
// 创建sftp通信通道
channel = (Channel) session.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
// 进入服务器指定的文件夹
sftp.cd(servicePath);

} catch (Exception e) {
e.printStackTrace();
}
return sftp;
}

/**
* 关闭连接
*/
public static void closeSftp() {
if (channel != null) {
if (channel.isConnected())
channel.disconnect();
}
if (session != null) {
if (session.isConnected())
session.disconnect();
}
}
}

2.上传下载工具类

package Test;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;

import org.junit.Test;

import com.jcraft.jsch.ChannelSftp;

public class SftpUploadOrDownload {

/*
* @author lixiongjun
*
* 实现sftp文件上传下载的工具类
* 2015-1-27 下午15:13:26
*/

/**
* 上传本地文件到服务器
* @param srcPath 本地文件路径
* @param dstFilename 目标文件名
* @return 是否上传成功
*/
public boolean upload(String srcPath,String dstFilename){
ChannelSftp sftp=null;
try {
sftp =SftpUtil.getSftp();
sftp.put(srcPath,dstFilename);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
finally{
SftpUtil.closeSftp();
}
}

/**
* 上传本地文件到服务器
* @param in 输入流
* @param dstFilename 目标文件名
* @return 是否上传成功
*/
public boolean uploadBystrem(InputStream in,String dstFilename){
ChannelSftp sftp=null;
try {
sftp =SftpUtil.getSftp();
sftp.put(in,dstFilename);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
finally{
SftpUtil.closeSftp();
}
}

/**
* 把服务器文件下载到本地
* @param desPath 下载到本地的目标路径
* @param srcFilename 源文件名
* @return 是否下载成功
*/
public boolean download(String srcFilename,String dstPath){
ChannelSftp sftp=null;
try {
sftp =SftpUtil.getSftp();
sftp.get(srcFilename,dstPath);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
finally{
SftpUtil.closeSftp();
}
}

/**
* 获取服务器文件的内容，只对文本文件有效
* @param srcFilename 服务器所在源文件名
* @return 文件内容
*/
public String getServiceFileContext(String srcFilename){
ChannelSftp sftp=null;
InputStream in=null;
BufferedReader br=null;
String filecontext="";
try {
sftp =SftpUtil.getSftp();
in=sftp.get(srcFilename);
br=new BufferedReader(new InputStreamReader(in));
String str=br.readLine();
while(str!=null){
filecontext+=str+"\n";
str=br.readLine();
}

} catch (Exception e) {
e.printStackTrace();
}
finally{
try {
br.close();
in.close();
} catch (IOException e) {
e.printStackTrace();
}
SftpUtil.closeSftp();
}
return filecontext;
}

/**
* 删除服务器上文件
* @param filename 要删除的文件名
* @return 是否删除成功
*/
public boolean remove(String filename){
ChannelSftp sftp=null;
try {
sftp =SftpUtil.getSftp();
sftp.rm(filename);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
finally{
SftpUtil.closeSftp();
}
}

@Test
public void TestSftpUpload(){
if(upload("E:/test.txt","test.txt")){
System.out.println("上传文件成功");
}
else{
System.out.println("上传文件失败");
}
}

@Test
public void TestSftpDownload(){
if(download("test.txt","E:/downtest.txt")){
System.out.println("下载文件成功");
}
else{
System.out.println("下载文件失败");
}
}

@Test
public void TestSftpgetServiceFileContext(){

String context=getServiceFileContext("test.txt");
System.out.println(context);

}

@Test
public void TestSftpRemove(){
if(remove("test.txt")){
System.out.println("删除文件成功");
}
else{
System.out.println("删除文件失败");
}
}