远程方法调用的模仿实现（附系统的通信图）

RMI 即remote method invoke
远程方法调用：基于一种网络的技术
在本地执行一个方法，实际上是在服务器端完成的即服务器端真正的执行了这个方法并且通过网络进行函数执行结果的返回给客户端
下面我们逐步分析;
1 首先我们进行服务器与客户端的建立
2 并通过 ***来进行方法的执行
3 最终返回给客户端

这是我们进行分析之后，得到这个工程的通信图

RMI源码git链接

我们可以开始设计代码了
客户端
客户端代码进行服务器的连接，
并且将执行方法的名字以及参数传递给服务器端
最后准备接收服务器端传过来的函数结果

public class RMIClient1 {
	
	private  int RMIport;
	private  String RMIip;
	private Socket socket;
	private DataInputStream dis;
	private DataOutputStream dos;
	
	//get 和set        ip 以及port

	public RMIClient1(int RMIport,String RMIip) {
		this.RMIip=RMIip;
		this.RMIport=RMIport;
	}
	
	
	void ConnectToServer() {
// 建立通信信道
		try {
			this.socket=new Socket(RMIip,RMIport);
			this.dis=new DataInputStream(socket.getInputStream());
			this.dos=new DataOutputStream(socket.getOutputStream());
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		
	}


	public Object invokeMethod( Method method ,Object[] args) {
//		将要实现的方法传过去
		ArgumentMaker argmaker=new ArgumentMaker();
		for(int i=0;i<args.length;i++) {
			argmaker.addArg("arg"+i, args[i]);
		}
		String argStr=argmaker.toString();
		
		Object res=null;
		try {
			dos.writeUTF(String.valueOf(method.toString().hashCode()));
			dos.writeUTF(argStr);
			
			String result =dis.readUTF();
//			将由服务端返回的JSON字符串 结果传递回来给客户端
			res=ArgumentMaker.gson.fromJson(result, method.getReturnType());
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	
		
		return res;
	}
	}

我们再来看看服务器端
他需要完成自己的启动以及进行方法的执行

public class RMIServer1 implements Runnable{
	private int port;
	private ServerSocket server;
	private volatile  boolean   goon;
	
	public int getPort() {
		return port;
	}
	public void setPort(int port) {
		this.port = port;
	}

	public RMIServer1(int port) {
		this.port=port;
		
	}
	void Startup() {
		if(goon==true) {
			return;
		}
		try {
			server=new ServerSocket(port);
			goon=true;
			new Thread(this,"serverThread").start();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	void shutdown() {
		if(goon==false) {
			return ;
		}
		goon=false;
		try {
			server.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	@Override
	public void run() {
//		进行 服务器端的 通信线道的建立
//		进行 客户端传过来方法的执行
		Socket socket;
		try {
			socket = server.accept();
			new RMIActioner1(socket) ;
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

这里要遵循软件工程中职责单一的原则故我们在RMIActioner里面进行方法的执行

在进行编写的过程中，突然发现invoke 函数执行的时候需要methodname 以及
Object 故定义了 MethodDefination类给出两个成员的get和set方法
所以利用工厂模式将这他们生产出来

工厂里面有methodpool 键必须唯一所以想到
利用method的名字做hashmap得到唯一的键

远程方法调用的模仿实现（附系统的通信图）

全站热榜