FTP文件的上传与下载

 利用FTP实现文件的上传与下载（Java):

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.TimeZone;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;import org.apache.log4j.Logger;import static org.apache.log4j.Logger.getLogger;public class FtpServer {private FTPClient ftpClient;private String strIp;private int intPort;private String user;private String password;private static Logger logger = getLogger(FtpServer.class.getName());/* ** Ftp构造函数*/public FtpServer(String strIp, int intPort, String user, String Password) {this.strIp = strIp;this.intPort = intPort;this.user = user;this.password = Password;this.ftpClient = new FTPClient();}/*** @return 判断是否登入成功* */public boolean ftpLogin() {boolean isLogin = false;FTPClientConfig ftpClientConfig = new FTPClientConfig();ftpClientConfig.setServerTimeZoneId(TimeZone.getDefault().getID());this.ftpClient.setControlEncoding("GBK");this.ftpClient.configure(ftpClientConfig);try {if (this.intPort > 0) {this.ftpClient.connect(this.strIp, this.intPort);}else {this.ftpClient.connect(this.strIp);}// FTP服务器连接回答int reply = this.ftpClient.getReplyCode();if (!FTPReply.isPositiveCompletion(reply)) {this.ftpClient.disconnect();logger.error("登录FTP服务失败！");return isLogin;}this.ftpClient.login(this.user, this.password);// 设置传输协议this.ftpClient.enterLocalPassiveMode();this.ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);logger.info("恭喜" + this.user + "成功登陆FTP服务器");isLogin = true;}catch (Exception e) {e.printStackTrace();logger.error(this.user + "登录FTP服务失败！" + e.getMessage());}this.ftpClient.setBufferSize(1024 * 2);this.ftpClient.setDataTimeout(30 * 1000);return isLogin;}/*** @退出关闭服务器链接* */public void ftpLogOut() {if (null != this.ftpClient && this.ftpClient.isConnected()) {try {boolean reuslt = this.ftpClient.logout();// 退出FTP服务器if (reuslt) {logger.info("成功退出服务器");}}catch (IOException e) {e.printStackTrace();logger.warn("退出FTP服务器异常！" + e.getMessage());}finally {try {this.ftpClient.disconnect();// 关闭FTP服务器的连接}catch (IOException e) {e.printStackTrace();logger.warn("关闭FTP服务器的连接异常！");}}}}/**** 上传Ftp文件* @param localFile 当地文件* @param romotUpLoadePath上传服务器路径 - 应该以/结束* */public boolean uploadFile(File localFile, String romotUpLoadePath) {BufferedInputStream inStream = null;boolean success = false;try {this.ftpClient.changeWorkingDirectory(romotUpLoadePath);// 改变工作路径inStream = new BufferedInputStream(new FileInputStream(localFile));logger.info(localFile.getName() + "开始上传.....");success = this.ftpClient.storeFile(localFile.getName(), inStream);if (success == true) {logger.info(localFile.getName() + "上传成功");return success;}}catch (FileNotFoundException e) {e.printStackTrace();logger.error(localFile + "未找到");}catch (IOException e) {e.printStackTrace();}finally {if (inStream != null) {try {inStream.close();}catch (IOException e) {e.printStackTrace();}}}return success;}/**** 下载文件* @param remoteFileName   待下载文件名称* @param localDires 下载到当地那个路径下* @param remoteDownLoadPath remoteFileName所在的路径* */public boolean downloadFile(String remoteFileName, String localDires,String remoteDownLoadPath) {String strFilePath = localDires + remoteFileName;BufferedOutputStream outStream = null;boolean success = false;try {this.ftpClient.changeWorkingDirectory(remoteDownLoadPath);outStream = new BufferedOutputStream(new FileOutputStream(strFilePath));logger.info(remoteFileName + "开始下载....");success = this.ftpClient.retrieveFile(remoteFileName, outStream);if (success == true) {logger.info(remoteFileName + "成功下载到" + strFilePath);return success;}}catch (Exception e) {e.printStackTrace();logger.error(remoteFileName + "下载失败");}finally {if (null != outStream) {try {outStream.flush();outStream.close();}catch (IOException e) {e.printStackTrace();}}}if (success == false) {logger.error(remoteFileName + "下载失败!!!");}return success;}/**** @上传文件夹* @param localDirectory*            当地文件夹* @param remoteDirectoryPath*            Ftp 服务器路径 以目录"/"结束* */public boolean uploadDirectory(String localDirectory,String remoteDirectoryPath) {File src = new File(localDirectory);try {remoteDirectoryPath = remoteDirectoryPath + src.getName() + "/";boolean makeDirFlag = this.ftpClient.makeDirectory(remoteDirectoryPath);System.out.println("localDirectory : " + localDirectory);System.out.println("remoteDirectoryPath : " + remoteDirectoryPath);System.out.println("src.getName() : " + src.getName());System.out.println("remoteDirectoryPath : " + remoteDirectoryPath);System.out.println("makeDirFlag : " + makeDirFlag);// ftpClient.listDirectories();}catch (IOException e) {e.printStackTrace();logger.info(remoteDirectoryPath + "目录创建失败");}File[] allFile = src.listFiles();for (int currentFile = 0;currentFile < allFile.length;currentFile++) {if (!allFile[currentFile].isDirectory()) {String srcName = allFile[currentFile].getPath().toString();uploadFile(new File(srcName), remoteDirectoryPath);}}for (int currentFile = 0;currentFile < allFile.length;currentFile++) {if (allFile[currentFile].isDirectory()) {// 递归uploadDirectory(allFile[currentFile].getPath().toString(),remoteDirectoryPath);}}return true;}/**** @下载文件夹* @param localDirectoryPath本地地址* @param remoteDirectory 远程文件夹* */public boolean downLoadDirectory(String localDirectoryPath, String remoteDirectory) {try {String fileName = new File(remoteDirectory).getName();localDirectoryPath = localDirectoryPath + fileName + "//";new File(localDirectoryPath).mkdirs();FTPFile[] allFile = this.ftpClient.listFiles(remoteDirectory);//System.out.println(allFile.length);for (int currentFile = 0;currentFile < allFile.length;currentFile++) {if (!allFile[currentFile].isDirectory()) {downloadFile(allFile[currentFile].getName(),localDirectoryPath, remoteDirectory);}}for (int currentFile = 0;currentFile < allFile.length;currentFile++) {if (allFile[currentFile].isDirectory()) {String strremoteDirectoryPath = remoteDirectory + "/"+ allFile[currentFile].getName();downLoadDirectory(localDirectoryPath,strremoteDirectoryPath);}}}catch (IOException e) {e.printStackTrace();logger.info("下载文件夹失败");return false;}return true;}// FtpClient的Set 和 Get 函数public FTPClient getFtpClient() {return ftpClient;}public void setFtpClient(FTPClient ftpClient) {this.ftpClient = ftpClient;}public static void main(String[] args) throws IOException {FtpServer ftp=new FtpServer("192.168.1.6",21,"boyixingyu","boyixingyu");ftp.ftpLogin();System.out.println("1");//上传文件夹boolean uploadFlag = ftp.uploadDirectory("G:\\FtpServerTest", "/"); //如果是admin/那么传的就是所有文件，如果只是/那么就是传文件夹System.out.println("uploadFlag : " + uploadFlag);//下载文件夹//ftp.downLoadDirectory("G:\\FtpServerTest", "/");ftp.ftpLogOut();}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/745974.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

2024.3.14 ARM

2024.3.14 ARM

思维导图
阅读更多...
录屏在哪开？很简单，我来告诉你！

录屏在哪开？很简单，我来告诉你！

随着数码产品的普及和网络技术的发展&#xff0c;录屏已经成为人们日常生活中经常需要使用的功能。无论是录制游戏精彩瞬间、制作教学视频还是保存线上会议内容&#xff0c;录屏都扮演着重要的角色。然而&#xff0c;很多用户却不知道录屏在哪开&#xff0c;以及如何使用它们。…
阅读更多...
『scrapy爬虫』04. 使用管道将数据写入excel（详细注释步骤）

『scrapy爬虫』04. 使用管道将数据写入excel（详细注释步骤）

目录 1. excel文件的初始化与保存2. 配置管道使用运行测试总结 欢迎关注 『scrapy爬虫』 专栏&#xff0c;持续更新中 欢迎关注 『scrapy爬虫』 专栏&#xff0c;持续更新中 1. excel文件的初始化与保存 安装操作excel文件的库 pip install openpyxl钩子函数&#xff08;Hook…
阅读更多...
✅技术社区—MySQL和ES的数据同步策略

✅技术社区—MySQL和ES的数据同步策略

使用Canal框架实现MySQL与Elasticsearch&#xff08;ES&#xff09;的数据同步确实可以提高实时搜索的准确性和效率。Canal通过模拟MySQL的binlog日志订阅和解析&#xff0c;实现了数据的实时同步。在这样的同步机制下&#xff0c;ES中的数据可以非常接近于MySQL数据库中的实时…
阅读更多...
非阻塞 IO多路复用

非阻塞 IO多路复用

非阻塞 & IO多路复用 一、非阻塞 socket都是会阻塞的 在等待连接以及等待接收数据的时候进入一个阻塞状态 # 服务端 import socketphone socket.socket(socket.AF_INET , socket.SOCK_STREAM) phone.bind((127.0.0.1 , 8080)) phone.listen(5)# 设置非阻塞状态 phone.…
阅读更多...
【MySQL性能优化】- 一文了解MVCC机制

【MySQL性能优化】- 一文了解MVCC机制

MySQL理解MVCC &#x1f604;生命不息&#xff0c;写作不止 &#x1f525; 继续踏上学习之路&#xff0c;学之分享笔记 &#x1f44a; 总有一天我也能像各位大佬一样 &#x1f3c6; 博客首页 怒放吧德德 To记录领地 &#x1f31d;分享学习心得&#xff0c;欢迎指正&#xff…
阅读更多...
【Qt】QListView 显示富文本，设置文本内容颜色

【Qt】QListView 显示富文本，设置文本内容颜色

【Qt】QListView 显示富文本&#xff0c;设置文本内容颜色 文章目录 I - 控件使用II - 显示富文本III - 注意事项 I - 控件使用 Qt 的 MVC 架构为 MV &#xff0c;Controller 部分继承到了 View 里&#xff0c;View(视图) 设置 Model(模型)&#xff0c;Model 设置数据 这里使用…
阅读更多...
NTP网络时间服务器的妙用？让网络更精准

NTP网络时间服务器的妙用？让网络更精准

NTP网络时间服务器的妙用&#xff1f;让网络更精准 NTP网络时间服务器的妙用&#xff1f;让网络更精准 随着计算机网络的迅猛发展&#xff0c;网络应用已经非常普遍&#xff0c;众多领域的网络系统如电力、石化、金融业&#xff08;证券、银行&#xff09;、广电业&#xff08…
阅读更多...
华为机试真题实战应用【算法代码篇】-字符串最后一个单词的长度（附Python、C++和Java代码）

华为机试真题实战应用【算法代码篇】-字符串最后一个单词的长度（附Python、C++和Java代码）

目录 问题描述 思路解析 思路1 思路2 代码实现 Java 代码2
阅读更多...
工作中Git如何切换远程仓库地址

工作中Git如何切换远程仓库地址

工作中Git如何切换远程仓库地址 部门之前的仓库不用了&#xff0c;重新建了一个仓库&#xff0c;但是上传代码还是上传到了之前的仓库里面了&#xff0c;所以得进行修改&#xff0c;下面将修改地址的方法进行操作。 方法一、直接修改远程仓库地址 查看当前远程仓库地址 git …
阅读更多...
ideaSSM校医院管理网页模式开发mysql数据库web结构java编程计算机网页源码maven项目

ideaSSM校医院管理网页模式开发mysql数据库web结构java编程计算机网页源码maven项目

一、源码特点 idea ssm 校医院管理系统是一套完善的完整信息管理系统&#xff0c;结合SSM框架完成本系统SpringMVC spring mybatis &#xff0c;对理解JSP java编程开发语言有帮助系统采用SSM框架&#xff08;MVC模式开发&#xff09;&#xff0c; 系统具有完整的源代码和数据…
阅读更多...
C# tcp通信连接正常判断

C# tcp通信连接正常判断

在 C# 中&#xff0c;你可以使用 TcpClient 类来进行 TCP 连接的管理。你可以编写一个循环来尝试连接&#xff0c;以及检测连接是否正常。以下是一个简单的示例代码&#xff0c;演示如何实现这一功能&#xff1a; using System; using System.Net.Sockets; using System.Threa…
阅读更多...
前端跨页面通信的几种方式---同源

前端跨页面通信的几种方式---同源

参考链接 1、LocalStorage:当 LocalStorage 变化时&#xff0c;会触发storage事件。利用这个特性&#xff0c;我们可以在发送消息时&#xff0c;把消息写入到某个 LocalStorage 中&#xff1b;然后在各个页面内&#xff0c;通过监听storage事件即可收到通知。 2、BroadCast C…
阅读更多...
Java实现知乎热点小时榜爬虫

Java实现知乎热点小时榜爬虫

1.效果演示 1.1 热点问题列表 启动程序后&#xff0c;自动展示热点问题&#xff0c;并等待终端输入 1.2 根据序号选择想看的热点问题 输入问题序号&#xff0c;展示回答内容 1.3 退出 输入q即可退出程序 2.源码 2.1 pom.xml <?xml version"1.0" enco…
阅读更多...
Spring Boot 获取maven打包时间

Spring Boot 获取maven打包时间

引入maven打包插件 <build><plugins><!-- 打包时生成打包时间 --><plugin><groupId>org.codehaus.mojo</groupId><artifactId>buildnumber-maven-plugin</artifactId><version>3.2.0</version><configuration&…
阅读更多...
perl 用 XML::LibXML 解析 Freeplane.mm文件，XML文件

perl 用 XML::LibXML 解析 Freeplane.mm文件，XML文件

Perl 官网 www.cpan.org 从 https://strawberryperl.com/ 下载网速太慢了 建议从 https://download.csdn.net/download/qq_36286161/87892419 下载 strawberry-perl-5.32.1.1-64bit.zip 约105MB 解压后安装.msi&#xff0c;装完后有520MB&#xff0c;建议安装在D:盘 在云计算…
阅读更多...
kotlin 程序 编译与执行

kotlin 程序 编译与执行

准备kotlin环境 Ubuntu安装kotlin 1. 创建一个名为 hello.kt 文件&#xff0c;代码如下&#xff1a; fun main(args: Array<String>) {println("Hello, World!") }2. 使用 Kotlin 编译器编译应用 kotlinc hello.kt -include-runtime -d hello.jar-d: 用来设…
阅读更多...
java数据结构与算法刷题-----LeetCode46. 全排列

java数据结构与算法刷题-----LeetCode46. 全排列

java数据结构与算法刷题目录&#xff08;剑指Offer、LeetCode、ACM&#xff09;-----主目录-----持续更新(进不去说明我没写完)&#xff1a;https://blog.csdn.net/grd_java/article/details/123063846 文章目录 1. 暴力回溯2. 分区法回溯 1. 暴力回溯 解题思路&#xff1a;时…
阅读更多...
Linux下JSON解析工具

Linux下JSON解析工具

jq&#xff1a;是一个强大的命令行工具&#xff0c;用于处理 JSON 格式的数据。它可以帮助你查询、过滤、修改和处理 JSON 数据&#xff0c;使得再命令行环境下处理 JSON 变得非常方便。 官方下载地址&#xff1a; https://jqlang.github.io/jq/download/ 官方文档&#xff1…
阅读更多...
Python和MATLAB数字信号波形和模型模拟

Python和MATLAB数字信号波形和模型模拟

要点 Python和MATLAB实现以下波形和模型模拟 以给定采样率模拟正弦信号&#xff0c;生成给定参数的方波信号&#xff0c;生成给定参数隔离矩形脉冲&#xff0c;生成并绘制线性调频信号。快速傅里叶变换结果释义&#xff1a;复数离散傅里叶变换、频率仓和快速傅里叶变换移位&am…
阅读更多...
最新文章

Copyright @ 2022~2023