本文引用了https://www.cnblogs.com/lr393993507/p/5502266.html资源,并做了一些优化

这里有个写好的java项目demo,csdn好像擅自给我的资源加了很多积分,我原来只设置2个,现在要7个,下面是资源的地址,如果不能用,请留言:

https://pan.baidu.com/s/11DcCCdgPQKnTIg6Bhvp7Yg      ek6i

同时附csdn的资源地址:https://download.csdn.net/download/qq_30307137/10513665

所需jar:

ftp model类,负责ftp连接属性的设置, 提供set get 方法:

package com.ftp.model;

public class Ftp {
private String ipAddr;//ip地址
    
    private Integer port;//端口号
    
    private String userName;//用户名
    
    private String pwd;//密码
    
    private String path;//路径
    
    public Ftp(String ipAddr, Integer port, String userName, String pwd,
String path) {

this.ipAddr = ipAddr;
this.port = port;
this.userName = userName;
this.pwd = pwd;
this.path = path;
}

public Ftp() {

}

public String getIpAddr() {
        return ipAddr;
    }

public void setIpAddr(String ipAddr) {
        this.ipAddr = ipAddr;
    }

public Integer getPort() {
        return port;
    }

public void setPort(Integer port) {
        this.port = port;

}

public String getUserName() {
        return userName;

}

public void setUserName(String userName) {
        this.userName = userName;
    }

public String getPwd() {
        return pwd;
    }

public void setPwd(String pwd) {
        this.pwd = pwd;
    }

public String getPath() {
        return path;
    }

public void setPath(String path) {
        this.path = path;
    }

}

ftp进行上传下载的工具类:

package com.ftp.utils;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;

import com.ftp.model.Ftp;

public class FtpUtils {

private static Logger logger=Logger.getLogger(FtpUtils.class);
private static FTPClient ftp;
/**
     * 获取ftp连接
     * @param f
     * @return
     * @throws Exception
     */
    public static boolean connectFtp(Ftp f) throws Exception{
        ftp=new FTPClient();
        boolean flag=false;
        int reply;
        if (f.getPort()==null) {
            ftp.connect(f.getIpAddr(),21);
        }else{
            ftp.connect(f.getIpAddr(),f.getPort());
        }
        ftp.login(f.getUserName(), f.getPwd());
        ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
        reply = ftp.getReplyCode();      
        if (!FTPReply.isPositiveCompletion(reply)) {      
              ftp.disconnect();      
              return flag;      
        }      
        ftp.changeWorkingDirectory(f.getPath());      
        flag = true;   
       
        return flag;
    }
   
