本篇内容介绍了“Java远程过程调用方法是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
问题:
1)要搭建一个新服务,免不了需要依赖他人的服务,而现在他人的服务都在远端,怎么调用?
2)其它团队要使用我们的新服务,我们的服务该怎么发布以便他人调用?
下文将对这两个问题展开探讨。
<>之前,public interface HelloWorldService { ,,,,String sayHello (String 味精); 以前,} <>之前public class HelloWorldServiceImpl implements HelloWorldService { ,,,@Override ,,,public String sayHello (String 味精),{ ,,,,,,,,String result =,“hello world “, +,味精; ,,,,,,,,System.out.println(结果); ,,,,,,,,return 结果; ,,,,} 以前,} <>之前,public class Test { ,,,,public static void main (String [], args), { ,,,,,,,,HelloWorldService HelloWorldService =, new HelloWorldServiceImpl (); ,,,,,,,,helloWorldService.sayHello (“test"); ,,,,} }1 如何调用他人的远程服务？
由于各服务部署在不同机器，服务间的调用免不了网络通信过程，服务消费方每调用一个服务都要写一坨网络通信相关的代码，不仅复杂而且极易出错。
如果有一种方式能让我们像调用本地服务一样调用远程服务，而让调用者对网络通信这些细节无感知，那么将大大提高生产力，比如服务消费方在执行 helloWorldService.sayHello("test") 时，实质上调用的是远端的服务。这种方式其实就是RPC（Remote Procedure Call Protocol），在各大互联网公司中被广泛使用，如阿里巴巴的hsf、dubbo（开源）、Facebook的thrift（开源）、Google grpc（开源）、Twitter的finagle（开源）等。
要让网络通信细节对使用者透明，我们需要对通信细节进行封装，我们先看下一个RPC调用的流程涉及到哪些通信细节：
服务消费方（client）调用以本地调用方式调用服务；
client stub接收到调用后负责将方法、参数等组装成能够进行网络传输的消息体；
client stub找到服务地址，并将消息发送到服务端；
server stub收到消息后进行解码；
server stub根据解码结果调用本地的服务；
本地服务执行并将结果返回给server stub；
server stub将返回结果打包成消息并发送至消费方；
client stub接收到消息，并进行解码；
服务消费方得到最终结果。
RPC的目标就是要2~8这些步骤都封装起来，让用户对这些细节无感知。
1.1 怎么做到无感知化远程服务调用？
怎么封装通信细节才能让用户像以本地调用方式调用远程服务呢？对java来说就是使用代理！java代理有两种方式：
jdk 动态代理；
字节码生成；
尽管字节码生成方式实现的代理更为强大和高效，但代码维护不易，大部分公司实现RPC框架时还是选择动态代理方式。
下面简单介绍下动态代理怎么实现我们的需求。我们需要实现RPCProxyClient代理类，代理类的invoke方法中封装了与远端服务通信的细节，消费方首先从RPCProxyClient获得服务提供方的接口，当执行 helloWorldService.sayHello("test") 方法时就会调用invoke方法。
public class RPCProxyClient implements java.lang.reflect.InvocationHandler{
,,,private Object obj;
,,,public RPCProxyClient (Object obj) {
,,,,,,,this.obj=obj;
,,,}
,,,/* *
,,,,*,得到被代理对象;
,,,*/,,,public static Object getProxy (Object obj) {
,,,,,,,return java.lang.reflect.Proxy.newProxyInstance (obj.getClass () .getClassLoader (),
,,,,,,,,,,,,,,,obj.getClass () .getInterfaces (),, new RPCProxyClient (obj));
,,,}
,,,/* *
,,,,*,调用此方法执行
,,,*/,,,public Object 调用(Object 代理,Method 方法,对象[],args)
,,,,,,,,,,,throws Throwable {
,,,,,,,//结果参数;
,,,,,,,Object result =, new 对象();
,,,,,,,//,,执行通信相关逻辑
,,,,,,,//,…
,,,,,,,return 结果;
,,,}
}Java远程过程调用方法是什么
