• vsftp文件服务器的搭建与使用案例

    一、Linux 云服务器搭建 FTP 服务

    1.执行以下命令，安装 vsftpd。

    yum install -y vsftpd

    2.执行以下命令，设置 vsftpd 开机自启动。

    systemctl enable vsftpd

    3.执行以下命令，启动 FTP 服务

    systemctl start vsftpd

    4.执行以下命令，确认服务是否启动

    netstat -antup | grep ftp

    5.配置 vsftpd

    5.1.执行以下命令，为 FTP 服务创建一个 Linux 用户，本文以 ftpuser 为例。

    useradd ftpuser

    5.2.执行以下命令，设置 ftpuser 用户的密码

    passwd ftpuser

    5.3.执行以下命令，创建 FTP 服务使用的文件目录，本文以 /var/ftp/test 为例。

    mkdir /var/ftp/test

    5.4.执行以下命令，修改目录权限

    chown -R ftpuser:ftpuser /var/ftp/test

    5.6.执行以下命令，打开 vsftpd.conf 文件

    vim /etc/vsftpd/vsftpd.conf

    5.7.修改以下配置参数

    主动模式配置:

    1. anonymous_enable=NO
    2. local_enable=YES
    3. write_enable=YES
    4. chroot_local_user=YES
    5. chroot_list_enable=YES
    6. chroot_list_file=/etc/vsftpd/chroot_list
    7. listen=YES
    8. #listen_ipv6=YES

    被动模式配置:

    1. local_root=/var/ftp/test
    2. allow_writeable_chroot=YES
    3. pasv_enable=YES
    4. pasv_address=xxx.xx.xxx.xx #请修改为您的 Linux 云服务器公网 IP
    5. pasv_min_port=40000
    6. pasv_max_port=45000

     按Esc 后输入 :wq 保存后退出.

    5.8.执行以下命令，重启 FTP 服务。

    systemctl restart vsftpd

    安装教程参考如下地址:云服务器 Linux 云服务器搭建 FTP 服务-最佳实践-文档中心-腾讯云

    FTP客户端下载:FileZilla中文网 - 免费开源的FTP解决方案

    二、使用教程

    建立连接:

    1. //需要连接到的ftp端的ip
    2.     @Value(value = "${ftp.ip}")
    3.     private String ip;
    4.  
    5.     //连接端口，默认21
    6.     @Value(value = "${ftp.prot}")
    7.     private int port;
    8.  
    9.     //要连接到的ftp端的名字
    10.     @Value(value = "${ftp.username}")
    11.     private String name;
    12.  
    13.     //要连接到的ftp端的对应得密码
    14.     @Value(value = "${ftp.password}")
    15.     private String pwd;
    16.  
    17.     @Value(value = "${ftp.ftpUrl}")
    18.     private String ftpUrl;
    19.     //ftp对象
    20.     private FTPClient ftp;
    21.  
    22. /**
    23.      * 1.连接ftp
    24.      * 调用此方法，输入对应得ip，端口，要连接到的ftp端的名字，要连接到的ftp端的对应得密码。连接到ftp对象，并验证登录进入fto
    25.      */
    26.     public boolean ftp1() {
    27.         ftp = new FTPClient();
    28.         try {
    29.             if (!ftp.isConnected()) {
    30.                 ftp.connect(ip, port);
    31.             }
    32.             log.info("连接状态：" + ftp.login(name, pwd));
    33.  
    34.             ftp.setCharset(Charset.forName("UTF-8"));
    35.             ftp.setControlEncoding("UTF-8");
    36. //            ftp.enterLocalActiveMode();    //主动模式
    37.             ftp.enterLocalPassiveMode();        // 被动模式
    38.             return true;
    39.         } catch (IOException e) {
    40.             e.printStackTrace();
    41.         }
    42.         return false;
    43.     }
    44.  
    45.  public CommonResultVo threeDAndEightDReports() {
    46.         //抱怨单号、FTP地址、3D/8D文件类型
    47.         log.info("-------------ftpUrl地址：" + ip);
    48.         boolean flag = this.ftp1();  //1.连接FTP
    49.         if (flag) {
    50.             try {
    51.                 this.gmRead(ftpUrl); //2.获取文件、解析文件内容，进库操作
    52.                 this.disconnect();  //3. 关闭连接
    53.                 return CommonResultVo.failed("FTP数据发送MQ完成");
    54.             } catch (Exception e) {
    55.                 e.printStackTrace();
    56.             }
    57.         }
    58.         return CommonResultVo.failed("连接FTP失败");
    59.     }
    60.  /**
    61.      * 2.获取文件、解析文件内容，进库操作
    62.      */
    63.     public void gmRead(String ftpUrl) throws IOException {
    64.  
    65.         boolean downloadResult = false;
    66.         try {
    67.             ftp.changeWorkingDirectory(ftpUrl);
    68.             log.info("远程路径为*************************" + ftpUrl);
    69.  
    70.             FTPFile[] files = ftp.listFiles(ftpUrl); // 通过路径得到文件
    71.             log.info("文件数量为*************************" + files.length);
    72.  
    73.             for (int i = 0; i < files.length; i++) {
    74.                 FTPFile file = files[i];
    75.                 if (file.isFile()) {
    76. //                    downloadResult = this.download(file);// 下载文件 到本地读取路径
    77. //                    this.downloadFtpFile(file);
    78.                     new FTPDownload().downloadToFileAll(ftp, ftpUrl);
    79.                 } else {
    80.                     log.info("************* 文件不存在 ************");
    81.                 }
    82.             }
    83.  
    84.         } catch (Exception e) {
    85.             e.printStackTrace();
    86.         }
    87.     }

    文件下载:

    1. import static com.cetc.service.impl.MessageServicesImpl.pathStr;
    2.  
    3. /**
    4.  * @author ：jerry
    5.  * @date ：Created in 2022/10/25 11:04
    6.  * @description：FTP文件下载
    7.  * @version: V1.1
    8.  */
    9. @Slf4j
    10. public class FTPDownload {
    11.  
    12.     //下载存放路径
    13.     public static final String pathStr = Paths.get("upload").toAbsolutePath().toString();
    14.     private FTPClient ftp;
    15.  
    16.     /**
    17.      * 1.普通下载
    18.      */
    19.     public synchronized void downloadToFile(FTPClient ftp, String pathname, String filename) throws IOException {
    20.         //删除文件
    21.         File directory = new File(pathStr);
    22.         Files.walk(directory.toPath()).filter(Files::isRegularFile).map(Path::toFile).forEach(File::delete);
    23.         log.info("删除"+pathStr+"目录下的所有历史文件成功");
    24.  
    25.         try {
    26.             this.ftp = ftp;
    27.             //切换FTP目录
    28.             ftp.setFileType(FTP.BINARY_FILE_TYPE);
    29.             ftp.changeWorkingDirectory(pathname);
    30.             FTPFile[] ftpFiles = ftp.listFiles();
    31.             for (FTPFile file : ftpFiles) {
    32.                 if (filename.equalsIgnoreCase(file.getName())) {
    33.                     File localFile = new File(pathStr + "/" + filename);
    34.                     OutputStream is = new FileOutputStream(localFile);
    35.                     ftp.retrieveFile(file.getName(), is);
    36.                     is.close();
    37.                     break;
    38.                 }
    39.             }
    40.             ftp.logout();
    41.             log.info("下载文件成功");
    42.         } catch (Exception e) {
    43.             log.error("下载文件失败");
    44.             e.printStackTrace();
    45.         } finally {
    46.             if (ftp.isConnected()) {
    47.                 try {
    48.                     ftp.disconnect();
    49.                 } catch (IOException e) {
    50.                     e.printStackTrace();
    51.                 }
    52.             }
    53.         }
    54.     }
    55.  
    56.     /**
    57.      * 2.字节流的形式下载文件
    58.      */
    59.     public ByteArrayOutputStream byteDownloadZip(FTPClient ftp, FTPFile filePath) {
    60.         this.ftp = ftp;
    61.         ByteArrayOutputStream bos = null;
    62.         try {
    63.             //切换FTP目录
    64.             ftp.setFileType(FTP.BINARY_FILE_TYPE);
    65.             ftp.changeWorkingDirectory(pathStr);
    66.             FTPFile[] ftpFiles = ftp.listFiles();
    67.             String filename = filePath.getName();
    68.             for (FTPFile file : ftpFiles) {
    69.                 if (filename.equalsIgnoreCase(file.getName())) {
    70.                     InputStream is = ftp.retrieveFileStream(filename);
    71.                     bos = new ByteArrayOutputStream();
    72.                     int len = 0;
    73.                     byte[] buffer = new byte[1024];
    74.                     while ((len = is.read(buffer)) > 0) {
    75.                         bos.write(buffer, 0, len);
    76.                     }
    77.                     bos.flush();
    78.                     bos.close();
    79.                     is.close();
    80.                     ftp.completePendingCommand();
    81.                     break;
    82.                 }
    83.             }
    84.             ftp.logout();
    85.             log.info("下载文件成功");
    86.         } catch (Exception e) {
    87.             log.error("下载文件失败");
    88.             e.printStackTrace();
    89.         } finally {
    90.             if (ftp.isConnected()) {
    91.                 try {
    92.                     ftp.disconnect();
    93.                 } catch (IOException e) {
    94.                     e.printStackTrace();
    95.                 }
    96.             }
    97.         }
    98.         System.out.println(bos);
    99.         return bos;
    100.  
    101.     }
    102.  
    103.     /**
    104.      * 下载全部FTP文件目录文件
    105.      * */
    106.     public synchronized void downloadToFileAll(FTPClient ftp, String pathname) {
    107.         try {
    108.             this.ftp = ftp;
    109.             //切换FTP目录
    110.             ftp.setFileType(FTP.BINARY_FILE_TYPE);
    111.             ftp.changeWorkingDirectory(pathname);
    112.             FTPFile[] ftpFiles = ftp.listFiles();
    113.             for (FTPFile file : ftpFiles) {
    114.                 String filename = file.getName();
    115.                 log.info("filename:"+filename);
    116.                 File localFile = new File(pathStr + "/" + filename);
    117.                 OutputStream is = new FileOutputStream(localFile);
    118.                 ftp.retrieveFile(file.getName(), is);
    119.                 is.close();
    120.             }
    121.             ftp.logout();
    122.             log.info("下载文件成功");
    123.         } catch (Exception e) {
    124.             log.error("下载文件失败");
    125.             e.printStackTrace();
    126.         } finally {
    127.             if (ftp.isConnected()) {
    128.                 try {
    129.                     ftp.disconnect();
    130.                 } catch (IOException e) {
    131.                     e.printStackTrace();
    132.                 }
    133.             }
    134.         }
    135.     }
    136.  
    137. }
    1.  
    2. import lombok.Builder;
    3. import lombok.Getter;
    4. import lombok.Setter;
    5.  
    6.  
    7. @Getter
    8. @Setter
    9. @Builder
    10. public class CommonResultVo {
    11.  
    12.     private int code;
    13.     private String message;
    14.     private T data;
    15.  
    16.     protected CommonResultVo() {
    17.     }
    18.  
    19.     protected CommonResultVo(int code, String message, T data) {
    20.         this.code = code;
    21.         this.message = message;
    22.         this.data = data;
    23.     }
    24.  
    25.     /**
    26.      * 成功返回结果
    27.      *
    28.      */
    29.     public static  CommonResultVo success() {
    30.         return new CommonResultVo(ResultCode.SUCCESS.getCode(), ResultCode.SUCCESS.getMessage(), null);
    31.     }
    32.  
    33.     /**
    34.      * 成功返回结果
    35.      *
    36.      * @param data 获取的数据
    37.      */
    38.     public static  CommonResultVo success(T data) {
    39.         return new CommonResultVo(ResultCode.SUCCESS.getCode(), ResultCode.SUCCESS.getMessage(), data);
    40.     }
    41.  
    42.     /**
    43.      * 成功返回结果
    44.      *
    45.      * @param data 获取的数据
    46.      * @param  message 提示信息
    47.      */
    48.     public static  CommonResultVo success(T data, String message) {
    49.         return new CommonResultVo(ResultCode.SUCCESS.getCode(), message, data);
    50.     }
    51.  
    52.     /**
    53.      * 失败返回结果
    54.      * @param resultCode 错误码
    55.      */
    56.     public static  CommonResultVo failed(ResultCode resultCode) {
    57.         return new CommonResultVo(resultCode.getCode(), resultCode.getMessage(), null);
    58.     }
    59.  
    60.     /**
    61.      * 失败返回结果
    62.      * @param resultCode 错误码
    63.      * @param message 错误信息
    64.      */
    65.     public static  CommonResultVo failed(ResultCode resultCode, String message) {
    66.         return new CommonResultVo(resultCode.getCode(), message, null);
    67.     }
    68.  
    69.     /**
    70.      * 失败返回结果
    71.      * @param message 提示信息
    72.      */
    73.     public static  CommonResultVo failed(String message) {
    74.         return new CommonResultVo(ResultCode.FAILED.getCode(), message, null);
    75.     }
    76.  
    77.     /**
    78.      * 失败返回结果
    79.      */
    80.     public static  CommonResultVo failed() {
    81.         return failed(ResultCode.FAILED);
    82.     }
    83. }

     

    1. import lombok.Getter;
    2. import lombok.Setter;
    3.  
    4.  
    5. public enum ResultCode {
    6.     SUCCESS(0, "操作成功"),
    7.     FAILED(-1, "操作失败"),
    8.     VALIDATE_FAILED(404, "参数检验失败"),
    9.     UNAUTHORIZED(401, "暂未登录或token已经过期"),
    10.     FORBIDDEN(403, "没有相关权限");
    11.  
    12.     @Setter
    13.     @Getter
    14.     private int code;
    15.  
    16.     @Setter
    17.     @Getter
    18.     private String message;
    19.  
    20.     private ResultCode(int code, String message) {
    21.         this.code = code;
    22.         this.message = message;
    23.     }
    24.  
    25.  
    26. }

    yml配置如下:

    1. #个人测试
    2. ftp:
    3.   ip: 10.10.10.121   #IP
    4.   prot: 21  #端口
    5.   ftpUrl: /   #文件路径
    6.   username: ftpuser   #用户名
    7.   password: 123456   #密码

     

    注意:

    ftp.changeWorkingDirectory(pathname);    //是切换到你的文件所在的目录,如果文件不在根目录,下载下来可能为0kb

  • 相关阅读:
    【一】【SQL】表的增删查改（部分）
    两道ospf 网络优化题目解析
    面试：gradle添加自定义task
    多维数组求和函数
    Konva事件机制
    重构从现在开始
    【Django】聚合查询——连接和聚合
    Leetcode2-AddTwoNumbers
    全志H616开发版
    物业系统自主研发接口测试框架
  • 原文地址：https://blog.csdn.net/qq_40068304/article/details/127846100