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