    public static void closeFtp(){
        if (ftp!=null && ftp.isConnected()) {
            try {
                ftp.logout();
                ftp.disconnect();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

public static void upload(File f) throws Exception{
        if (f.isDirectory()) {
            ftp.makeDirectory(f.getName());
            ftp.changeWorkingDirectory(f.getName());
            String[] files=f.list();
            for(String fstr : files){
                File file1=new File(f.getPath()+"/"+fstr);
                if (file1.isDirectory()) {
                    upload(file1);
                    ftp.changeToParentDirectory();
                }else{
                    File file2=new File(f.getPath()+"/"+fstr);
                    FileInputStream input=new FileInputStream(file2);
                    ftp.storeFile(file2.getName(),input);
                    input.close();
                }
            }
        }else{
            File file2=new File(f.getPath());
            FileInputStream input=new FileInputStream(file2);
            ftp.storeFile(file2.getName(),input);
            input.close();
        }
    }
    
    /**
     * 下载链接配置
     * @param f
     * @param localBaseDir 本地目录
     * @param remoteBaseDir 远程目录
     * @throws Exception
     */
    public static void startDown(Ftp f,String localBaseDir,String remoteBaseDir,String alone ) throws Exception{
        if (FtpUtils.connectFtp(f)) {
            try { 
                FTPFile[] files = null; 
                boolean changedir = ftp.changeWorkingDirectory(remoteBaseDir); 
                if (changedir) { 
                    ftp.setControlEncoding("GBK"); 
                    files = ftp.listFiles(); 
                    
                    if(null!=alone&&!("".equals(alone))){
                    for(int i=0;i<files.length;i++){
                    if(files[i].getName().contains(alone)){
                    downloadFile(files[i], localBaseDir, remoteBaseDir); 
                    }
                    }
                    }else{
                    for (int i = 0; i < files.length; i++) { 
                    downloadFile(files[i], localBaseDir, remoteBaseDir); 
                    }
                    }
                } 
            } catch (Exception e) { 
                logger.error(e); 
                logger.error("下载过程中出现异常"); 
            } 
        }else{
            logger.error("链接失败!");
        }   
    }
    
    
    /** 
     * 
     * 下载FTP文件 
     * 当你需要下载FTP文件的时候,调用此方法 
     * 根据<b>获取的文件名,本地地址,远程地址</b>进行下载 
     * 
     * @param ftpFile 
     * @param relativeLocalPath 
     * @param relativeRemotePath 
     */ 
    private  static void downloadFile(FTPFile ftpFile, String relativeLocalPath,String relativeRemotePath) { 
        if (ftpFile.isFile()) {
            if (ftpFile.getName().indexOf("?") == -1) { 
                OutputStream outputStream = null; 
                try { 
                    File locaFile= new File(relativeLocalPath+ ftpFile.getName()); 
                    //判断文件是否存在,存在则返回 
                    if(locaFile.exists()){ 
                        return; 
                    }else{ 
                        outputStream = new FileOutputStream(relativeLocalPath+ ftpFile.getName()); 
                        ftp.retrieveFile(ftpFile.getName(), outputStream); 
                        outputStream.flush(); 
                        outputStream.close(); 
                    } 
                } catch (Exception e) { 
                    logger.error(e);
                } finally { 
                    try { 
                        if (outputStream != null){ 
                            outputStream.close(); 
                        }
                    } catch (IOException e) { 
                       logger.error("输出文件流异常"); 
                    } 
                } 
            } 
        } else { 
            String newlocalRelatePath = relativeLocalPath + ftpFile.getName(); 
            String newRemote = new String(relativeRemotePath+ ftpFile.getName().toString()); 
            File fl = new File(newlocalRelatePath); 
            if (!fl.exists()) { 
                fl.mkdirs(); 
            } 
            try { 
                newlocalRelatePath = newlocalRelatePath + '/'; 
                newRemote = newRemote + "/"; 
                String currentWorkDir = ftpFile.getName().toString(); 
                boolean changedir = ftp.changeWorkingDirectory(currentWorkDir); 
                if (changedir) { 
                    FTPFile[] files = null; 
                    files = ftp.listFiles(); 
                    for (int i = 0; i < files.length; i++) { 
                        downloadFile(files[i], newlocalRelatePath, newRemote); 
                    } 
                } 
                if (changedir){
                    ftp.changeToParentDirectory(); 
                } 
            } catch (Exception e) { 
                logger.error(e);
            } 
        } 
    }

}

测试类:

package com.ftp.test;

import java.io.File;

import org.apache.commons.net.ftp.FTPFile;

import com.ftp.model.Ftp;
import com.ftp.utils.FtpUtils;

public class Test {
public static void main(String[] args) {
try {
Ftp ftp=new Ftp();
ftp.setIpAddr("127.0.0.1");//直接写ip地址,不需要加ftp://
ftp.setPath("/haha");      //你需要下载上传或下载文件的ftp路径
ftp.setPort(21);           //端口号
ftp.setPwd("123456");      //ftp密码
ftp.setUserName("admin");  //ftp账号
FtpUtils.connectFtp(ftp); //连接

//上传方法的调用:将本地桌面文件heihei.txt上传到ftp上haha目录下
File f=new File("C:\\Users\\Administrator\\Desktop\\heihei.txt");//需要上传文件的路径+文件名
FtpUtils.upload(f);      //执行上传
 
//下载方法的调用:将ftp上目录为haha中的xu2.xlsx文件下载到桌面,如果需要下载haha中的全部文件,则第四个参数为null
//FtpUtils.startDown(ftp, "C:\\Users\\Administrator\\Desktop\\", null,"xu2.xlsx");
/*
* 下载方法说明:FtpUtils.startDown(ftp, "C:\\Users\\Administrator\\Desktop\\", null,"xu2.xlsx");
* 下载ftp上目录为haha中xu2.xlsx文件到桌面。

* FtpUtils.startDown(ftp, "C:\\Users\\Administrator\\Desktop\\", null,null);
* 下载ftp上目录为haha下的所有文件到桌面。

* 如果你需要下载haha目录下的多个文件,但是又不需要全部下载,调用多次就行了,如下:
* FtpUtils.startDown(ftp, "C:\\Users\\Administrator\\Desktop\\", null,"xu1.xlsx");
* FtpUtils.startDown(ftp, "C:\\Users\\Administrator\\Desktop\\", null,"xu2.xlsx");
* FtpUtils.startDown(ftp, "C:\\Users\\Administrator\\Desktop\\", null,"xu3.xlsx");

* 注意:只要 ftp.setPath("/haha")方法参数设置好,下载方法第三个参数方法最好是null


* 如果发现上传下载出现问题,尝试从以下入手:
* 1.ftp上打开该用户的上传下载权限
* 2.检查路经是否写错了
* 3.无论上传下载,文件名不能包含中文、空格,最好英文、数字. ---------(这条很重要)----------
*/

} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();

}

}

}

使用java对ftp进行文件的上传下载demo相关推荐

  1. java 文件下载 组件_java文件夹上传下载组件

    核心原理: 该项目核心就是文件分块上传.前后端要高度配合,需要双方约定好一些数据,才能完成大文件分块,我们在项目中要重点解决的以下问题. *如何分片: *如何合成一个文件: *中断了从哪个分片开始. ...

  2. Java使用SFTP和FTP两种连接服务器的方式实现对文件的上传下载

    一.Java实现对SFTP服务器的文件的上传下载: 1.添加maven依赖: <dependency><groupId>com.jcraft</groupId>&l ...

  3. Java ftp实现文件的上传和下载ftp,sftp sun.net.ftp.FtpProtocolException:Welcome message: SSH-2.0-OpenSSH_5.1

    Java ftp实现文件的上传和下载 ftp,sftp 运行后发现很长时间没有反应,很久以后抛出如下异常:sun.net.ftp.FtpProtocolException:Welcome messag ...

  4. java ftp ftpclient_详解JAVA中使用FTPClient工具类上传下载

    详解JAVA中使用FTPClient工具类上传下载 在Java程序中,经常需要和FTP打交道,比如向FTP服务器上传文件.下载文件.本文简单介绍如何利用jakarta commons中的FTPClie ...

  5. FastDFS:Java客户都实现文件的上传、下载、修改、删除

    FastDFS:Java客户都实现文件的上传.下载.修改.删除 <project xmlns="http://maven.apache.org/POM/4.0.0" xmln ...

  6. java文件客户端下载_使用Java写一个minio的客户端上传下载文件

    标签:color   ati   tty   java   system   wired   format   media   param 前言: 确保已经安装了minio的服务端 代码: pom.x ...

  7. Linux安装FTP及使用python上传下载ftp

    参考 https://www.cnblogs.com/mingforyou/p/4103022.html 一.安装及配置 1.直接使用yum安装 yum -y install vsftpd 2.配置文 ...

  8. 基于layui.upload.js 拖拽文件/文件夹上传下载

    layui.upload.js 拖拽文件/文件夹上传下载 前言 js代码 页面使用(我这里用的是uploader.jsp) CSS文件 上传效果 总结 前言 项目需求完成文件上传,可以拖拽上传文件/文 ...

  9. 使用JSP+Servlet实现文件的上传下载上传

    <!DOCTYPE html > <html> <head> <meta charset="UTF-8"> <title> ...

最新文章

  1. 解决AW2013用led_classdev_register()注册red但/sys/class/leds下看不到red的问题
  2. altium designer无法创建工程_前端工程化之开发脚手架及封装自动化构建
  3. larvare数据库引入php_PHP全栈学习笔记6
  4. 地址已在使用 java_java – UDP地址已经在使用?
  5. 直接存储器存取(Direct Memory Access,DMA)详细讲解
  6. LAMP、LNMP实战之九搭建cms、blog、bbs(持续更新)
  7. mysql的事物隔离机制?
  8. python单例设计模式(待补充)
  9. 20181114 Redis
  10. 配置Typescript+Node环境
  11. java swing开发打飞机的小游戏源代码下载
  12. Scratch 3.x编程技巧:条件语句与随机数
  13. tomcat8安装及配置详细步骤(win10)
  14. 成神之路——实施工程师
  15. java标准化考试系统源码_java标准化考试系统
  16. flash动画短片制作常用表现方法与技巧(精华)
  17. C++——STL容器
  18. OpenCV4--->基础函数,与操作
  19. ps cs6如何破解
  20. rxjava背压_Android RxJava :图文详解 背压策略

热门文章

  1. 2021.11.20关于用递归来解决进制转换
  2. 【初等数论】同余方程、与二次剩余互反律
  3. golang学习笔记(19)-gin路由分组和中间件
  4. 番茄闹钟三(登录注册页面)
  5. 计算机金融专业课程方案,美国留学卡内基梅隆大学计算机金融专业简介
  6. 腾讯云cos本地和云端同步python工具类
  7. Android 音频录制 的三种方式
  8. 《机器学习实战》学习笔记(四) : 朴素贝叶斯的基本原理
  9. c语言何编写自定义函数,C语言菜鸟基础教程之自定义函数
  10. 安科瑞工业绝缘监测及故障定位解决方案