import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.SFTPInputStream;
import ch.ethz.ssh2.SFTPv3Client;


public class Fs{
	public static void main(String[] args) throws Exception {
		OwnClassLoader ocl = new OwnClassLoader();
		String ip,user,password;
		ip = "120.34.168.80";//自己的遠程ip
		user = "root";//username
		password = "123456";//password
		ocl.login(ip, user, password);
		Object obj = ocl.loadeOthClass("/opt/4/tt.class");//class文件路徑
				
		System.out.println(obj);
		Class c = obj.getClass();
		Field f = c.getDeclaredField("age");
		f.setAccessible(true);
		System.out.println("age:"+f.get(obj));
	}
}
//自定義類加載器
class OwnClassLoader extends ClassLoader{
	private Connection conn = null;
	//初始化鏈接
	public  Connection login(String ip,String user,String password){
		Connection conn = null;
		try {
			//也可以new Connection(ip, port)創(chuàng)建對象,默認22
			conn = new Connection(ip);
			//連接遠程服務(wù)
			conn.connect();
			//使用用戶名和密碼登錄
			conn.authenticateWithPassword(user, password);
			this.conn  = conn;
	        return conn;
		} catch (IOException e) {   
			e.printStackTrace();
	  }
	  return null;
	}
	//返回遠程實例
	public Object loadeOthClass(String url) throws Exception{
		if(null==conn)
			throw new Exception("請初始化鏈接");
		SFTPv3Client sc = new SFTPv3Client(conn);//創(chuàng)建ssh客戶端連接
		InputStream is = new SFTPInputStream(sc.openFileRO(url));//創(chuàng)建輸入流
		byte[] b = this.readClassFile(is);
		Class<?> c = super.defineClass(b, 0, b.length);//定義class
		return c.newInstance();//創(chuàng)建實例
	}
	//讀取遠程class文件
	private  byte[] readClassFile(InputStream is){
		byte[] b = new byte[1024];
		int len;
		ByteArrayOutputStream bos = null;
		try {
			bos = new ByteArrayOutputStream();//內(nèi)存流輸出
			while((len=is.read(b))!=-1){
				bos.write(b, 0, len);
			}
			b = bos.toByteArray();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				if(is!=null)
					is.close();
				if(bos!=null)
					bos.close();
			} catch (Exception e2) {
				// TODO: handle exception
			}		
		}	
		return b;	
	}	
}