import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
@Override
public boolean authenticate(String username, String password, ServerSession session) throws
        PasswordChangeRequiredException {
    try {
        Authentication auth = authProvider.authenticate(
                new UsernamePasswordAuthenticationToken(username, password));
        session.getIoSession().setAttribute(Constants.USER, username);
        session.getIoSession().setAttribute(Constants.USER_ROLES, auth.getAuthorities().stream()
                .map(ga -> ga.getAuthority()).collect(Collectors.toSet()));
        return true;
    } catch (AuthenticationException ex) {
        log.warn(ex.getMessage());
        return false;
    }
}
 

import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
@Override
public boolean authenticate(String username, String password, ServerSession session) throws
        PasswordChangeRequiredException {
    session.getIoSession().setAttribute(Constants.USER_ROLES, Collections.<String>singleton("*"));
    session.getIoSession().setAttribute(Constants.USER, username);
    return username.equals(props.getUsername()) && password.equals(props.getPassword());
}
 

import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
public static SshServer create() {

        SshServer sshd = SshServer.setUpDefaultServer();
        sshd.setPort(SpashConfig.getInstance().spashListenPort());

        AbstractGeneratorHostKeyProvider keyProvider = new SimpleGeneratorHostKeyProvider(new File(SpashConfig.getInstance().spashKeyFileName()));
        keyProvider.setAlgorithm(SpashConfig.getInstance().spashKeyAlgorithm());
        keyProvider.setKeySize(SpashConfig.getInstance().spashKeyLength());

        sshd.setKeyPairProvider(keyProvider);

        List<NamedFactory<UserAuth>> userAuthFactories = new ArrayList<NamedFactory<UserAuth>>();
        userAuthFactories.add(new UserAuthPasswordFactory());
        sshd.setUserAuthFactories(userAuthFactories);

        sshd.setPasswordAuthenticator(new PasswordAuthenticator() {
            @Override
            public boolean authenticate(String username, String password, ServerSession serverSession) throws PasswordChangeRequiredException {
                return username!=null && username.length()>0 && username.equals(password);
            }
        });

        sshd.setShellFactory(new SpashShellFactory());

        List<NamedFactory<Command>> namedFactoryList = new ArrayList<>();
        namedFactoryList.add(new SftpSubsystemFactory());
        sshd.setSubsystemFactories(namedFactoryList);

        sshd.setCommandFactory(new ScpCommandFactory());

        sshd.setFileSystemFactory(new FileSystemFactory() {
            @Override
            public FileSystem createFileSystem(Session session) throws IOException {
                return SpashFileSystem.get().getFileSystem();
            }
        });

        return sshd;
    }
 

import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
@BeforeClass
public static void setup() throws Exception {
    sshdServer.setPort(PORT);
    sshdServer.setKeyPairProvider(new SimpleGeneratorHostKeyProvider());

    sshdServer.setPasswordAuthenticator(new PasswordAuthenticator() {
        public boolean authenticate(String user, String password, ServerSession serverSession) throws PasswordChangeRequiredException {
            return user.equals(USERNAME) && password.equals(USERPWD);
        }
    });

    sshdServer.start();
}
 

import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
@Override
public boolean authenticate(String username, String password, ServerSession session)
        throws PasswordChangeRequiredException
{
    return Objects.equals(username, "admin") && Objects.equals(password, "admin");
}
 

import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
@Override
public boolean authenticate(String username, String password, ServerSession serverSession) throws PasswordChangeRequiredException {
    return password.equals(users.get(username));
}
 

import org.apache.sshd.server.auth.password.PasswordChangeRequiredException; //导入依赖的package包/类
@Override
public boolean authenticate(String username, String password, ServerSession session)
    throws PasswordChangeRequiredException {
  return username.equals("testuser") && password.equals("pass");
}