Java之——RMI远程过程调用（插曲）

标签：rmi   java   通信   网络   分布式   

转载请注明出处：http://blog.csdn.net/l1028386804/article/details/45970641

一、定义

         Java RMI：Java远程方法调用，即Java RMI（Java Remote Method Invocation）是Java编程语言里，一种用于实现远程过程调用的应用程序编程接口。它使客户机上运行的程序可以调用远程服务器上的对象。远程方法调用特性使Java编程人员能够在网络环境中分布操作。RMI全部的宗旨就是尽可能简化远程接口对象的使用。

      我们知道远程过程调用（Remote Procedure Call, RPC）可以用于一个进程调用另一个进程（很可能在另一个远程主机上）中的过程，从而提供了过程的分布能力。Java 的 RMI 则在 RPC 的基础上向前又迈进了一步，即提供分布式对象间的通讯。

      RMI（Remote Method Invocation）为远程方法调用，是允许运行在一个Java虚拟机的对象调用运行在另一个Java虚拟机上的对象的方法。

      这两个虚拟机可以是运行在相同计算机上的不同进程中，也可以是运行在网络上的不同计算机中。

二、工作原理

        RMI能让一个Java程序去调用网络中另一台计算机的Java对象的方法，那么调用的效果就像是在本机上调用一样。通俗的讲：A机器上面有一个class，通过远程调用，B机器调用这个class 中的方法。

      RMI，远程方法调用（Remote Method Invocation）是Enterprise JavaBeans的支柱，是建立分布式Java应用程序的方便途径。RMI是非常容易使用的，但是它非常的强大。

      RMI的基础是接口，RMI构架基于一个重要的原理：定义接口和定义接口的具体实现是分开的。下面我们通过具体的例子，建立一个简单的远程计算服务和使用它的客户程序

三、RMI包含部分

        远程服务的接口定义远程服务接口的具体实现桩（Stub）和框架（Skeleton）文件一个运行远程服务的服务器一个RMI命名服务，它允许客户端去发现这个远程服务类文件的提供者（一个HTTP或者FTP服务器）一个需要这个远程服务的客户端程序

四、用途

     RMI的用途是为分布式Java应用程序之间的远程通信提供服务，提供分布式服务。

     目前主要应用时封装在各个J2EE项目框架中，例如Spring，EJB（Spring和EJB均封装了RMI技术）

     在Spring中实现RMI：

     ①在服务器端定义服务的接口，定义特定的类实现这些接口；

     ②在服务器端使用org.springframework.remoting.rmi.RmiServiceExporter类来注册服务；

     ③在客户端使用org.springframework.remoting.rmi.RmiProxyFactoryBean来实现远程服务的代理功能；

     ④在客户端定义访问与服务器端服务接口相同的类

五、RMI的局限

        RMI目前使用Java远程消息交换协议JRMP（Java Remote Messaging Protocol）进行通信。JRMP是专为Java的远程对象制定的协议，由于JRMP是专为Java对象制定的，因此，RMI对于用非Java语言开发的应用系统的支持不足。不能与用非Java语言书写的对象进行通信（意思是只支持客户端和服务器端都是Java程序的代码的远程调用）。

六、RMI的使用局限

       由于客户机和服务器都是使用Java编写的，二者平台兼容性的要求仅仅是双方都运行在版本兼容的Java虚拟机上。

七、调用远程方法的参数和返回值

        当调用远程对象上的方法时，客户机除了可以将原始类型的数据作为参数一外，还可以将对象作为参数来传递，与之相对应的是返回值，可以返回原始类型或对象，这些都是通过Java的对象序列化（serialization）技术来实现的。（换而言之：参数或者返回值如果是对象的话必须实现Serializable接口）

八、RMI应用程序的基本类型

九、RMI体系结构

     桩/框架（Stub/Skeleton）层：客户端的桩和服务器端的框架；

      远程引用（remote reference）层：处理远程引用行为

      传送层（transport）：连接的建立和管理，以及远程对象的跟踪

十、RMI类和接口

(一) Remote接口：

      是一个不定义方法的标记接口

      Public interface Remote{}

      在RMI中，远程接口声明了可以从远程Java虚拟机中调用的方法集。远程接口满足下列要求：

      1、远程接口必须直接或间接扩展Java.rmi.Remote接口，且必须声明为public，除非客户端于远程接口在同一包中

      2、在远程接口中的方法在声明时，除了要抛出与应用程序有关的一场之外，还必须包括RemoteException（或它的超类，IOExcepion或Exception）异常

      3、在远程方法声明中，作为参数或返回值声明的远程对象必须声明为远程接口，而非该接口的实现类。

(二) RemoteObject抽象类

        实现了Remote接口和序列化Serializable接口，它和它的子类提供RMI服务器函数。

(三) LocateRegistry final()

        类用于获得特定主机的引导远程对象注册服务器程序的引用（即创建stub），或者创建能在特定端口接收调用的远程对象注册服务程序。

服务器端：

       向其他客户机提供远程对象服务

      SomeService servcie=……；//远程对象服务

客户机端：

       向服务器提供相应的服务请求。

Registry registry=LocateRegisty.getRegistry()；
SomeService servcie=(SomeService)registry.lookup(“I serve”);
Servcie.requestService();

(四) Naming类和Registry类类似。

客户端：

      Naming.lookup(String url)

      url 格式如下"rmi://localhost/"+远程对象引用

