sftp的⽤法：ChannelSftp类
SFTP简介
SFTP是Secure File Transfer Protocol的缩写，安全⽂件传送协议。可以为传输⽂件提供⼀种安全的加密⽅法。SFTP 为 SSH的⼀部份，是⼀种传输⽂件到服务器的安全⽅式。SFTP是使⽤加密传输认证信息和传输的数据，所以，使⽤SFTP是⾮常安全的。但是，由于这种传输⽅式使⽤了加密/解密技术，所以传输效率⽐普通的FTP要低得多，如果您对⽹络安全性要求更⾼时，可以使⽤SFTP代替FTP。
ChannelSftpAPI
ChannelSftp类是JSch实现SFTP核⼼类，它包含了所有SFTP的⽅法.
githubAPI地址 :
sftp代码
pom依赖
<!-- sftp的依赖-->
<dependency>
<groupId>com.jcraft</groupId>
<artifactId>jsch</artifactId>
<version>0.1.55</version>
</dependency>
<dependency>
<groupId>org.apachemons</groupId>
<artifactId>commons-io</artifactId>
<version>1.3.2</version>
</dependency>
<!-- log⽇志依赖 -->
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
<version>2.11.2</version>
</dependency>
jar包百度⾃⾏下载
Java代码
import com.jcraft.jsch.*;
import org.apachemons.io.IOUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.io.*;
import java.util.Vector;
/**
* FTP服务器⼯具类：
* JSch类通过 SFTP 协议上传⽂件到 freeSSHd 服务器
*
* @author yindong
* @time 2019-05-28
* @vision 1.0.0
*/
public class SftpUtil {
private Logger logger = Logger(SftpUtil.class);
private ChannelSftp sftp;
private Session session;
/**
* ⽤户名
*/
private String username;
/**
* 密码
*/
private String password;
/
**
* 秘钥
*/
private String privateKey;
/**
* FTP服务器Ip
*/
private String host;
/**
* FTP服务器端⼝号
*/
private int port;
/**
* 构造器：基于密码认证sftp对象
* @param username ⽤户名
* @param password 密码
* @param host 服务器ip
* @param port 服务器端⼝号
*/
public SftpUtil(String username, String password, String host, int port){ this.username = username;
this.password = password;
this.host = host;
this.port = port;
}
/**
* 构造器：基于秘钥认证sftp对象
* @param username ⽤户名
* @param privateKey 秘钥
* @param host 服务器ip
* @param port 服务器端⼝号
*/
public SftpUtil(String username, String privateKey, int port, String host){ this.username = username;
this.privateKey = privateKey;
this.host = host;
this.port = port;
}
/**
* 连接SFTP服务器
*/
public void login(){
JSch jsch = new JSch();
try{
if(privateKey != null){
//设置登陆主机的秘钥
jsch.addIdentity(privateKey);
}
}
//采⽤指定的端⼝连接服务器
session = Session(username,host,port);
if(password != null){
//设置登陆主机的密码
session.setPassword(password);
}
//优先使⽤ password 验证注：t()性能低，使⽤password验证可跳过gssapi认证，提升连接服务器速度 session.setConfig("PreferredAuthentications","password");
//设置第⼀次登陆的时候提⽰，可选值：(ask | yes | no)exists的用法
session.setConfig("StrictHostKeyChecking","no");
//创建sftp通信通道
Channel channel = session.openChannel("sftp");
sftp = (ChannelSftp) channel;
logger.info("sftp server connect success !!");
}catch (JSchException e){
<("SFTP服务器连接异常！！", e);
}
}
/
**
* 关闭SFTP连接
*/
public void logout(){
if(sftp != null){
if(sftp.isConnected()){
sftp.disconnect();
logger.info("sftp is close already");
}
}
if(session != null){
if(session.isConnected()){
session.disconnect();
logger.info("session is close already");
}
}
}
/**
* 将输⼊流上传到SFTP服务器，作为⽂件
*
* @param directory 上传到SFTP服务器的路径
* @param sftpFileName 上传到SFTP服务器后的⽂件名
* @param input 输⼊流
* @throws SftpException
*/
public void upload(String directory, String sftpFileName, InputStream input) throws SftpException{
long start = System.currentTimeMillis();
try{
//如果⽂件夹不存在，则创建⽂件夹
if(sftp.ls(directory) == null){
sftp.mkdir(directory);
}
//切换到指定⽂件夹
sftp.cd(directory);
}catch (SftpException e){
//创建不存在的⽂件夹，并切换到⽂件夹
sftp.mkdir(directory);
sftp.cd(directory);
}
sftp.put(input, sftpFileName);
logger.info("⽂件上传成功！！耗时：{}ms",(System.currentTimeMillis() - start));
}
/**
* 上传单个⽂件
*
* @param directory 上传到SFTP服务器的路径
* @param uploadFileUrl ⽂件路径
*/
public void upload(String directory, String uploadFileUrl){
File file = new File(uploadFileUrl);
try{
upload(directory, Name(), new FileInputStream(file));
}catch (FileNotFoundException | SftpException e){
<("上传⽂件异常！", e);
}
}
/**
* 将byte[] 上传到SFTP服务器，作为⽂件
* 注：从String转换成byte[] 需要指定字符集
*
* @param directory 上传到SFTP服务器的路径
* @param sftpFileName 上传SFTP服务器后的⽂件名
* @param bytes 字节数组
*/
public void upload(String directory, String sftpFileName, byte[] bytes){
try{
upload(directory, sftpFileName, new ByteArrayInputStream(bytes));
}catch (SftpException e){
<("上传⽂件异常！", e);
}
}
/**
* 将字符串按照指定编码格式上传到SFTP服务器
*
* @param directory 上传到SFTP服务器的路径
* @param sftpFileName 上传SFTP服务器后的⽂件名
* @param dataStr 字符串
* @param charsetName 字符串的编码格式
*/
public void upload(String directory, String sftpFileName, String dataStr, String charsetName){
try{
upload(directory, sftpFileName, new Bytes(charsetName))); }catch (UnsupportedEncodingException | SftpException e){
<("上传⽂件异常！", e);
}
}
/**
* 下载⽂件
*
* @param directory SFTP服务器的⽂件路径
* @param downloadFile SFTP服务器上的⽂件名
* @param saveFile 保存到本地路径
*/
public void download(String directory, String downloadFile, String saveFile){
try{
if(directory != null && !"".equals(directory)){
sftp.cd(directory);
}
File file = new File(saveFile);
<(downloadFile, new FileOutputStream(file));
}catch (SftpException | FileNotFoundException e){
<("⽂件下载异常！", e);
}
}
}
/**
* 下载⽂件
*
* @param directory SFTP服务器的⽂件路径
* @param downloadFile SFTP服务器上的⽂件名
* @return 字节数组
*/
public byte[] download(String directory, String downloadFile){
try{
if(directory != null && !"".equals(directory)){
sftp.cd(directory);
}
InputStream inputStream = (downloadFile);
ByteArray(inputStream);
}catch (SftpException | IOException e){
<("⽂件下载异常！", e);
}
return null;
}
/**
* 下载⽂件
*
* @param directory SFTP服务器的⽂件路径
* @param downloadFile SFTP服务器上的⽂件名
* @return 输⼊流
*/
public InputStream downloadStream(String directory, String downloadFile){ try{
if(directory != null && !"".equals(directory)){
sftp.cd(directory);
}
(downloadFile);
}catch (SftpException e){
<("⽂件下载异常！", e);
}
return null;
}
/**
* 删除⽂件
*
* @param directory SFTP服务器的⽂件路径
* @param deleteFileName 删除的⽂件名称
*/
public void delete(String directory, String deleteFileName){
try{
sftp.cd(directory);
<(deleteFileName);
}catch (SftpException e){
<("⽂件删除异常！", e);
}
}
/
**
* 删除⽂件夹
*
* @param directory SFTP服务器的⽂件路径
*/
public void delete(String directory){
Vector vector = listFiles(directory);
for(Object v : vector){
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论