4个答案 按时间排序 按投票排序

0 0

哪三个文件啊？

2011年11月21日 21:14

khan
303
0 0 1

• 添加评论

0 0

有啊，

package com.surekam.collie.collecter.task.conn.inst;

import com.surekam.collie.collecter.task.conn.AbsActiveConn;
import com.surekam.collie.model.collecter.ProtocolDetail;
import com.surekam.conf.api.ConfigManager;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.net.telnet.TelnetClient;

import java.io.InputStream;
import java.io.PrintStream;
import java.util.Map;
import java.util.concurrent.*;

public class TelnetNConn extends AbsActiveConn implements Callable{
    private final static Log log = LogFactory.getLog(TelnetNConn.class);
    private TelnetClient telnetSession;
    private String destAddress;
    private int    destPort = 23;
    private String destUser;
    private String destPWD ;
    private String terminalEnv;
    private final  String TIMEOUT   = "telnetTimeOut";
    private long   timeout          = 40000;
    private String userPrompt       = "ogin: ";
    private String passPrompt       = ": ";
    private String prompt           = "$ ";
    private boolean isLogin         = false;
    private ExecutorService executor; //异步执行传入命令


    /**
     * telnet 连接初始化
     */
    public void init(ProtocolDetail protocolDetail) throws Exception {
        /**
         * 参数,成员初始处理
         */
        Map<String, String> params = protocolDetail.getParamsMap();
        destAddress = params.get("IP").trim();
        destUser    = params.get("USER");
        destPWD     = params.get("PASSWORD");
        terminalEnv = params.get("TERMINALENV");  //终端模拟，如使用不正确可能导致采集结果返回乱码，数值主要包括：VT220、VT100、LINUX等
        destPort    = Integer.parseInt(params.get("PORT"));
        prompt      = params.get("PROMPT").trim();
        terminalEnv = null==terminalEnv||terminalEnv.trim().length()<1?"VT100":"";
        timeout     = Long.parseLong(ConfigManager.getInstance().getConfiger().getParameter(TIMEOUT));
        executor    = Executors.newSingleThreadExecutor();  //命令任务处理

        /**
         * 连接初始处理
         */
        try{
            telnetSession = new TelnetClient(terminalEnv);
            telnetSession.setReaderThread(false);
            telnetSession.connect(destAddress, destPort);
            login(destUser,destPWD);
        }catch (Exception e){
            e.printStackTrace();
        }

    }

    /**
     * 登陆到telnet服务端
     * @param destUser
     * @param destPWD
     */
    private void login(String destUser, String destPWD) {
        try{
            if(telnetSession.isConnected()){
                sendString("");
                String welcomeInfo = (String)call();
//                log.info("welcome:"+welcomeInfo);
                sendString(destUser);
                String fillUserInfo  = (String)call();
//                log.info("fillUserInfo："+fillUserInfo);
                sendString(destPWD);
                String fillPWDInfo   = (String)call();
//                log.info("filePWD:"+fillPWDInfo);
                /**
                 *  根据填充完密码返回信息
                 *  判断登陆是否成功
                 */
                if(fillPWDInfo.trim().endsWith(prompt.trim())){
                        isLogin = true;
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    /**
     * telnet连接后执行系统指令
     * @param cmd
     * @return
     * @throws Exception
     */
    public Object execCommand(final String cmd) throws Exception {
//        log.info("isLogin:"+isLogin);
        if(isLogin){
            sendString(cmd);
            Future future = executor.submit(this);
            return  future.get(timeout,TimeUnit.MILLISECONDS);
        }else{
            throw new Exception("连接问题导致连接异常");
        }
    }

    /**
     * 发送指令到telnet服务端
     * @param s
     * @throws Exception
     */
    private void sendString(String s) throws Exception {
        PrintStream os = new PrintStream(telnetSession.getOutputStream());
        os.println(s);
        os.flush();
    }

    /**
     * 读取telnet服务端返回数据
     * @return
     * @throws Exception
     */
    public Object call() throws Exception {
            InputStream inputStream = telnetSession.getInputStream();
            StringBuffer stringBuffer = new StringBuffer();
            try {
                    byte[] buff = new byte[1024];
                    int ret_read = 0;
                    boolean loopFlag = true;
                    while (loopFlag && ret_read >= 0){
                            /**
                             *  读取数据
                             */
                            ret_read = inputStream.read(buff);
                            if (ret_read > 0) {
                                String temp = new String(buff, 0, ret_read);
                                stringBuffer.append(temp);
                            }
                            /**
                             *  判断返回
                             */
                            if(isLogin){ //login的情况下不处理冒号
                                if(stringBuffer.toString().trim().endsWith(prompt.trim())){
                                      loopFlag = false;
                                }
                            }else {     // 登陆成功只判断命令提示符
                                if(stringBuffer.toString().trim().endsWith(":")||stringBuffer.toString().trim().endsWith(prompt.trim())){
                                      loopFlag = false;
                                }
                            }
                    }
		    } catch (Exception e) {
			    log.debug("telnet读取命令返回数据错误",e);
		    }
            return  new String(stringBuffer.toString().getBytes(),"utf-8");
    }

    /**
     * 适配抽象方法
     * @return
     */
    public Object getInnerConnection() {
        throw new UnsupportedOperationException("Telnet连接不支持此操作！");//示例不支持的操作写法
    }

    /**
     * InnerConnection底层抽象实现
     * @return  true:alive
     */
    public boolean isAlive() {
    	try {
			String result = (String) this.execCommand("echo testLink");
			if(!(result.indexOf("testLink")>-1)){
				return false;
			}
		} catch (Exception e) {
			log.error("判断连接错误",e);
			return false;
		}
        return true;

    }

    /**
     * 端口与telnet服务端的连接
     */
    public void close() {
        try {
        	if(telnetSession!=null)
        		telnetSession.disconnect();
        }
        catch (Exception e) {
            log.error(e);
        }
    }


    public static void main(String[] args) {
        ProtocolDetail protocolDetail = new ProtocolDetail();
        Map params = protocolDetail.getParamsMap();
        params.put("IP", "192.168.1.103");
        params.put("USER", "itim");
        params.put("PASSWORD", "itim");
        params.put("TERMINALENV", "VT100");
        params.put("PORT", "23");
        params.put("PROMPT", "$");

        TelnetNConn conn = new TelnetNConn();
        try {
              conn.init(protocolDetail);
              System.out.println(conn.isAlive());
              System.out.println(conn.execCommand("ll"));
              System.out.println("执行完毕");
        }catch (Exception e) {
			e.printStackTrace();

		}finally{
			conn.close();
		}
    }


}

2011年11月21日 19:58

khan
303
0 0 1

• 添加评论

0 0

只能telnet了，兄弟！

2011年11月21日 18:43

khan
303
0 0 1

• 添加评论

0 0

你的问题是否类似于电脑的远程登录？

2011年11月21日 18:32

泰山宏图
71
0 0 1

• 添加评论