分布式系统之间通信可以分为两种：

• 基于消息方式实现系统间通信
• 基于远程调用方式实现系统间通信

基于远程调用实现系统间通信

远程调用方式就是尽可能将系统间的调用模拟为系统内的调用，让使用者感觉远程调用就像是调用本地接口一样。但远程调用并不能做到完全透明，因为存在网络问题、超时问题、 序列化 /反序列化问题等等。

两种基于远程调用实现系统间通信的方法

在Java中实现远程调用的技术主要有RMI和 WebService 两种。

RMI

RMI（Remote Method Invocation)中，客户端只有服务端提供服务的接口，通过接口实现对远程服务端的调用。

远程调用基于网络通信来实现，RMI也是如此：

• RMI服务端：通过启动RMI注册对象在一个端口上监听对外提供的接口。服务端接收到客户端请求后，解析其中的对象信息等，然后通过反射来获取相应的对象和方法来完成功能的调用。最后将结果序列化通过TCP/IP返回给客户端。
• RMI客户端：通过poxy的方式代理了对 服务器端口 的访问。RMI客户端将要访问的服务器对象等信息封装成一个对象序列化后通过TCP/IP传输到服务端。最后接收服务端返回的数据，反序列化后交给调用发起者。

服务端代码：

RMI要求服务端接口实现 Remote 接口，接口上每个方法必须抛出RemoteException.服务端业务类通过实现该接口提供业务功能，然后调用UnicastRemoteObject.exportObject将对象绑定到某端口上，最后将该对象注册到本地Locate registry 上，此时形成一个 字符串 对应于对象实例的映射关系。

//服务器端对外提供的接口
public interface  business  extends Remote{
 public String echo(String message) throws RemoteException;
}
//服务器端实现该接口的类
public class BusinessImpl implements Buniness{
 public String echo(String message) throws RemoteException{
 ...
 }
}
//基于RMI的服务器端
public static void main(String[] args){
 int post = 9527;
 String name = "BusinessDemo";
 Business business = new  Business Impl();
 UnicastRemoteObject.exportObject(business, post);
 Registry  Registry  = LocateRegistry.createRegistry(1099);
 registry.rebind(name,business);
}
 

客户端代码：

客户端首先通过LocateRegistry.getRegistry()来获取Registry对象，然后通过Registrylookup字符串获取要调用的服务器端口的实例对象，最后以接口的方式调用远程对象的方法。

Registry registry = LocateRegistry.getRegistry("localhost");
String name = "BusinessDemo");
//创建BusinessDemo类的代理类
RemoteException business business = (Business) registry.lookup(name);
 

WebService

WebService是一种跨语言的系统间交互标准。

• 服务端：以HTTP的形式提供服务，该服务采用WSDL描述，这个文件中描述服务所使用的协议，所希望的参数、返回的参数格式等。服务端应将WSDL文件放入HTTP服务器中，并借助Java辅助工具根据WSDL文件生成客户端sub代码。服务器端接收客户端请求并通过反射调用服务。
• 客户端：通过sub代码将产生的对象请求信息封装为标准的SOAP格式数据，并发送请求到服务器端。客户端和服务端的数据交互格式是SOAP。

服务端代码：

//服务器端对外提供的接口
public interface Business extends Remote{
 public String echo(String message) throws RemoteException;
}
//服务器端实现该接口的类
@WebService(name="Business",serviceName="BusinessService",targetNamespace="")
@SOAPBinding(style=SOAPBind.Style.RPC)
public class BusinessImpl implements Buniness{
 public String echo(String message) throws RemoteException{
 ...
 }
}
//发布WebService的类
public static void main(String[] args){
 Endpoint.publish("",new BusinessImpl());
 System.out.println("Server has beed started");
}
 

客户端代码：

客户端通过JDK bin目录下的wsimport命令来生成服务调用代码。执行下列命令生成辅助代码：

wsimport -keep 
 

执行后会在文件夹book/chapter/WebService/client下生成Business.java和BusinessService.java代码，基于这两个代码编写客户端代码：

BusinessService business = new BusinessService();
Business business = businessService.getBusinessPort();
business.echo(command);