在Spring-Boot中嵌入一个ftp的server服务

2018年10月17日11:50:33 发表评论 2,651 views

摘要

文件传输协议（英文：File Transfer Protocol，缩写：FTP）是用于在网络上进行文件传输的一套标准协议，使用客户/服务器模式。它属于网络传输协议的应用层。文件传送（file transfer）和文件访问（file access）之间的区别在于：前者由FTP提供，后者由如NFS等应用系统提供。

ftp的数据交互中存在两种模式，一种是port(主动模式)，另一种是pasv(被动模式)。

我在这里定义了两个class：FtpServer和RealUsermanager；前者用于ftp服务相关的配置，后者用于用户的动态增加。

maven依赖

<dependency>
    <groupId>org.apache.ftpserver</groupId>
    <artifactId>ftpserver-core</artifactId>
    <version>1.1.1</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<groupId>org.apache.ftpserver</groupId>

<artifactId>ftpserver-core</artifactId>

</exclusion>

</exclusions>

</dependency>

FtpServer

在启动设置中我主要设置了ftp的连接参数，本地监听参，数据传输模式。

public boolean startService(){
//连接设置
ConnectionConfigFactory configFactory = new ConnectionConfigFactory();
configFactory.setAnonymousLoginEnabled(false);
configFactory.setMaxAnonymousLogins(0);
configFactory.setMaxLoginFailures(5);
configFactory.setLoginFailureDelay(30);
configFactory.setMaxThreads(10);
configFactory.setMaxLogins(10);

//监听设置
ListenerFactory factory = new ListenerFactory();
factory.setPort(this.port);
factory.setIdleTimeout(60);

//数据传输模式设置
DataConnectionConfigurationFactory dccFactory = new DataConnectionConfigurationFactory();
// dccFactory.setActiveLocalPort(10000); //主动模式使用的端口
dccFactory.setPassiveIpCheck(true);
dccFactory.setPassivePorts(passivePorts); //被动模式使用的端口范围
DataConnectionConfiguration dcc=dccFactory.createDataConnectionConfiguration();
factory.setDataConnectionConfiguration(dcc);

//实例化ftpServer工厂
FtpServerFactory serverFactory = new FtpServerFactory();
serverFactory.addListener("default",factory.createListener());
serverFactory.setUserManager(this.um.getUm());
serverFactory.setConnectionConfig(configFactory.createConnectionConfig());

ftpServer = serverFactory.createServer();

try{
    //启动ftpServer
    ftpServer.start();
}catch (FtpException e){
    return false;
}
return true;
}

public boolean startService(){

//连接设置

ConnectionConfigFactory configFactory = new ConnectionConfigFactory();

configFactory.setAnonymousLoginEnabled(false);

configFactory.setMaxAnonymousLogins(0);

configFactory.setMaxLoginFailures(5);

configFactory.setLoginFailureDelay(30);

configFactory.setMaxThreads(10);

configFactory.setMaxLogins(10);

//监听设置

ListenerFactory factory = new ListenerFactory();

factory.setPort(this.port);

factory.setIdleTimeout(60);

//数据传输模式设置

DataConnectionConfigurationFactory dccFactory = new DataConnectionConfigurationFactory();

// dccFactory.setActiveLocalPort(10000); //主动模式使用的端口

dccFactory.setPassiveIpCheck(true);

dccFactory.setPassivePorts(passivePorts); //被动模式使用的端口范围

DataConnectionConfiguration dcc=dccFactory.createDataConnectionConfiguration();

factory.setDataConnectionConfiguration(dcc);

//实例化ftpServer工厂

FtpServerFactory serverFactory = new FtpServerFactory();

serverFactory.addListener("default",factory.createListener());

serverFactory.setUserManager(this.um.getUm());

serverFactory.setConnectionConfig(configFactory.createConnectionConfig());

ftpServer = serverFactory.createServer();

try{

//启动ftpServer

ftpServer.start();

}catch (FtpException e){

return false;

}

return true;

}

RealUserManager

创建用户管理器

PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory();
//创建用户管理器
um = userManagerFactory.createUserManager();

PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory();

//创建用户管理器

um = userManagerFactory.createUserManager();

添加用户

if(!um.doesExist(username)){
    List<Authority> authorities = new ArrayList<>();
    //设置用户权限
    authorities.add(new WritePermission());
    authorities.add(new ConcurrentLoginPermission(0, 0));
    BaseUser user = new BaseUser();
    user.setName(username);
    user.setPassword(password);
    //设置用户主目录
    user.setHomeDirectory(homeDir);
    user.setMaxIdleTime(60);
    user.setAuthorities(authorities);
    um.save(user);
}