我想通过将其嵌入我的java代码来启动Sftp服务器。当我启动Sftp服务器然后启动客户端时，异常抛出。
我的服务器代码
public class EmbeddedSftpServer {
public static final String SERVER_BASE_DIR = System.getProperty("user.dir") + File.separator + "src";
// public static final String SERVER_KEYSTORE = SERVER_BASE_DIR + File.separator + "resources" + File.separator + "ftpserver.jks";
public static final String SERVER_KEYSTORE= "C:\\Users\\y73wang\\IdeaProjects\\SFTPServer\\src\\main\\resources\\ftpserver.jks";
//public static final String SERVER_USERS = SERVER_BASE_DIR + File.separator + "resources" + File.separator + "users.properties";
public static final String SERVER_USERS ="C:\\Users\\y73wang\\IdeaProjects\\SFTPServer\\src\\main\\resources\\users.properties";
//public static final String USER_HOME_DIR = SERVER_BASE_DIR + File.separator + "SftpHomeDir" ;
public static final String USER_HOME_DIR = "D:\\TEST";
public static final String SAMPLE_FILE = "test.txt";
public static final String ADMIN = "admin";
public static final String PASSWORD = "password";
public static final int DEFAULT_PORT =8009;
private final FtpServer server;
public static EmbeddedSftpServer createDefaultServer() throws Exception {
return new EmbeddedSftpServer(DEFAULT_PORT,ADMIN,PASSWORD,true);
}
public EmbeddedSftpServer( int port, String username, String password, boolean implicitSsl ) throws Exception {
this.server = createServer( port, username, password, implicitSsl );
}
private FtpServer createServer( int port, String username, String password, boolean implicitSsl ) throws FtpException {
ListenerFactory factory = new ListenerFactory();
factory.setPort( port );
if ( implicitSsl ) {
SslConfigurationFactory ssl = new SslConfigurationFactory();
ssl.setKeystoreFile( new File( SERVER_KEYSTORE ) );
ssl.setKeystorePassword( PASSWORD );
// set the SSL configuration for the listener
factory.setSslConfiguration( ssl.createSslConfiguration() );
factory.setImplicitSsl( true );
}
FtpServerFactory serverFactory = new FtpServerFactory();
// replace the default listener
serverFactory.addListener( "default", factory.createListener() );
PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory();
userManagerFactory.setFile( new File( SERVER_USERS ) );
UserManager userManager = userManagerFactory.createUserManager();
if ( !userManager.doesExist( username ) ) {
BaseUser user = new BaseUser();
user.setName( username );
user.setPassword( password );
user.setEnabled( true );
user.setHomeDirectory( USER_HOME_DIR );
user.setAuthorities( Collections.<Authority>singletonList( new WritePermission() ) );
userManager.save( user );
}
serverFactory.setUserManager( userManager );
return serverFactory.createServer();
}
public void start() throws FtpException {
server.start();
}
public void stop(){
if (server != null){
server.stop();
}
}
public static void main(String[] args) throws Exception {
EmbeddedSftpServer sftpServer = new EmbeddedSftpServer(DEFAULT_PORT,"admin","admin",true);
sftpServer.start();
}
}
user.properties:
# Password is "admin"
ftpserver.user.admin.userpassword=21232F297A57A5A743894A0E4A801FC3
ftpserver.user.admin.homedirectory=D:/test
ftpserver.user.admin.enableflag=true
ftpserver.user.admin.writepermission=true
ftpserver.user.admin.maxloginnumber=10
ftpserver.user.admin.maxloginperip=10
ftpserver.user.admin.idletime=0
ftpserver.user.admin.uploadrate=0
ftpserver.user.admin.downloadrate=0
ftpserver.user.anonymous.userpassword=
ftpserver.user.anonymous.homedirectory=D:/test
ftpserver.user.anonymous.enableflag=true
ftpserver.user.anonymous.writepermission=false
ftpserver.user.anonymous.maxloginnumber=20
ftpserver.user.anonymous.maxloginperip=2
ftpserver.user.anonymous.idletime=300
ftpserver.user.anonymous.uploadrate=4800
ftpserver.user.anonymous.downloadrate=4800
客户代码：
public class JschClient {
public void sendFile(String filename) throws JSchException, SftpException, FileNotFoundException {
int Port =22;
String sftphost = "127.0.0.1";
String userName = "admin";
String password = "admin";
String HomeDir = "D:\\test";
Session session =null;
Channel channel =null;
ChannelSftp channelSftp = null;
JSch jSch = new JSch();
session =jSch.getSession(userName,sftphost,8009);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking","no");
config.put("PreferredAuthentications", "password");
session.setConfig(config);
session.setPassword(password);
session.connect(60000);
channel = session.openChannel("sftp");
channel.connect();
channelSftp = (ChannelSftp) channel;
((ChannelSftp) channel).cd(HomeDir);
File f = new File(filename);
channelSftp.put(new FileInputStream(f),f.getName());
channelSftp.exit();
System.out.println("sftp Channel exited.");
channel.disconnect();
System.out.println("Channel disconnected.");
session.disconnect();
System.out.println("Host Session disconnected.");
}
public static void main(String[]agrs) throws FileNotFoundException, JSchException, SftpException {
JschClient jschClient = new JschClient();
jschClient.sendFile("D:\\file1.txt");
}
错误日志：
Exception in thread "main" com.jcraft.jsch.JSchException: connection is closed by foreign host
at com.jcraft.jsch.Session.connect(Session.java:269)
at client.JschClient.sendFile(JschClient.java:29)
at client.JschClient.main(JschClient.java:45)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
我的代码有什么问题吗？
您正在启动FTP服务器，但使用SFTP客户端连接到它。
那不行。 FTP和SFTP是两种完全不同且不兼容的协议。
只需调整sshd_config'MaxStartups'计数，例如'MaxStartups 1000'，然后重启ssh
可能是我很晚才回答你的问题，但是如果有人需要如何使用jsch库连接SFTP。
您可以使用以下方法
static Session session = null;
static Channel channel = null;
public Session sftpConnection(final String value, final String sftpUser, final String sftpHost, final int sftpPort,
final String sftpPass) {
System.out.println("preparing the host information for sftp.");
try {
JSch jsch = new JSch();
this.session = jsch.getSession(sftpUser, sftpHost, sftpPort);
if (value.equals("puttyServer")) {
this.session.setProxy(new ProxySOCKS5("proxy need to add", Integer.parseInt("portnumber need to add")));
}
this.session.setPassword(sftpPass);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
this.session.setConfig(config);
this.session.connect();
return this.session;
} catch (Exception ex) {
ex.printStackTrace();
sftpConnection(value, sftpUser, sftpHost, sftpPort, sftpPass);
}
return null;
}