服务器间进行文件传输-SFTPSCP一篇搞定

2024-09-01 23:12

本文主要是介绍服务器间进行文件传输-SFTPSCP一篇搞定,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.简单介绍一下

在一些特殊场景,两台服务器之间需要进行文件传输的时候,或许我们会想到FTP,这也是我们常见的实现方式,但是如果我们不能操作远程服务器,无法判断远程服务器是否安装了FTP呢,众所周知,FTP使用的前提时确定服务器上配置了FTP服务,并且正在运行FTP服务器软件,这是最大的前提,如果我们不知道,那么就不能贸然的使用该方式。

我的需求是:我只知道对方服务器的ip、端口、用户名、密码,文件地址。其他的我一概不知。

那么还有什么方式呢,SFTP?SCP?

SFTP和FTP不就少了一个S,应该也需要安装FTP吧?答案是:NO

SFTP:是一种基于SSH协议的网络协议,用于在网络上安全的传输协议,SFTP提供了一个安全的文件传输机制,允许用户在传输过程中加密数据,从而保护数据免受窃听和篡改。

注意:OpenSSH支持SFTP,也就是说只要服务器中有OpenSSH,SFTP就可以使用。

FTP:是一种用于在网络上进行文件传输的协议。它是基于文本的协议,允许用户上传、下载、删除和重命名文件。

注意:需要安装配置FTP服务到服务器。

SCP:是一种用于在服务器之间安全复制文件的网络协议。基于SSH协议,提供了一个加密的方法来传输文件,确保数据在传输过程中的安全性。SCP是一个命令行工具,通常用于远程服务器管理、文件备份和系统维护。

注意:我认为只要服务器可以执行linux命令,应该都可以实现。

2.实现方式

我的实现方式是基于Spring Boot创建完成的哈,大家如果出现了什么问题,得放到评论区,得重新看看具体是什么原因。

2.1 FTP方式

这个大家就参考网上详细的文章哈,主要我的需求不能使用这个方式😄,所以没有代码😜。

2.2 SFTP方式

第一个肯定就是导入依赖

<dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.53</version>
</dependency>        

然后,咱们就得写一个工具类了

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
import java.io.File;public class ScpFileTransferUtil {// 远程服务器的IP地址private static final String IP = "192.xxx.xxx.xx";// 远程服务器的SSH端口private static final int PORT = xxxx;// 远程服务器的用户名private static final String USER_NAME = "root";// 远程服务器的密码private static final String PASSWORD = "xxxxxx";/*** 从远程服务器下载文件到本地** @param remotePath 远程文件路径* @param localPath  本地目标目录*/public static void scpFromRemote(String remotePath, String localPath) {try {JSch jsch = new JSch();Session session = jsch.getSession(USER_NAME, IP, PORT);session.setPassword(PASSWORD);// 设置配置项java.util.Properties config = new java.util.Properties();config.put("StrictHostKeyChecking", "no");session.setConfig(config);// 连接会话System.out.println("Connecting to SSH server...");session.connect();// 打开 SFTP 通道Channel channel = session.openChannel("sftp");channel.connect();ChannelSftp sftpChannel = (ChannelSftp) channel;// 解析远程文件路径中的文件名String fileName = extractFileNameFromPath(remotePath);// 创建本地文件路径File localFile = new File(localPath, fileName);// 创建本地目标目录File directory = localFile.getParentFile();if (!directory.exists()) {boolean mkdirResult = directory.mkdirs();if (mkdirResult) {System.out.println("创建文件夹成功");} else {System.out.println("创建文件夹失败");throw new RuntimeException("创建文件夹失败!");}}// 下载文件System.out.println("Downloading file from remote path: " + remotePath);sftpChannel.get(remotePath, localFile.getAbsolutePath());System.out.println("文件下载成功");// 关闭通道和会话channel.disconnect();session.disconnect();} catch (Exception e) {e.printStackTrace();System.err.println("文件下载失败:" + e.getMessage());}}/*** 从路径中提取文件名** @param path 完整路径* @return 文件名*/private static String extractFileNameFromPath(String path) {int lastSeparatorIndex = path.lastIndexOf(File.separator);return path.substring(lastSeparatorIndex + 1);}public static void main(String[] args) {System.out.println("Main method started.");//获取开始时间long startTime = System.currentTimeMillis();String remotePath = "/data/ceshiDown/eac207eeeb2095cc560f94b6e7e33f49_4.mp4"; // 远程文件路径String localPath = "E:\\mnt\\data_process_net\\token"; // 本地目标目录scpFromRemote(remotePath, localPath);System.out.println("Main method finished.");//获取结束时间long endTime = System.currentTimeMillis();System.out.println("程序运行时间:" + (endTime - startTime)/1000 + "s");}
}

