我要评论sftp（secure file transfer protocol）是一种安全的文件传输协议，是ssh（secure shell）协议的一个子协议，设计用于加密和保护文件传输的安全性。ssh本身是一种网络协议，用于在不安全的网络中提供安全的远程登录和其他安全网络服务。sftp则在此基础上，专注于文件的安全传输。
- 加密传输：sftp使用加密来保护传输的数据，包括文件内容和认证信息。
- 身份验证：sftp使用ssh身份验证机制来验证用户身份。用户通常需要提供用户名和密码，或者使用ssh密钥对进行身份验证。
- 文件和目录操作：sftp支持文件和目录的上传、下载、删除、重命名和创建等操作。
- 跨平台兼容性：sftp是一个跨平台协议，可以在各种操作系统上使用，包括linux、unix、windows等。
- 端到端数据完整性：sftp确保传输的文件在源和目标之间的完整性，防止数据在传输过程中被篡改或损坏。
- 可扩展性：sftp可以与其他协议和安全机制一起使用，以增强其功能。例如，它可以与公钥基础设施（pki）一起使用以实现更高级的安全性。
sftp通常用于许多场景，包括远程服务器维护、备份、文件共享和在不同计算机之间传输敏感数据。由于它提供了强大的安全性，因此特别适用于传输金融账户、公司文件和政府数据等敏感信息。
- 端口：sftp的默认端口与ssh相同，为22。这意味着只要sshd服务器启动了，sftp就可使用，不需要额外安装。
- 守护进程：sftp本身没有单独的守护进程，它必须使用sshd守护进程（端口号默认是22）来完成相应的连接操作。
- 配置：sftp的配置通常与ssh配置相关。例如，可以通过修改ssh配置文件（如sshd_config）来启用或禁用sftp功能，以及设置相关的访问权限和安全策略。
sftp结合了ssh的安全性和文件传输的便捷性，成为许多组织和个人在传输敏感数据时的首选协议。
一、常见注意事项
1、如果客户端不支持 ssh-rsa 协议时，需要在登陆的时候添加属性：
config.put("hostkeyalgorithms", "+ssh-rsa");…持续更新
二、添加第三方 pom 依赖
java本身并不支持连接 sftp，所以需要第三方依赖进行连接。
<dependency> <groupid>com.jcraft</groupid> <artifactid>jsch</artifactid> <version>0.1.55</version> </dependency>
三、sftputil 代码
注意：如果客户端不支持 ssh-rsa 协议时，需要添加属性
package com.wen.util;
import com.jcraft.jsch.*;
import org.slf4j.logger;
import org.slf4j.loggerfactory;
import java.io.*;
import java.util.date;
import java.util.properties;
import java.util.vector;
/**
* @author : rjw
* @date : 2024-10-14
*/
public class sftputil {
private static final logger logger = loggerfactory.getlogger(sftputil.class);
private session session;
private channelsftp channelsftp;
/**
* 登录
*/
public boolean login(string hostname, int port, string username, string password) {
try {
jsch jsch = new jsch();
// 根据用户名，ip地址获取一个session对象。
session = jsch.getsession(username, hostname, port);
session.setpassword(password);
// 避免第一次连接时需要输入yes确认
properties config = new properties();
config.put("stricthostkeychecking", "no");
session.setconfig(config);
session.connect();
logger.info("成功连接服务器");
channelsftp = (channelsftp) session.openchannel("sftp");
channelsftp.connect();
logger.info("成功连接服务器");
return true;
} catch (jschexception e) {
logger.error("sftputil login file error:", e);
}
return false;
}
/**
* 退出
*/
public void logout() {
if (channelsftp != null && channelsftp.isconnected()) {
try {
channelsftp.disconnect();
logger.info("成功退出 sftp 服务器");
} catch (exception e) {
logger.error("退出sftp服务器异常: ", e);
} finally {
try {
channelsftp.disconnect(); // 关闭ftp服务器的连接
} catch (exception e) {
logger.error("关闭sftp服务器的连接异常: ", e);
}
}
}
if (session != null && session.isconnected()) {
try {
session.disconnect();
logger.info("成功退出 session 会话");
} catch (exception e) {
logger.error("退出 session 会话异常: ", e);
} finally {
try {
session.disconnect(); // 关闭ftp服务器的连接
} catch (exception e) {
logger.error("关闭 session 会话的连接异常: ", e);
}
}
}
}
/**
* 判断是否连接
*/
public boolean isconnected() {
return channelsftp != null && channelsftp.isconnected();
}
/**
* 上传文件
* 采用默认的传输模式：overwrite
*
* @param src 输入流（文件）
* @param dst 上传路径
* @param filename 上传文件名
* @throws sftpexception
*/
public boolean uploadfile(inputstream src, string dst, string filename) throws sftpexception {
boolean issuccess = false;
try {
if (createdir(dst)) {
channelsftp.put(src, filename);
issuccess = true;
}
} catch (sftpexception e) {
logger.error(filename + "文件上传异常", e);
}
return issuccess;
}
/**
* 创建一个文件目录
*
* @param createpath 路径
* @return
*/
public boolean createdir(string createpath) {
boolean issuccess = false;
try {
if (isdirexist(createpath)) {
channelsftp.cd(createpath);
return true;
}
string[] patharray = createpath.split("/");
stringbuilder filepath = new stringbuilder("/");
for (string path : patharray) {
if (path.isempty()) {
continue;
}
filepath.append(path).append("/");
if (isdirexist(filepath.tostring())) {
channelsftp.cd(filepath.tostring());
} else {
// 建立目录
channelsftp.mkdir(filepath.tostring());
// 进入并设置为当前目录
channelsftp.cd(filepath.tostring());
}
}
channelsftp.cd(createpath);
issuccess = true;
} catch (sftpexception e) {
logger.error("目录创建异常！", e);
}
return issuccess;
}
/**
* 判断目录是否存在
*
* @param directory 路径
* @return
*/
public boolean isdirexist(string directory) {
boolean issuccess = false;
try {
sftpattrs sftpattrs = channelsftp.lstat(directory);
issuccess = true;
return sftpattrs.isdir();
} catch (exception e) {
logger.info("sftputil path has error:{}", directory);
logger.error("sftputil path has error: ", e);
if (e.getmessage().equalsignorecase("no such file")) {
issuccess = false;
}
}
return issuccess;
}
/**
* 重命名指定文件或目录
*/
public boolean rename(string oldpath, string newpath) {
boolean issuccess = false;
try {
channelsftp.rename(oldpath, newpath);
issuccess = true;
} catch (sftpexception e) {
logger.error("重命名指定文件或目录异常", e);
}
return issuccess;
}
/**
* 列出指定目录下的所有文件和子目录。
*/
public vector ls(string path) {
try {
vector vector = channelsftp.ls(path);
return vector;
} catch (sftpexception e) {
logger.error("列出指定目录下的所有文件和子目录。", e);
}
return null;
}
/**
* 删除文件
*/
public boolean deletefile(string directory, string deletefile) {
boolean issuccess = false;
try {
channelsftp.cd(directory);
channelsftp.rm(deletefile);
issuccess = true;
} catch (sftpexception e) {
logger.error("删除文件失败", e);
}
return issuccess;
}
/**
* 下载文件
*
* @param directory 下载目录
* @param downloadfile 下载的文件
* @param savefile 下载到本地路径
*/
public boolean download(string directory, string downloadfile, string savefile) {
boolean issuccess = false;
try {
channelsftp.cd(directory);
file file = new file(savefile);
channelsftp.get(downloadfile, new fileoutputstream(file));
issuccess = true;
} catch (sftpexception e) {
logger.error("下载文件失败", e);
} catch (filenotfoundexception e) {
logger.error("下载文件失败", e);
}
return issuccess;
}
/**
* 输出指定文件流
*/
public inputstream getfile(string path) {
try {
inputstream inputstream = channelsftp.get(path);
return inputstream;
} catch (sftpexception e) {
throw new runtimeexception(e);
}
}
/**
* 下载文件，新
*/
public inputstream downloadfile(string remotefilename, string remotefilepath) {
inputstream input = null;
try {
if (!isdirexist(remotefilepath)) {
logger.info("sftputil not changeworkingdirectory.filename:{},path:{}", remotefilename, remotefilepath);
logout();
return input;
}
logger.info("sftputil info filename:{},path:{}", remotefilename, remotefilepath);
bytearrayoutputstream outputstream = new bytearrayoutputstream();
channelsftp.get(remotefilename, outputstream);
input = new bytearrayinputstream(outputstream.tobytearray());
outputstream.close();
logger.info("file download. filename:{},path:{}", remotefilename, remotefilepath);
} catch (exception e) {
logger.error("sftputil download file error:", e);
logout();
}
return input;
}
/**
* 验证sftp文件是否有效(判断文件属性的日期)
*/
public string validatesourcedata(string filename, string remotefilepath, date nowtime) throws ioexception, sftpexception {
date temp = null;
if (!isdirexist(remotefilepath)) {
logout();
return "尝试切换sftp路径失败, 文件路径: " + remotefilepath + filename;
}
vector vector = channelsftp.ls(remotefilepath);
for (int i = 0; i < vector.capacity(); i++) {
channelsftp.lsentry data = (channelsftp.lsentry) vector.get(i);
if (data.getfilename().equalsignorecase(filename)) {
temp = new date(data.getattrs().getmtime() * 1000l);
//logger.info("时间: timestamp:{},nowtime:{}",temp,nowtime);
if (temp.gettime() == nowtime.gettime()) {
return "sftp文件没有更新";
}
nowtime.settime(temp.gettime());
break;
}
}
//logout();
return null;
}
/**
* ip
*/
public string getsftphost() {
return session.gethost();
}
/**
* 端口
*/
public int getsftpport() {
return session.getport();
}
}四、测试示例
public class test {
private static sftputil sftputil = new sftputil();
public static string convertinputstreamtostring(inputstream inputstream) throws ioexception{
stringbuilder stringbuilder = new stringbuilder();
try{
bufferedreader bufferedreader = new bufferedreader(new inputstreamreader(inputstream, "utf-8"));
string line;
while ((line = bufferedreader.readline()) != null){
system.out.println(line);
stringbuilder.append(line).append("\n");
}
}catch (exception e){
system.out.println(e);
}
if(stringbuilder.length() > 0 && stringbuilder.charat(stringbuilder.length() - 1) == '\n'){
stringbuilder.setlength(stringbuilder.length() - 1);
}
return stringbuilder.tostring();
}
public static void main(string[] args) {
boolean connected = sftputil.isconnected();
if (!connected) {
system.out.println("连接sftp");
// 折里可以采用配置文件 @value 注解
connected = sftputil.login("10.26.73.163", 2222, "username", "password");
}
if (connected) {
system.out.println("连接成功");
system.out.println(sftputil.getsftphost() + " : " + sftputil.getsftpport());
inputstream inputstream = sftputil.getfile("/rjw/wind.txt");
string s = convertinputstreamtostring(inputstream);
system.out.println(s);
file file = new file("c:\\users\\wen\\desktop\\sun.txt");
inputstream inputstream1 = files.newinputstream(file.topath());
boolean dir = sftputil.uploadfile(inputstream1, "/rjw", "big.txt");
system.out.println("添加文件成功： " + dir);
sftputil.logout();
}
}
}五、测试结果
到此这篇关于java 项目如何连接并使用 sftp 服务的示例详解的文章就介绍到这了,更多相关java使用 sftp 服务内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论