sftp做成一个池子
创始人
2024-11-14 17:06:44
0

前言:开发中的需求要去对方的 ftp 服务器下载文件,这里下载文件采用 ftp 方式,下载之后程序再去解析文件的内容,然后再存数据库。下载过来的文件默认是 zip 格式,需要解压 unzip 一下,然后里面有一个 csv 文件,用 easyecel 读取 csv 中的数据,至此需求梳理完成。这里每次取下载或者操作 ftp 的时候都要新建一个连接,用完再主动关闭,这里并未复用此连接,相当于说每次都是新建一个连接,这样不好,因此对这里进行设计改造。

引入 pom 依赖

                              com.jcraft             jsch             0.1.55                                        org.apache.commons             commons-pool2             2.6.1           

定义yml文件配置信息

sftp:   mft:     sftp-host: 101.233.389.58     sftp-port: 80219     sftp-username: user     sftp-password: 789678     sftp-path: /file/mft     save-path: /mft     pool:      max-total: 10      max-idle: 10      min-idle: 5  

定义配置属性SftpProperties 信息

读取yml中的属性信息,注意@ConfigurationProperties(prefix = "sftp.mft")注解是定义属性,下面的
sftpHost属性就读取到了yml文件中配置的信息,但是类中的maxTotal和yml文件中的max-total是怎么映射的呢?注意看yml中有一个pool下面 类中有一个private Pool pool = new Pool();pool改个名字就从yml文件点不进来了,说明是根据此来映射的

package x.x.config.sftpPool;  import com.jcraft.jsch.ChannelSftp; import lombok.Data; import org.apache.commons.pool2.impl.GenericObjectPoolConfig; import org.springframework.boot.context.properties.ConfigurationProperties;   @Data @ConfigurationProperties(prefix = "sftp.mft") public class SftpProperties {         private String sftpHost;     private int sftpPort;     private String sftpUsername;     private String sftpPassword;     private String sftpPath;     private String savePath;      private Pool pool = new Pool();     public static class Pool extends GenericObjectPoolConfig {             private int maxTotal = DEFAULT_MAX_TOTAL;         private int maxIdle = DEFAULT_MAX_IDLE;         private int minIdle = DEFAULT_MIN_IDLE;         public Pool() {                 super();         }         @Override         public int getMaxTotal() {                 return maxTotal;         }         @Override         public void setMaxTotal(int maxTotal) {                 this.maxTotal = maxTotal;         }         @Override         public int getMaxIdle() {                 return maxIdle;         }         @Override         public void setMaxIdle(int maxIdle) {                 this.maxIdle = maxIdle;         }         @Override         public int getMinIdle() {                 return minIdle;         }         @Override         public void setMinIdle(int minIdle) {                 this.minIdle = minIdle;         }     } } 

定义工厂类

生产sftp连接,获取上一步定义好的属性 SftpProperties 实现三个方法,create方法创建连接

package x.x.config.sftpPool;  import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.JSch; import<

相关内容

热门资讯

推荐开挂!wepoker底牌透... 推荐开挂!wepoker底牌透视脚本,星悦山东辅助,开挂(透视)辅助工具(有挂工具);wepoker...
分享辅助!拱趴游戏破解器,微信... 分享辅助!拱趴游戏破解器,微信新九游辅助,开挂(透视)辅助安装(有挂详细);1、这是跨平台的微信新九...
科技开挂!约局吧德州透视,微乐... 科技开挂!约局吧德州透视,微乐福建辅助器,开挂(透视)辅助脚本(有挂攻略)相信很多朋友都在电脑上玩过...
分享辅助!wepoker辅助器... 分享辅助!wepoker辅助器安装包,大菠萝辅助器,开挂(透视)辅助脚本(有挂技术);1、不需要AI...
发现辅助!来玩app 德州 辅... 发现辅助!来玩app 德州 辅助,兴动互娱辅助工具如何下载,开挂(透视)辅助神器(有挂教学);1、很...
分析开挂!hhpoker透视方... 分析开挂!hhpoker透视方法,广西友乐软件辅助,开挂(透视)辅助脚本(有挂解密);1、这是跨平台...
科技开挂!红龙poker有辅助... 科技开挂!红龙poker有辅助吗,微信小程序卡五星辅助器,开挂(透视)辅助下载(有挂解密);最新版2...
正品开挂!wepoker代打辅... 正品开挂!wepoker代打辅助机器人,小闲川南斗十四辅助,开挂(透视)辅助平台(有挂规律);一、小...
正品开挂!wepoker怎么买... 正品开挂!wepoker怎么买辅助,闲逸辅助插件,开挂(透视)辅助工具(果真有挂);1.闲逸辅助插件...
分享辅助!hhpoker可以控... 分享辅助!hhpoker可以控制吗,八闽掌上十八卦脚本,开挂(透视)辅助下载(有挂方法);1、这是跨...