java实现与远程 SFTP 服务器之间安全文件传输

2024-06-21 10:44
文章标签 java 实现 安全 远程 文件传输 sftp 服务器之间

本文主要是介绍java实现与远程 SFTP 服务器之间安全文件传输，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

    • 概要
    • FTP SFTP区别
    • 封装一个工具类

概要

SFTP（Secure File Transfer Protocol）是一种基于SSH（Secure Shell）协议的安全文件传输协议，它提供了在安全信道上进行数据传输的能力。相比传统的FTP（File Transfer Protocol），SFTP具有更高的安全性和更多的功能。

FTP SFTP区别

FTP和SFTP之间的一些主要区别：

特征FTPSFTP
协议基于传统的FTP协议（File Transfer Protocol）基于SSH的安全文件传输协议（Secure File Transfer Protocol）
安全性不安全，数据传输未加密安全，所有数据均经过SSH加密传输
端口默认端口为21默认端口为22
认证可以使用用户名和密码进行简单认证通过SSH密钥或用户名密码进行认证
加密不支持加密所有数据传输都通过SSH加密保护
目录访问控制依赖FTP服务器的权限和文件系统权限依赖SSH服务器的权限和文件系统权限
使用场景用于需要简单文件传输，无需考虑安全性的场景用于需要安全文件传输和操作的场景
适用性适用于内部网络和不涉及敏感信息的场景适用于需要加密和安全性要求较高的场景

封装一个工具类


import com.jcraft.jsch.*;import java.io.*;
import java.util.Properties;
import java.util.Vector;public class SftpUtil {public static final String NO_FILE = "No such file";public enum UploadStatus {Create_Directory_Fail,Create_Directory_Success,Upload_New_File_Success,Upload_New_File_Failed,File_Exits,Remote_Bigger_Local,Upload_From_Break_Success,Upload_From_Break_Failed,Delete_Remote_Faild;}private ChannelSftp sftp = null;private Session sshSession = null;private String username;private String password;private String host;private int port;public SftpUtil(String host, int port, String username, String password) {this.username = username;this.password = password;this.host = host;this.port = port;}/*** 连接到sftp服务器*/public ChannelSftp connect() throws Exception {JSch jsch = new JSch();try {jsch.getSession(username, host, port);sshSession = jsch.getSession(username, host, port);sshSession.setPassword(password);Properties properties = new Properties();properties.put("StrictHostKeyChecking", "no");sshSession.setConfig(properties);sshSession.connect();Channel channel = sshSession.openChannel("sftp");channel.connect();sftp = (ChannelSftp)channel;} catch (JSchException e) {throw new Exception("FtpUtil-->connect异常" + e.getMessage());}return sftp;}/*** 关闭连接*/public void disconnect() {if (this.sftp != null) {if (this.sftp.isConnected()) {this.sftp.disconnect();this.sftp = null;}}if (this.sshSession != null) {if (this.sshSession.isConnected()) {this.sshSession.disconnect();this.sshSession = null;}}}/*** 上传文件* 用于将本地文件上传到指定的远程目录，并且使用给定的文件名。适用于将现有的本地文件上传到SFTP服务器的情况。** @param directory         远程上传目录* @param uploadFilePath    本地文件路径* @param fileName          远程文件名* @throws Exception        可能抛出的异常*/public void uploadFile(String directory, String uploadFilePath, String fileName) throws Exception {FileInputStream in = null;connect();try {sftp.cd(directory);} catch (SftpException e) {try {sftp.mkdir(directory);sftp.cd(directory);} catch (SftpException e1) {throw new Exception("ftp创建文件路径失败，路径为" + directory);}}File file = new File(uploadFilePath);try {in = new FileInputStream(file);sftp.put(in, fileName);} catch (FileNotFoundException e) {throw new Exception("文件不存在-->" + uploadFilePath);} catch (SftpException e) {throw new Exception("sftp异常-->" + e.getMessage());} finally {if (in != null) {try {in.close();} catch (IOException e) {throw new Exception("Close stream error." + e.getMessage());}}disconnect();}}/*** 上传文件* 将文件从一个输入流上传到指定的远程路径和文件名。适用于需要从内存中的输入流直接上传文件的情况。** @param filePath  远程文件路径* @param filename  文件名* @param in        输入流* @return          上传状态*/public UploadStatus uploadFile(String filePath, String filename, InputStream in) {try {sftp.put(in, filePath + filename, ChannelSftp.OVERWRITE);} catch (SftpException e) {e.printStackTrace();}return UploadStatus.Upload_From_Break_Success;}/*** 获取文件列表** @param filePath  远程文件路径* @return          文件列表*/public Vector<LsEntry> getFileList(String filePath) {Vector<LsEntry> list = new Vector<>();try {Vector veItem = sftp.ls(filePath);for (Object obj : veItem) {if (obj instanceof LsEntry) {list.add((LsEntry)obj);}}} catch (SftpException e) {e.printStackTrace();}return list;}/*** 下载文件** @param directory         远程下载目录* @param remoteFileName    远程文件名* @param localFile         本地文件路径* @return                  下载的文件对象* @throws Exception        可能抛出的异常*/public File downloadFile(String directory, String remoteFileName, String localFile) throws Exception {connect();File file = null;OutputStream output = null;try {file = new File(localFile);if (file.exists()) {file.delete();}file.createNewFile();sftp.cd(directory);output = new FileOutputStream(file);sftp.get(remoteFileName, output);} catch (SftpException e) {if (e.toString().equals(NO_FILE)) {throw new Exception("FtpUtil-->downloadFile--ftp下载文件失败" + directory + remoteFileName + "不存在");}throw new Exception("ftp目录或者文件异常，检查ftp目录和文件" + e.toString());} catch (FileNotFoundException e) {throw new Exception("本地目录异常，请检查" + file.getPath() + e.getMessage());} catch (IOException e) {throw new Exception("创建本地文件失败" + file.getPath() + e.getMessage());} finally {if (output != null) {try {output.close();} catch (IOException e) {throw new Exception("Close stream error." + e.getMessage());}}disconnect();}return file;}}

