1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
package org.openslx.satellitedaemon.ftp;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import org.apache.ftpserver.ConnectionConfigFactory;
import org.apache.ftpserver.FtpServer;
import org.apache.ftpserver.FtpServerFactory;
import org.apache.ftpserver.ftplet.Authority;
import org.apache.ftpserver.ftplet.FtpException;
import org.apache.ftpserver.ftplet.UserManager;
import org.apache.ftpserver.listener.ListenerFactory;
import org.apache.ftpserver.usermanager.PropertiesUserManagerFactory;
import org.apache.ftpserver.usermanager.SaltedPasswordEncryptor;
import org.apache.ftpserver.usermanager.impl.BaseUser;
import org.apache.ftpserver.usermanager.impl.WritePermission;
/**
* FTP-Test-Utility, basierend auf Apache FtpServer: {@link http
* ://www.jarvana.com
* /jarvana/view/org/apache/ftpserver/ftpserver-core/1.0.6/ftpserver
* -core-1.0.6-javadoc.jar!/org/apache/ftpserver/FtpServer.html}
*/
public class FtpTestUtil {
/**
* Erzeuge FTP-Server.
*
* @param ftpPort
* FTP-Port, z.B. 2121
* @param ftpHomeDir
* FTP-Verzeichnis, z.B. "target/FtpHome"
* @param readUserName
* leseberechtigter Benutzer: Name
* @param readUserPwd
* leseberechtigter Benutzer: Passwort
* @param writeUserName
* schreibberechtigter Benutzer: Name
* @param writeUserPwd
* schreibberechtigter Benutzer: Passwort
* @param ftpUsersPropsFile
* kann null sein, oder z.B. "target/FtpUsers.properties"
* @param maxLogins
* maximale Anzahl von Logins (0 fuer Defaultwert)
*/
public static FtpServer createFtpServer(int ftpPort, String ftpHomeDir,
String readUserName, String readUserPwd, String writeUserName,
String writeUserPwd) throws FtpException, IOException {
return createFtpServer(ftpPort, ftpHomeDir, readUserName, readUserPwd,
writeUserName, writeUserPwd, null, 0);
}
public static FtpServer createFtpServer(int ftpPort, String ftpHomeDir,
String readUserName, String readUserPwd, String writeUserName,
String writeUserPwd, String ftpUsersPropsFile, int maxLogins)
throws FtpException, IOException {
return createFtpServer(ftpPort, ftpHomeDir, readUserName, readUserPwd,
writeUserName, writeUserPwd, ftpUsersPropsFile, maxLogins, 0);
}
public static FtpServer createFtpServer(int ftpPort, String ftpHomeDir,
String readUserName, String readUserPwd, String writeUserName,
String writeUserPwd, String ftpUsersPropsFile, int maxLogins,
int maxIdleTimeSec) throws FtpException, IOException {
File fhd = new File(ftpHomeDir);
if (!fhd.exists())
fhd.mkdirs();
ListenerFactory listenerFactory = new ListenerFactory();
listenerFactory.setPort(ftpPort);
PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory();
userManagerFactory.setPasswordEncryptor(new SaltedPasswordEncryptor());
if (ftpUsersPropsFile != null && ftpUsersPropsFile.trim().length() > 0) {
File upf = new File(ftpUsersPropsFile);
if (!upf.exists())
upf.createNewFile();
userManagerFactory.setFile(upf);
}
// Einen Nur-Lese-User und einen User mit Schreibberechtigung anlegen:
UserManager userManager = userManagerFactory.createUserManager();
BaseUser userRd = new BaseUser();
BaseUser userWr = new BaseUser();
userRd.setName(readUserName);
userRd.setPassword(readUserPwd);
userRd.setHomeDirectory(ftpHomeDir);
userWr.setName(writeUserName);
userWr.setPassword(writeUserPwd);
userWr.setHomeDirectory(ftpHomeDir);
if (maxIdleTimeSec > 0) {
userRd.setMaxIdleTime(maxIdleTimeSec);
userWr.setMaxIdleTime(maxIdleTimeSec);
}
ArrayList<Authority> authorities = new ArrayList<Authority>();
authorities.add(new WritePermission());
userWr.setAuthorities(authorities);
userManager.save(userRd);
userManager.save(userWr);
FtpServerFactory serverFactory = new FtpServerFactory();
serverFactory.addListener("default", listenerFactory.createListener());
serverFactory.setUserManager(userManager);
if (maxLogins > 0) {
ConnectionConfigFactory ccf = new ConnectionConfigFactory();
ccf.setMaxLogins(maxLogins);
serverFactory.setConnectionConfig(ccf.createConnectionConfig());
}
return serverFactory.createServer();
}
}
|
