使用FTP连接池在Ubuntu服务器上实现文件上传与播放

使用FTP连接池在Ubuntu服务器上实现文件上传与播放

在开发应用程序时，我们经常需要与服务器进行文件交互，比如上传文件或从服务器获取文件进行播放。这篇博客将介绍如何在Ubuntu服务器使用FTP连接池来高效地处理文件上传和播放。在Ubuntu系统搭建FTP服务器可以参考这篇博客（https://blog.csdn.net/weixin_52799373/article/details/131045373）

1.添加FTP连接池依赖

为了实现FTP连接池，首先要在项目中引入以下两个Apache Commons库：

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.11.1</version>
        </dependency>
        <dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.8.0</version>
        </dependency>
1
2
3
4
5
6
7
8
9
10

这两个库提供了FTP连接管理和FTP客户端功能。

2.配置FTP连接池

创建一个FTPClientPoolableFactory类，该类继承自BasePooledObjectFactory，并实现FTP客户端的创建、销毁和验证方法。同时，从application.yml文件中读取FTP服务器的配置信息。

• yml配置信息

record:
  uftp:
    host: 127.0.0.1
    port: 21
    username: uftp
    password: root
    remoteDir: /data/liss/data/
1
2
3
4
5
6
7

• FTPClientPoolableFactory工厂类配置

  /**
   * @Description:FTP客户端池化对象工厂
   * @Author: yange
   * @Date: 2024/5/6 15:56
   */
  @Component
  @Slf4j
  public class FTPClientPoolableFactory extends BasePooledObjectFactory<FTPClient> {
      @Value("${record.uftp.host}")
      private String host;
  
      @Value("${record.uftp.port}")
      private int port;
  
      @Value("${record.uftp.username}")
      private String username;
  
      @Value("${record.uftp.password}")
      private String password;
  
      @Value("${record.uftp.remoteDir}")
      private String remoteDir;
  
  
      @Override
      public FTPClient create(){
          FTPClient ftpClient = new FTPClient();
          try {
              ftpClient.setConnectTimeout(60000);
              ftpClient.connect(host, port);
              if (!ftpClient.login(username, password)) {
                  log.warn("ftpClient 登录失败： " + username + password);
                  return null;
              }
              // 设置被动模式，文件传输端口设置
              ftpClient.enterLocalPassiveMode();
              //文件类型
              ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
              //切换目录
              if (!ftpClient.changeWorkingDirectory(remoteDir)) {
                  ftpClient.makeDirectory(remoteDir);
                  ftpClient.changeWorkingDirectory(remoteDir);
              }
          } catch (IOException e) {
              log.error("FtpClient 创建错误： " + e.getMessage());
          }
          return ftpClient;
      }
  
      /**
       * 用PooledObject封装对象放入池中
       */
      @Override
      public PooledObject<FTPClient> wrap(FTPClient ftpClient) {
          return new DefaultPooledObject<>(ftpClient);
      }
  
      /**
       * 销毁FtpClient对象
       */
      @Override
      public void destroyObject(PooledObject<FTPClient> ftpPooled) {
          if (ftpPooled == null) {
              return;
          }
          FTPClient ftpClient = ftpPooled.getObject();
          try {
              if (ftpClient.isConnected()) {
                  ftpClient.logout();
              }
          } catch (Exception io) {
              log.error("销毁FtpClient错误..." + io.getMessage());
          } finally {
              try {
                  ftpClient.disconnect();
              } catch (IOException io) {
                  log.error("销毁FtpClient错误..." + io.getMessage());
              }
          }
      }
      /**
       * 验证FtpClient对象
       */
      @Override
      public boolean validateObject(PooledObject<FTPClient> ftpPooled) {
          try {
              FTPClient ftpClient = ftpPooled.getObject();
              return ftpClient.sendNoOp();
          } catch (IOException e) {
              log.error("验证FtpClient对象错误: " + e.getMessage());
          }
          return false;
      }
  
  }
  
  1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22
  23
  24
  25
  26
  27
  28
  29
  30
  31
  32
  33
  34
  35
  36
  37
  38
  39
  40
  41
  42
  43
  44
  45
  46
  47
  48
  49
  50
  51
  52
  53
  54
  55
  56
  57
  58
  59
  60
  61
  62
  63
  64
  65
  66
  67
  68
  69
  70
  71
  72
  73
  74
  75
  76
  77
  78
  79
  80
  81
  82
  83
  84
  85
  86
  87
  88
  89
  90
  91
  92
  93
  94
  95
  96

  这里需要注意 在设置被动模式ftpClient.enterLocalPassiveMode();如果没有在云服务器开启端口组，就会报Connection timed out: connect 这个错误，如果是Windows系统上传下载不加也可以，但是如果上传到Linux服务器就会发现上传失败。这时候开启被动模式就很有必要。官方的解释

  在使用FTP传输文件时，特别是当涉及到云服务器或有严格防火墙规则的网络环境时，  选择正确的数据
  传输模式至关重要。
  FTP提供两种模式：主动模式（PORT）和被动模式（PASV）。这两种模式主要区别在于客户端和服务器如何
  建立用于传输数据的连接。
  主动模式（PORT）
  在主动模式下，客户端首先连接到FTP服务器的21号控制端口。然后，客户端告知服务
  器其本地端口号，服务器尝试连接到这个指定的端口来传输数据。然而，这种方法可能会在客户端和服务器
  之间存在防火墙或NAT设备时遇到问题，因为服
  1
  2
  3
  4
  5
  6
  7