我刚刚创建了一个适合我的示例。我使用 Putty 连接到 Apache SSHD。我使用的 Lib 版本是“apache-sshd-0.9.0”(下载时间:2014-02-04)。JDK 1.7。
我的示例的主要内容如下:
public static void main(String[] args) throws IOException
{
SshServer sshd = SshServer.setUpDefaultServer();
sshd.setPort(22);
sshd.setKeyPairProvider(new SimpleGeneratorHostKeyProvider("./keys/mysample",
SimpleGeneratorHostKeyProvider.SSH_RSA));
List<NamedFactory<UserAuth>> userAuthFactories = new ArrayList<NamedFactory<UserAuth>>();
userAuthFactories.add(new UserAuthPassword.Factory());
sshd.setUserAuthFactories(userAuthFactories);
sshd.setPasswordAuthenticator(new PasswordAuthenticator() {
public boolean authenticate(String username, String password, ServerSession session) {
return "tomek".equals(username) && "123".equals(password);
}
});
sshd.setShellFactory(new MyCommandFactory());
sshd.start();
while (true) ;
}
如您所见,我创建了自己的命令工厂,如下所示:(顺便说一句。这个关于 SO的问题对我很有帮助)
public class MyCommandFactory implements CommandFactory, Factory<Command>
{
public Command createCommand(String s)
{
System.out.println("command requested: " + s);
return new MyCommand(s);
}
public Command create()
{
return createCommand("none");
}
}
出于测试目的,创建如下命令:
public class MyCommand implements Command
{
private String name;
private InputStream inputStream;
private OutputStream outputStream;
private ExitCallback exitCallback;
public MyCommand(String name)
{
this.name = name;
}
public void setInputStream(final InputStream inputStream)
{
System.out.println("input stream was set on command: " + name);
this.inputStream = inputStream;
}
public void setOutputStream(final OutputStream outputStream)
{
System.out.println("output stream was set on command: " + name);
this.outputStream = outputStream;
}
public void setErrorStream(OutputStream outputStream)
{
System.out.println("error stream was set on command: " + name);
}
public void setExitCallback(ExitCallback exitCallback)
{
System.out.println("exit callback was set on command: " + name);
this.exitCallback = exitCallback;
}
public void start(Environment environment) throws IOException
{
try
{
final PrintWriter writer = new PrintWriter(outputStream, true);
writer.println("Welcome to Java SSH echo server!");
writer.flush();
// ... here you gonna read input from remote client ...
// use writer to write back responses
}
catch (final Exception e)
{
e.printStackTrace();
}
}
public void destroy()
{
System.out.println("destroy was called on command: " + name);
// client or server closed connection, clean up resources here
}
}
如您所见,我使用了一个密钥文件“./keys/mysample”。要创建这样一个密钥文件,试试这个:(顺便说一句。这个关于 SO的问题对此很有帮助)
keytool -genkey -keystore ./keys/mysample" -keyalg RSA
瞧:
我希望这对某人有帮助。
[编辑] 看看这里有一个更好的回声服务器:http:
//svn.apache.org/repos/asf/mina/sshd/trunk/sshd-core/src/test/java/org/apache/sshd/ util/EchoShellFactory.java