服务器端：

     Registry registry=LocateRegistry.createRegistry(int port);
     Naming.rebind(“service”,service);

(五) RMISecurityManager类

     在RMI引用程序中，如果没有设置安全管理器，则只能从本地类路径加载stub和类，这可以确保应用程序不受由远程方法调用所下载的代码侵害

     在从远程主机下载代码之前必须执行以下代码来安装RMISecurityManager:

     System.setSecurityManager（new RMISecurityManager（））；

十一、代码开发

        为了编写一个demo，我们分为两部分，一部分是server端的代码，一部分是client端的代码，client端的代码主要是为了使用server端的代码。当然这个代码是非常简单的，只是为了说明问题，现实的使用会使比较复杂的。

(一) 我们的目的

     建立一个server端的java project，包含远程端的代码，定义接口，定义接口实现，然后在建立一个client端的java project，通过RMI使用远端服务中的方法。

(二) 我们的代码结构

(三) 远程服务代码

      1. 远程服务的接口定义

       第一步就是建立和编译服务接口的Java代码。这个接口定义了所有的提供远程服务的功能，下面是源程序：

       UserManagerInterface.java

  package cn.com.tt.rmiserver.stub;
  import java.rmi.Remote;
  import java.rmi.RemoteException;
  import cn.com.tt.rmiserver.bean.Account;
  /**
   *  author liuyazhuang
   */
  public interface UserManagerInterface extends Remote{
      public String getUserName() throws RemoteException;
     public Account getAdminAccount() throws RemoteException;
 }

    2. 接口的具体实现

    第二步就是对于上面的接口进行实现:

    UserManagerImp.java

  package cn.com.tt.rmiserver;
  
  import java.rmi.RemoteException;
  
  import cn.com.tt.rmiserver.stub.UserManagerInterface;
  import cn.com.tt.rmiserver.bean.Account;
  /**
   *  author liuyazhuang	
   */
  public class UserManagerImp implements UserManagerInterface {
      public UserManagerImp() throws RemoteException {
 
     }
     private static final long serialVersionUID = -3111492742628447261L;
 
     public String getUserName() throws RemoteException{
         return "TT";
     }
     public Account getAdminAccount() throws RemoteException{
         Account account=new Account();
         account.setUsername("TT");
         account.setPass<a href="http://www.it165.net/edu/ebg/" target="_blank" class="keylink">word</a>("123456");
         return account;
     }
 }

  3. 定义一个bean

   实现implements Serializable序列化接口。也就是可以在client和server端进行传输的可序列化对象。

      Account.java

  package cn.com.tt.rmiserver.bean;
  
  import java.io.Serializable;
  /**
   *  @author liuyazhuang	
   */
  public class Account implements Serializable,Cloneable{
      private static final long serialVersionUID = -1858518369668584532L;
      private String username;
      private String pass<a href="http://www.it165.net/edu/ebg/" target="_blank" class="keylink">word</a>;
      
     public String getUsername() {
         return username;
     }
     public void setUsername(String username) {
         this.username = username;
     }
     public String getPassword() {
         return password;
     }
     public void setPassword(String password) {
         this.password = password;
     }
 }

  4. 定义server端的主程序入口。

          Entry.java

  package cn.com.tt.rmiserver.entry;
  
  import java.rmi.AlreadyBoundException;
  import java.rmi.RemoteException;
  import java.rmi.registry.LocateRegistry;
  import java.rmi.registry.Registry;
  import java.rmi.server.UnicastRemoteObject;
  
  import cn.com.tt.rmiserver.UserManagerImp;
  import cn.com.tt.rmiserver.stub.UserManagerInterface;
  /**
   * @author liuyazhuang
   */
  public class Entry {
     public static void main(String []args) throws AlreadyBoundException, RemoteException{
         UserManagerImp userManager=new UserManagerImp();
         UserManagerInterface userManagerI=(UserManagerInterface)UnicastRemoteObject.exportObject(userManager,0);
         // Bind the remote object's stub in the registry
         Registry registry = LocateRegistry.createRegistry(2002);
        
         registry.rebind("userManager", userManagerI);
         System.out.println("server is ready");
         }
 }

(四) client端代码

    5. 新建一个java Project，导入jar包，编写客户端代码。

    6. 代码

  package weiblog.rmi;
  
  import java.rmi.NotBoundException;
  import java.rmi.RemoteException;
  import java.rmi.registry.LocateRegistry;
  import java.rmi.registry.Registry;
  
  import cn.com.tt.rmiserver.stub.UserManagerInterface;
  /**
   *  @author liuyazhuang
   */
  public class ClientEntry {
     
     public static void main(String []args){
         
         try {
             Registry registry = LocateRegistry.getRegistry("localhost",2004);
             UserManagerInterface userManager = (UserManagerInterface)registry.lookup("userManager");
             System.out.println("用户名是"+userManager.getAdminAccount().getUsername()
                     +"密码"+userManager.getAdminAccount().getPassword());
         } catch (RemoteException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         } catch (NotBoundException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
         
     }
 
 }

     7. 先运行服务器端代码， 然后运行客户端代码

    显示运行结果，客户端可以运行多次，每次都可以取得服务器端的对象。如果要再次运行客户端代码就需要更改端口号，如果不更改就会显示端口号被占用。

Java之——RMI远程过程调用（插曲）

标签：rmi   java   通信   网络   分布式   

原文地址：http://blog.csdn.net/l1028386804/article/details/45970641