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。

相关文章

一文详解如何在idea中快速搭建一个Spring Boot项目

一文详解如何在idea中快速搭建一个Spring Boot项目

《一文详解如何在idea中快速搭建一个SpringBoot项目》IntelliJIDEA作为Java开发者的‌首选IDE‌,深度集成SpringBoot支持,可一键生成项目骨架、智能配置依赖,这篇文... 目录前言1、创建项目名称2、勾选需要的依赖3、在setting中检查maven4、编写数据源5、开启热
阅读更多...
C++中零拷贝的多种实现方式

C++中零拷贝的多种实现方式

《C++中零拷贝的多种实现方式》本文主要介绍了C++中零拷贝的实现示例,旨在在减少数据在内存中的不必要复制,从而提高程序性能、降低内存使用并减少CPU消耗,零拷贝技术通过多种方式实现,下面就来了解一下... 目录一、C++中零拷贝技术的核心概念二、std::string_view 简介三、std::stri
阅读更多...
C++高效内存池实现减少动态分配开销的解决方案

C++高效内存池实现减少动态分配开销的解决方案

《C++高效内存池实现减少动态分配开销的解决方案》C++动态内存分配存在系统调用开销、碎片化和锁竞争等性能问题,内存池通过预分配、分块管理和缓存复用解决这些问题,下面就来了解一下... 目录一、C++内存分配的性能挑战二、内存池技术的核心原理三、主流内存池实现：TCMalloc与Jemalloc1. TCM
阅读更多...
OpenCV实现实时颜色检测的示例

OpenCV实现实时颜色检测的示例

《OpenCV实现实时颜色检测的示例》本文主要介绍了OpenCV实现实时颜色检测的示例,通过HSV色彩空间转换和色调范围判断实现红黄绿蓝颜色检测,包含视频捕捉、区域标记、颜色分析等功能,具有一定的参考... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间
阅读更多...
Java对异常的认识与异常的处理小结

Java对异常的认识与异常的处理小结

《Java对异常的认识与异常的处理小结》Java程序在运行时可能出现的错误或非正常情况称为异常,下面给大家介绍Java对异常的认识与异常的处理,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参... 目录一、认识异常与异常类型。二、异常的处理三、总结 一、认识异常与异常类型。（1）简单定义-什么是
阅读更多...
SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志

SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志

《SpringBoot项目配置logback-spring.xml屏蔽特定路径的日志》在SpringBoot项目中,使用logback-spring.xml配置屏蔽特定路径的日志有两种常用方式,文中的... 目录方案一：基础配置（直接关闭目标路径日志）方案二：结合 Spring Profile 按环境屏蔽关
阅读更多...
Python实现精准提取 PDF中的文本,表格与图片

Python实现精准提取 PDF中的文本,表格与图片

《Python实现精准提取PDF中的文本,表格与图片》在实际的系统开发中,处理PDF文件不仅限于读取整页文本,还有提取文档中的表格数据,图片或特定区域的内容,下面我们来看看如何使用Python实... 目录安装 python 库提取 PDF 文本内容：获取整页文本与指定区域内容获取页面上的所有文本内容获取
阅读更多...
基于Python实现一个Windows Tree命令工具

基于Python实现一个Windows Tree命令工具

《基于Python实现一个WindowsTree命令工具》今天想要在Windows平台的CMD命令终端窗口中使用像Linux下的tree命令,打印一下目录结构层级树,然而还真有tree命令,但是发现... 目录引言实现代码使用说明可用选项示例用法功能特点添加到环境变量方法一：创建批处理文件并添加到PATH1
阅读更多...
Java使用HttpClient实现图片下载与本地保存功能

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.
阅读更多...
canal实现mysql数据同步的详细过程

canal实现mysql数据同步的详细过程

《canal实现mysql数据同步的详细过程》：本文主要介绍canal实现mysql数据同步的详细过程,本文通过实例图文相结合给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的... 目录1、canal下载2、mysql同步用户创建和授权3、canal admin安装和启动4、canal
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2