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