解释代码：

connect()函数：

  1. 创建 JSch 对象。
  2. 通过 getSession 方法获取会话，并设置用户名、主机、端口和密码。
  3. 创建属性对象，并将 StrictHostKeyChecking 设置为 no ，然后应用到会话配置中。
  4. 连接会话。
  5. 打开 sftp 通道并进行连接。
  6. 将通道强转为 ChannelSftp 类型并赋值给 sftp 。
  7. 最后返回 sftp 对象。

disconnect()函数：

  1. 检查 sftp 对象是否不为空且已连接，如果是，则断开连接并将其置为 null 。
  2. 检查 sshSession 对象是否不为空且已连接，如果是，则断开连接并将其置为 null 。

public void uploadFile(String directory, String uploadFilePath, String fileName) throws Exception {}方法：

  1. 调用 connect 方法建立连接。
  2. 尝试切换到指定的目录，如果目录不存在则创建目录后再切换。
  3. 读取要上传的文件，并通过 sftp.put 方法将文件上传。
  4. 处理可能出现的文件未找到、SFTP 异常等情况。
  5. 在 finally 块中，若文件输入流不为空则关闭，并调用 disconnect 方法断开连接。

downloadFile函数：

  1. 调用 connect 方法建立连接。
  2. 创建本地文件，如果文件已存在则先删除再创建新文件。
  3. 切换到指定目录。
  4. 创建文件输出流。
  5. 通过 sftp.get 方法从远程获取文件并写入本地输出流。
  6. 处理可能出现的 SFTP 异常、文件未找到异常、本地目录异常、创建本地文件异常等情况。
  7. 在 finally 块中，若输出流不为空则关闭，并调用 disconnect 方法断开连接。
  8. 最后返回下载的本地文件。

❤觉得有用的可以留个关注~❤

这篇关于java实现与远程 SFTP 服务器之间安全文件传输的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1081006。

相关文章

Java中流式并行操作parallelStream的原理和使用方法

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流（parallelStream）的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS
阅读更多...
C++中unordered_set哈希集合的实现

C++中unordered_set哈希集合的实现

《C++中unordered_set哈希集合的实现》std::unordered_set是C++标准库中的无序关联容器,基于哈希表实现,具有元素唯一性和无序性特点,本文就来详细的介绍一下unorder... 目录一、概述二、头文件与命名空间三、常用方法与示例1. 构造与析构2. 迭代器与遍历3. 容量相关4
阅读更多...
Java中Redisson 的原理深度解析

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、
阅读更多...
C++中悬垂引用(Dangling Reference) 的实现

C++中悬垂引用(Dangling Reference) 的实现

《C++中悬垂引用(DanglingReference)的实现》C++中的悬垂引用指引用绑定的对象被销毁后引用仍存在的情况,会导致访问无效内存,下面就来详细的介绍一下产生的原因以及如何避免,感兴趣... 目录悬垂引用的产生原因1. 引用绑定到局部变量，变量超出作用域后销毁2. 引用绑定到动态分配的对象，对象
阅读更多...
SpringBoot基于注解实现数据库字段回填的完整方案

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代
阅读更多...
一篇文章彻底搞懂macOS如何决定java环境

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面：本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一：使用 which命令方法二：使用 Java_home工具（Apple 官方推荐）那问题来了，
阅读更多...
Java HashMap的底层实现原理深度解析

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述：HashMap的宏观结构二、核心数据结构解析1. 数组（桶数组）2. 链表节点（Node
阅读更多...
Java AOP面向切面编程的概念和实现方式

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点（如日志、事务）与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么？二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关
阅读更多...
详解SpringBoot+Ehcache使用示例

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储：配置灵活性：编码示例引入依赖：配置ehcache.XML文件：配置
阅读更多...
Java 虚拟线程的创建与使用深度解析

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程？1.2 为什么需要虚拟线程？二、虚拟线程与平台线程对比代码对比示例：三
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2