使用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> 

这两个库提供了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/ 

• 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;     }  }  

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

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