feat: 支持连接相关配置

Author: meethigher

README.md

@@ -1,3 +1,5 @@
+Note: This project is for personal learning only. Please use [Apache FtpServer 1.2.0 Release — Apache MINA](https://mina.apache.org/ftpserver-project/download_1_2.html) for production environment.
+
 ![image-20240421225808979](README/image-20240421225808979.png)
 
 # Introduction
@@ -17,11 +19,17 @@ java -jar ftp-server.jar
 you can configure ftp by configuring **server.properties**.
 
 ```properties
-port=201
-idleSeconds=501
-activeLocalPort=202
+port=21
+idleSeconds=60
+activeLocalPort=20
 passivePorts=30000-30005
-web.enable=true
+anonymousLoginEnabled=true
+loginFailureDelay=500
+maxLogins=1000
+maxAnonymousLogins=2
+maxLoginFailures=3
+maxThreads=0
+web.enable=false
 web.port=8080
 web.username=admin
 web.password=admin

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>top.meethigher</groupId>
     <artifactId>ftp-server</artifactId>
-    <version>1.3</version>
+    <version>1.3.1</version>
     <properties>
         <project.name>ftp-server</project.name>
         <maven.compiler.source>8</maven.compiler.source>

server.properties

@@ -1,8 +1,14 @@
-port=201
-idleSeconds=501
-activeLocalPort=202
+port=21
+idleSeconds=60
+activeLocalPort=20
 passivePorts=30000-30005
-web.enable=true
+anonymousLoginEnabled=true
+loginFailureDelay=500
+maxLogins=1000
+maxAnonymousLogins=2
+maxLoginFailures=3
+maxThreads=0
+web.enable=false
 web.port=8080
 web.username=admin
 web.password=admin

src/main/java/top/meethigher/ftp/server/Server.java

@@ -1,6 +1,7 @@
 package top.meethigher.ftp.server;
 
 
+import org.apache.ftpserver.ConnectionConfig;
 import org.apache.ftpserver.ftplet.UserManager;
 import org.apache.ftpserver.listener.Listener;
 import org.apache.ftpserver.usermanager.impl.BaseUser;
@@ -21,8 +22,8 @@ public void run() throws Exception {
         List<BaseUser> baseUserList = baseUserList();
         UserManager um = userManager(baseUserList);
         Listener listener = listener(ftpServerProperties);
-
-        AuditFtpServer ftpServer = ftpServer(listener, um);
+        ConnectionConfig connectionConfig = connectionConfig(ftpServerProperties);
+        AuditFtpServer ftpServer = ftpServer(listener, um, connectionConfig);
         ftpServer.start();
         if (ftpServerProperties.isWebEnable()) {
             WebServer webServer = new WebServer(ftpServerProperties, ftpServer);

src/main/java/top/meethigher/ftp/server/config/FTPServerProperties.java

@@ -59,6 +59,36 @@ public class FTPServerProperties {
      */
     private boolean webEnable = true;
 
+    /**
+     * 最大登录数
+     */
+    private int maxLogins = 10;
+
+    /**
+     * 启用匿名登录
+     */
+    private boolean anonymousLoginEnabled = true;
+
+    /**
+     * 最大匿名登录数
+     */
+    private int maxAnonymousLogins = 10;
+
+    /**
+     * 最大登录失败数
+     */
+    private int maxLoginFailures = 3;
+
+    /**
+     * 登录失败延迟
+     */
+    private int loginFailureDelay = 500;
+
+    /**
+     * 最大线程
+     */
+    private int maxThreads = 0;
+
 
     public int getPort() {
         return port;
@@ -123,4 +153,52 @@ public boolean isWebEnable() {
     public void setWebEnable(boolean webEnable) {
         this.webEnable = webEnable;
     }
+
+    public int getMaxLogins() {
+        return maxLogins;
+    }
+
+    public void setMaxLogins(int maxLogins) {
+        this.maxLogins = maxLogins;
+    }
+
+    public boolean isAnonymousLoginEnabled() {
+        return anonymousLoginEnabled;
+    }
+
+    public void setAnonymousLoginEnabled(boolean anonymousLoginEnabled) {
+        this.anonymousLoginEnabled = anonymousLoginEnabled;
+    }
+
+    public int getMaxAnonymousLogins() {
+        return maxAnonymousLogins;
+    }
+
+    public void setMaxAnonymousLogins(int maxAnonymousLogins) {
+        this.maxAnonymousLogins = maxAnonymousLogins;
+    }
+
+    public int getMaxLoginFailures() {
+        return maxLoginFailures;
+    }
+
+    public void setMaxLoginFailures(int maxLoginFailures) {
+        this.maxLoginFailures = maxLoginFailures;
+    }
+
+    public int getLoginFailureDelay() {
+        return loginFailureDelay;
+    }
+
+    public void setLoginFailureDelay(int loginFailureDelay) {
+        this.loginFailureDelay = loginFailureDelay;
+    }
+
+    public int getMaxThreads() {
+        return maxThreads;
+    }
+
+    public void setMaxThreads(int maxThreads) {
+        this.maxThreads = maxThreads;
+    }
 }

src/main/java/top/meethigher/ftp/server/utils/FTPServerUtils.java

@@ -1,10 +1,13 @@
 package top.meethigher.ftp.server.utils;
 
+import org.apache.ftpserver.ConnectionConfig;
 import org.apache.ftpserver.DataConnectionConfigurationFactory;
 import org.apache.ftpserver.FtpServer;
 import org.apache.ftpserver.FtpServerFactory;
 import org.apache.ftpserver.ftplet.Authority;
 import org.apache.ftpserver.ftplet.UserManager;
+import org.apache.ftpserver.impl.DefaultConnectionConfig;
+import org.apache.ftpserver.impl.DefaultDataConnectionConfiguration;
 import org.apache.ftpserver.listener.Listener;
 import org.apache.ftpserver.usermanager.impl.BaseUser;
 import org.apache.ftpserver.usermanager.impl.ConcurrentLoginPermission;
@@ -105,6 +108,12 @@ public static FTPServerProperties ftpServerProperties() {
             p.setIdleSeconds(properties.getInteger("idleSeconds", p.getIdleSeconds()));
             p.setActiveLocalPort(properties.getInteger("activeLocalPort", p.getActiveLocalPort()));
             p.setPassivePorts(properties.getString("passivePorts", p.getPassivePorts()));
+            p.setAnonymousLoginEnabled(properties.getBoolean("anonymousLoginEnabled", p.isAnonymousLoginEnabled()));
+            p.setLoginFailureDelay(properties.getInteger("loginFailureDelay", p.getLoginFailureDelay()));
+            p.setMaxLogins(properties.getInteger("maxLogins", p.getMaxLogins()));
+            p.setMaxAnonymousLogins(properties.getInteger("maxAnonymousLogins", p.getMaxAnonymousLogins()));
+            p.setMaxLoginFailures(properties.getInteger("maxLoginFailures", p.getMaxLoginFailures()));
+            p.setMaxThreads(properties.getInteger("maxThreads", p.getMaxThreads()));
             p.setWebPort(properties.getInteger("web.port", p.getWebPort()));
             p.setWebUsername(properties.getString("web.username", p.getWebUsername()));
             p.setWebPassword(properties.getString("web.password", p.getWebPassword()));
@@ -180,6 +189,11 @@ public static Listener listener(FTPServerProperties p) {
         return listenerFactory.createListener();
     }
 
+    public static ConnectionConfig connectionConfig(FTPServerProperties p) {
+        return new DefaultConnectionConfig(p.isAnonymousLoginEnabled(), p.getLoginFailureDelay(),
+                p.getMaxLogins(), p.getMaxAnonymousLogins(), p.getMaxLoginFailures(), p.getMaxThreads());
+    }
+
     public static UserManager userManager(List<BaseUser> list) {
         MemoryPropertiesUserManagerFactory propertiesUserManagerFactory = new MemoryPropertiesUserManagerFactory();
         UserManager um = propertiesUserManagerFactory.createUserManager();
@@ -193,8 +207,10 @@ public static UserManager userManager(List<BaseUser> list) {
     }
 
     public static AuditFtpServer ftpServer(Listener listener,
-                                           UserManager userManager) {
+                                           UserManager userManager, ConnectionConfig connectionConfig) {
         AuditFtpServerFactory serverFactory = new AuditFtpServerFactory();
+        // 配置连接限制
+        serverFactory.setConnectionConfig(connectionConfig);
         //请不要移除default
         serverFactory.addListener("default", listener);
         serverFactory.setUserManager(userManager);

src/main/resources/logback.xml

@@ -4,7 +4,7 @@
     <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
         <Target>System.out</Target>
         <encoder>
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${PID} --- [%15.15t] %-40.40logger{39} : %msg%n%ex{5}</pattern>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${PID} --- [%15.15t] : %msg%n%ex{5}</pattern>
             <charset>utf-8</charset>
         </encoder>
     </appender>
@@ -19,7 +19,7 @@
         </rollingPolicy>
         <append>true</append>
         <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${PID} --- [%15.15t] %-40.40logger{39} : %msg%n%ex{5}</pattern>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${PID} --- [%15.15t] : %msg%n%ex{5}</pattern>
             <charset>utf-8</charset>
         </encoder>
     </appender>

users/ftpadmin.properties

@@ -4,8 +4,8 @@ password=ftpadmin
 maxUploadRate=1024000
 name=ftpadmin
 maxDownloadRate=1024000
-maxConcurrentLoginsPerIP=1
+maxConcurrentLoginsPerIP=1000
 write=/ccc-test
-maxConcurrentLogins=5
+maxConcurrentLogins=5000
 enabled=true
-homeDir=C\:/Users/meethigher/Desktop
+homeDir=D:/Desktop/ftpadmin