J2ssh 를 이용한 SSH 접속 인증

인사이드자바
J2ssh 를 이용한 SSH 접속 인증

> 패스워드를 이용한 인증과 공개키를 이용한 인증 방식
import java.io.File;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.sshtools.j2ssh.SshClient;
import com.sshtools.j2ssh.authentication.AuthenticationProtocolState;
import com.sshtools.j2ssh.authentication.PasswordAuthenticationClient;
import com.sshtools.j2ssh.authentication.PublicKeyAuthenticationClient;
import com.sshtools.j2ssh.configuration.SshConnectionProperties;
import com.sshtools.j2ssh.session.SessionChannelClient;
import com.sshtools.j2ssh.transport.publickey.SshPrivateKey;
import com.sshtools.j2ssh.transport.publickey.SshPrivateKeyFile;
 
/**
 * # SSH 접속 클라이언트
 */
public class J2sshCient {
    private Log log = LogFactory.getLog(this.getClass());    
    private SshClient ssh = null;    
    private SessionChannelClient session = null;    
    private String hostPrompt = null;        
     
    /**
     * @param server
     * @param userid
     * @param pwd
     * @throws Exception
     */
    public J2sshCient(String server, String userid, String password) throws Exception{    
        PasswordAuthenticationClient auth = null;    
 
        try {
            if (server == null || userid == null || password == null) {
                System.out.println("Parameter is null!");
            }
 
            ssh = new SshClient();
            ssh.setSocketTimeout(30000);
            SshConnectionProperties properties = new SshConnectionProperties();
            properties.setHost(server);
            properties.setPort(22);
            properties.setPrefPublicKey("ssh-dss");
            // Connect to the host
            ssh.connect(properties, new AlwaysAllowingConsoleKnownHostsKeyVerification());
 
// # 패스워드를 이용한 인증 접속        
// ------------------------------------------------------------
//            PasswordAuthenticationClient authClient = new PasswordAuthenticationClient();
//            authClient.setUsername(userid);
//            authClient.setPassword(password);
// ------------------------------------------------------------
 
 
 
// # 패스워드 없이 공개키를 이용한 인증 접속        
// ------------------------------------------------------------
            // Initialize the authentication data.
            PublicKeyAuthenticationClient authClient = new PublicKeyAuthenticationClient();
            // 사용자 계정
            authClient.setUsername(userid);
            // id_rsa 파일 위치
            SshPrivateKeyFile file = SshPrivateKeyFile.parse(
                                          new File("/home/userid/.ssh/id_rsa"));
            SshPrivateKey privateKey = file.toPrivateKey(null);
            authClient.setKey( privateKey );    
// ------------------------------------------------------------
            int result = ssh.authenticate(authClient);
 
            if (result != AuthenticationProtocolState.COMPLETE) {
                throw new Exception("Login failed");
            }    
 
            // SSH 터미널 커맨드 실행용
            session = ssh.openSessionChannel();
            session.requestPseudoTerminal("vt100", 80, 25, 0, 0 , "");
            session.startShell();
        } catch (Exception e) {
            e.printStackTrace();
            log.error(e);
            throw e;
        }    
    }   
 
    /*    * 커맨드 실행 함수(ex : ls -l\n)    */
    public String exec(String cmd) throws Exception
    {
        StringBuffer returnValue = null;
        boolean promptReturned = false;
        byte[] buffer = null;
        OutputStream out = null;
        InputStream in = null;
        int read;
        String response = null;
        int i = 0;
 
        try {
            if (session == null) {
                log.error("Session is not connected!");
                throw new Exception("Session is not connected!");
            }
 
            out = session.getOutputStream();
            cmd = cmd+"\n"; // 행단위 명령을 위해 \n 추가
            out.write(cmd.getBytes());
            out.flush();
            in = session.getInputStream();
            buffer = new byte[255];
            returnValue = new StringBuffer(300);
 
            while(promptReturned == false && (read = in.read(buffer))> 0) {
                response = new String(buffer, 0, read);
                if (i == 1)
                    returnValue.append(response.toString());
                if (!StringUtils.isEmpty(response) 
                   && response.indexOf(this.hostPrompt) >= 0) {
                    ++i;
                    if (i >= 2) {
                        promptReturned = true;
                    }
                }
            }
            log.error("returnValue : " + returnValue.toString());
 
        } catch (Exception e) {
            e.printStackTrace();
            log.error(e);
        }
        return returnValue.toString();
    }
 
    public boolean isClosed() throws Exception
    {
        boolean rtn = true;
        try {
 
            if (session != null)
                rtn = session.isClosed();
        } catch(Exception e) {
            e.printStackTrace();
            log.error(e);
        }
        return rtn;
    }
 
    public boolean logout() throws Exception
    {
        boolean rtn = false;
 
        try {
            if (session != null) {
                session.getOutputStream().write("exit\n".getBytes());
                session.close();
            }
            if (ssh != null)
                ssh.disconnect();
            rtn = true;
        } catch(Exception e) {
            e.printStackTrace();
            log.error(e);
        }
        return rtn;
    }
 
    public String getHostprompt() {
 
        return this.hostPrompt;
    } 
 
    public void setHostprompt(String hostPrompt) {
 
        this.hostPrompt = hostPrompt;
    }
 
    public static void main(String[] args)     {
        try {
 
            J2sshCient jsclient = new J2sshCient("192.168.1.10", "userid", "password");
            jsclient.setHostprompt("> ");
            String result = jsclient.exec("ls -al");
            System.out.println("jsclient.exec :" + result);
            jsclient.logout();
            System.out.println("isClosed : " + jsclient.isClosed());
             
        } catch (Exception e) {
            System.out.println(e);
        }    
    }
 
}