RPC的简单解读和具体实现Demo

2017-09-13 12:25:34来源:CSDN作者:G_Youda人点击

分享
RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型中,RPC跨越了传输层应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。RPC采用客户机/服务器模式。请求程序就是一个客户机,而服务提供程序就是一个服务器。首先,客户机调用进程发送一个有进程参数的调用信息到服务进程,然后等待应答信息。在服务器端,进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达,服务器获得进程参数,计算结果,发送答复信息,然后等待下一个调用信息,最后,客户端调用进程接收答复信息,获得进程结果,然后调用执行继续进行。有多种 RPC模式和执行。最初由 Sun 公司提出。IETF ONC 宪章重新修订了 Sun 版本,使得 ONC RPC 协议成为 IETF 标准协议。现在使用最普遍的模式和执行是开放式软件基础的分布式计算环境(DCE)。利用RPC,我们可以很容易的实现业务系统的水平扩展,将一个业务系统按照功能可以拆分到多个不同的主机上独立运行,其他模块需要用到该模块的功能时可以通过RPC进行远程调用,这样极大的扩展了系统的性能,也降低了系统各部分之间的耦合程度。各部分只需要知道其他模块的接口即可,而具体的实现逻辑完全不用知道,方便了协同开发。同时部分模块的变更只要不影响到接口对其他模块不会产生影响。以下通过一个简单的登录验证小Demo进行举例:假如我们的业务系统较为庞大,不可能做到把MVC三层全都放到一台机器上,这样会极大的降低性能,也会因为单点故障等问题导致的服务不可用。所以建议将控制层,业务逻辑层,数据访问层分开部署到不同的机器上去,但是这就面临一个问题:我们平时都是通过对象调用相应的函数进行其他模块的调用,这都是在同一台机器,甚至同一个代码工程里面,这样非常简单,但是要去访问其他机器的方法时这就行不通了。所以这时就需要RPC的帮忙进行远程调用。服务端:1.定义接口:LoginServiceInterface.class
package cn.guyouda.rpc;import java.rmi.Remote;import java.rmi.RemoteException;public interface LoginServiceInterface extends Remote{	public String login(String username,String password) throws RemoteException;}

2.实现接口:LoginServiceImpl.java
package cn.guyouda.rpc;import java.rmi.RemoteException;public class LoginServiceImpl implements LoginServiceInterface {	@Override	public String login(String username, String password) throws RemoteException {		if("GYD".equals(username) && "123456".equals(password)){			return "Login successfully";		}		else{			return "Error!";		}	}}

3.启动服务,等待远程程序调用
package cn.guyouda.rpc;import java.rmi.RemoteException;import java.rmi.registry.LocateRegistry;import java.rmi.registry.Registry;public class Server {	public static void main(String[] args) {		 // 注册管理器          Registry registry = null;          try {              // 创建一个服务注册管理器              registry = LocateRegistry.createRegistry(9999);            } catch (RemoteException e) {                        }          try {              // 创建一个服务              LoginServiceInterface server = new LoginServiceImpl();              // 将服务绑定命名              registry.rebind("loginService", server);                            System.out.println("==========bind server successfully===========");          } catch (RemoteException e) {          	System.out.println("==========Error:Bind server===========");        }  	}}

客户端:1.定义接口(需要和服务器端保持一致)
package cn.guyouda.rpc;import java.rmi.Remote;import java.rmi.RemoteException;public interface LoginServiceInterface extends Remote{	public String login(String username,String password) throws RemoteException;}


2.远程调用
package cn.guyouda.rpc;import java.rmi.AccessException;import java.rmi.NotBoundException;import java.rmi.RemoteException;import java.rmi.registry.LocateRegistry;import java.rmi.registry.Registry;import org.junit.Test;public class Client {		@Test	public void loginTest(){		 Registry registry = null;  		 try{			 // 获取服务注册管理器  			 registry = LocateRegistry.getRegistry("192.168.2.100",9999);  	                   // 根据命名获取服务              LoginServiceInterface server = (LoginServiceInterface) registry.lookup("loginService");              // 调用远程方法              String result = server.login("GYD", "123456");              // 输出调用结果              System.out.println("登录结果: " + result);  	        } catch (AccessException e) {  	              e.printStackTrace();	        } catch (RemoteException e) {  	              e.printStackTrace();	        } catch (NotBoundException e) {  	              e.printStackTrace();	        }  	}}

























最新文章

123

最新摄影

微信扫一扫

第七城市微信公众平台