这段代码应该不需要我讲解一下了吧,我相信兄弟们都可以看懂的,必要的注释我都加上啦。

搞定!

2.3 SCP方式

SCP的实现方式,有一些稍微的麻烦,需要写一个expect脚本,为什么使用脚本呢,说明一下,在我们使用scp命令在拷贝远程服务器的时候,我们中间需要输入密码。

但是我们在执行代码的时候,可以自动识别需要输入密码,然后自动化输入密码吗?答案是不能的。

所以这里介入expect脚本的作用就是识别哪里需要输入密码,然后自动化输入密码。

这里应该不需要安装任何的依赖的。

直接就是工具类:

import lombok.extern.slf4j.Slf4j;import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
@Slf4j
public class ScpUtil {public static void scpFromRemoteUsingExpect(String expectScriptPath, String user, String host, int port, String remotePath, String localPath, String password) {Process process = null;try {// 确保目标目录存在File localDir = new File(localPath);if (!localDir.exists()) {boolean created = localDir.mkdirs(); // 创建多级目录if (!created) {throw new IOException("无法创建目标目录: " + localPath);}}// 构建 expect 脚本的命令行参数String[] params = {user, host, Integer.toString(port), remotePath, localPath, password};String command = expectScriptPath + " " + String.join(" ", params);// 执行 expect 脚本process = Runtime.getRuntime().exec(command);// 读取命令的输出BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));String line;while ((line = reader.readLine()) != null) {System.out.println(line);}// 等待命令执行完成int exitCode = process.waitFor();if (exitCode == 0) {log.info("文件下载成功");} else {log.info("文件下载失败,退出代码:{}", exitCode);}} catch (Exception e) {e.printStackTrace();log.info("文件下载失败:{}", e.getMessage());}finally {// 确保资源被释放if (process != null) {process.destroy();}}}public static void scpDirectoryFromRemoteUsingExpect(String expectScriptPath, String user, String host, int port, String remotePath, String localPath, String password) {Process process = null;try {// 确保目标目录存在File localDir = new File(localPath);if (!localDir.exists()) {boolean created = localDir.mkdirs(); // 创建多级目录if (!created) {throw new IOException("无法创建目标目录: " + localPath);}}// 构建 expect 脚本的命令行参数,确保 remotePath 是一个目录String[] params = {user, host, Integer.toString(port), remotePath + "/", localPath, password};String command = expectScriptPath + " " + String.join(" ", params);// 执行 expect 脚本process = Runtime.getRuntime().exec(command);// 读取命令的输出BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));String line;while ((line = reader.readLine()) != null) {System.out.println(line);}// 等待命令执行完成int exitCode = process.waitFor();if (exitCode == 0) {System.out.println("文件夹下载成功");} else {System.err.println("文件夹下载失败,退出代码:" + exitCode);}} catch (IOException e) {e.printStackTrace();log.info("文件夹下载失败:{}", e.getMessage());} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 重新设置中断状态e.printStackTrace();log.info("文件夹下载被中断:{}", e.getMessage());} finally {// 确保资源被释放if (process != null) {try {process.getInputStream().close();process.getOutputStream().close();process.getErrorStream().close();} catch (IOException e) {e.printStackTrace();}process.destroy();}}}public static void main(String[] args) {log.info("Main method started.");// 获取开始时间long startTime = System.currentTimeMillis();String expectScriptPath = "/script/scp_download_directory.exp"; // expect 脚本的路径String remotePath = "/data/ceshiDown/";String localPath = "/data/ceshi2";ScpUtil.scpDirectoryFromRemoteUsingExpect(expectScriptPath, USER_NAME, IP, PORT, remotePath, localPath, PASSWORD);log.info("Main method finished.");// 获取结束时间long endTime = System.currentTimeMillis();System.out.println("程序运行时间:" + (endTime - startTime) / 1000 + "s");}
}

上面这个工具类呢,scpFromRemoteUsingExpect()方法是复制文件的,scpDirectoryFromRemoteUsingExpect()是复制文件夹的。注意一下哦。

最终要的来啦,脚本怎么写呢。
复制文件的脚本下载地址:scp复制远程服务器文件至本地服务器expect脚本

复制文件夹的脚本下载地址:scp复制远程服务器文件夹至本地服务器expect脚本

若是文件下载不了,千万别花钱下载,联系我,我发你。

这里我就不测试了,我是在服务器测试的,是行得通的。
完结!撒花!以上内容,若有任何问题,欢迎在评论区留言,在此,若有更好的解决方案的兄弟,也请留言,让我学习一下哈

这篇关于服务器间进行文件传输-SFTPSCP一篇搞定的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1128313

相关文章

Linux使用fdisk进行磁盘的相关操作

《Linux使用fdisk进行磁盘的相关操作》fdisk命令是Linux中用于管理磁盘分区的强大文本实用程序,这篇文章主要为大家详细介绍了如何使用fdisk进行磁盘的相关操作,需要的可以了解下... 目录简介基本语法示例用法列出所有分区查看指定磁盘的区分管理指定的磁盘进入交互式模式创建一个新的分区删除一个存

C#使用HttpClient进行Post请求出现超时问题的解决及优化

《C#使用HttpClient进行Post请求出现超时问题的解决及优化》最近我的控制台程序发现有时候总是出现请求超时等问题,通常好几分钟最多只有3-4个请求,在使用apipost发现并发10个5分钟也... 目录优化结论单例HttpClient连接池耗尽和并发并发异步最终优化后优化结论我直接上优化结论吧,

NFS实现多服务器文件的共享的方法步骤

《NFS实现多服务器文件的共享的方法步骤》NFS允许网络中的计算机之间共享资源,客户端可以透明地读写远端NFS服务器上的文件,本文就来介绍一下NFS实现多服务器文件的共享的方法步骤,感兴趣的可以了解一... 目录一、简介二、部署1、准备1、服务端和客户端:安装nfs-utils2、服务端:创建共享目录3、服

使用Python进行文件读写操作的基本方法

《使用Python进行文件读写操作的基本方法》今天的内容来介绍Python中进行文件读写操作的方法,这在学习Python时是必不可少的技术点,希望可以帮助到正在学习python的小伙伴,以下是Pyth... 目录一、文件读取:二、文件写入:三、文件追加:四、文件读写的二进制模式:五、使用 json 模块读写

使用zabbix进行监控网络设备流量

《使用zabbix进行监控网络设备流量》这篇文章主要为大家详细介绍了如何使用zabbix进行监控网络设备流量,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录安装zabbix配置ENSP环境配置zabbix实行监控交换机测试一台liunx服务器,这里使用的为Ubuntu22.04(

在Pandas中进行数据重命名的方法示例

《在Pandas中进行数据重命名的方法示例》Pandas作为Python中最流行的数据处理库,提供了强大的数据操作功能,其中数据重命名是常见且基础的操作之一,本文将通过简洁明了的讲解和丰富的代码示例,... 目录一、引言二、Pandas rename方法简介三、列名重命名3.1 使用字典进行列名重命名3.编

Python项目打包部署到服务器的实现

《Python项目打包部署到服务器的实现》本文主要介绍了PyCharm和Ubuntu服务器部署Python项目,包括打包、上传、安装和设置自启动服务的步骤,具有一定的参考价值,感兴趣的可以了解一下... 目录一、准备工作二、项目打包三、部署到服务器四、设置服务自启动一、准备工作开发环境:本文以PyChar

python安装完成后可以进行的后续步骤和注意事项小结

《python安装完成后可以进行的后续步骤和注意事项小结》本文详细介绍了安装Python3后的后续步骤,包括验证安装、配置环境、安装包、创建和运行脚本,以及使用虚拟环境,还强调了注意事项,如系统更新、... 目录验证安装配置环境(可选)安装python包创建和运行Python脚本虚拟环境(可选)注意事项安装

如何使用celery进行异步处理和定时任务(django)

《如何使用celery进行异步处理和定时任务(django)》文章介绍了Celery的基本概念、安装方法、如何使用Celery进行异步任务处理以及如何设置定时任务,通过Celery,可以在Web应用中... 目录一、celery的作用二、安装celery三、使用celery 异步执行任务四、使用celery

Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单

《Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单》:本文主要介绍Springboot的ThreadPoolTaskScheduler线... 目录ThreadPoolTaskScheduler线程池实现15分钟不操作自动取消订单概要1,创建订单后