`
zsmud
  • 浏览: 73388 次
  • 性别: Icon_minigender_1
  • 来自: 厦门
社区版块
存档分类
最新评论

rmi原理

阅读更多
1:RMI工作原理
        RMI的本质就是实现在不同JVM之间的调用,它的实现方法就是在两个JVM中各开一个Stub和Skeleton,二者通过socket通信来实现参数和返回值的传递。
        有关RMI的例子代码网上可以找到不少,但绝大部分都是通过extend the interface java.rmi.Remote实现,已经封装的很完善了,不免使人有雾里看花的感觉。下面的例子是我在《Enterprise JavaBeans》里看到的,虽然很粗糙,但很直观,利于很快了解它的工作原理。

1. 定义一个Person的接口,其中有两个business method, getAge() 和getName()

代码:
public interface Person { 
      public int getAge() throws Throwable; 
      public String getName() throws Throwable; 
} 

2. Person的实现PersonServer类
代码:

public class PersonServer implements Person { 
      int age; 
      String name; 

      public PersonServer(String name, int age) { 
          this.age = age; 
          this.name = name; 
      } 

      public int getAge() { 
          return age; 
      } 

      public String getName() { 
          return name; 
      } 
} 


3. 好,我们现在要在Client机器上调用getAge()和getName()这两个business

method,那么就得编写相应的Stub(Client端)和Skeleton(Server端)程序。这是Stub的实现:
代码:

import java.io.ObjectOutputStream; 
import java.io.ObjectInputStream; 
import java.net.Socket; 

public class Person_Stub implements Person { 
      Socket socket; 

      public Person_Stub() throws Throwable { 
          // connect to skeleton 
          socket = new Socket("computer_name", 9000); 
      } 

      public int getAge() throws Throwable { 
          // pass method name to skeleton 
          ObjectOutputStream outStream = 
              new ObjectOutputStream(socket.getOutputStream()); 
          outStream.writeObject("age"); 
          outStream.flush(); 

          ObjectInputStream inStream = 
              new ObjectInputStream(socket.getInputStream()); 
          return inStream.readInt(); 
      } 

      public String getName() throws Throwable { 
          // pass method name to skeleton 
          ObjectOutputStream outStream = 
              new ObjectOutputStream(socket.getOutputStream()); 
          outStream.writeObject("name"); 
          outStream.flush(); 

          ObjectInputStream inStream = 
              new ObjectInputStream(socket.getInputStream()); 
          return (String)inStream.readObject(); 
      } 
} 


注意,Person_Stub和PersonServer一样,都implements
Person。它们都实现了getAge()和getName()两个business
method,不同的是PersonServer是真的实现,Person_Stub是建立socket连接,并向Skeleton发请求,然后通过
Skeleton调用PersonServer的方法,最后接收返回的结果。

4. Skeleton实现
代码:
import java.io.ObjectOutputStream; 
import java.io.ObjectInputStream; 
import java.net.Socket; 
import java.net.ServerSocket; 

public class Person_Skeleton extends Thread { 
      PersonServer myServer; 

      public Person_Skeleton(PersonServer server) { 
          // get reference of object server 
          this.myServer = server; 
      } 

      public void run() { 
          try { 
              // new socket at port 9000 
              ServerSocket serverSocket = new ServerSocket(9000); 
              // accept stub's request 
              Socket socket = serverSocket.accept(); 

              while (socket != null) { 
                  // get stub's request 
                  ObjectInputStream inStream = 
                      new ObjectInputStream(socket.getInputStream()); 
                  String method = (String)inStream.readObject(); 

                  // check method name 
                  if (method.equals("age")) { 
                      // execute object server's business method 
                      int age = myServer.getAge(); 
                      ObjectOutputStream outStream = 
                          new ObjectOutputStream(socket.getOutputStream()); 

                      // return result to stub 
                      outStream.writeInt(age); 
                      outStream.flush(); 
                  } 

                  if(method.equals("name")) { 
                      // execute object server's business method 
                      String name = myServer.getName(); 
                      ObjectOutputStream outStream = 
                          new ObjectOutputStream(socket.getOutputStream()); 

                      // return result to stub 
                      outStream.writeObject(name); 
                      outStream.flush(); 
                  } 
              } 
          } catch(Throwable t) { 
              t.printStackTrace(); 
              System.exit(0); 
          } 
      } 

      public static void main(String args []) { 
          // new object server 
          PersonServer person = new PersonServer("Richard", 34); 

          Person_Skeleton skel = new Person_Skeleton(person); 
          skel.start(); 
      } 
} 

Skeleton类 extends from Thread,它长驻在后台运行,随时接收client发过来的request。并根据发送过来的
key去调用相应的business method。

5. 最后一个,Client的实现
代码:
public class PersonClient { 
      public static void main(String [] args) { 
          try { 
              Person person = new Person_Stub(); 
              int age = person.getAge(); 
              String name = person.getName(); 
              System.out.println(name + " is " + age + " years old"); 
          } catch(Throwable t) { 
              t.printStackTrace(); 
          } 
      } 
} 

Client的本质是,它要知道Person接口的定义,并实例一个Person_Stub,通过Stub来调用business method,
至于Stub怎么去和Server沟通,Client就不用管了。
注意它的写法:
Person person = new Person_Stub(); 

而不是
Person_Stub person = new Person_Stub(); 

为什么?因为要面向接口编程嘛,呵呵。
// RMI实质上就是生成2个类stub,skeleton来进行参数和返回值的传递,采用值传递方式
// 类似于以前写的聊天室程序,被传递的对象应实现java.io.Serializable接口
分享到:
评论

相关推荐

    rmi原理及应用ppt

    ### RMI原理及应用知识点详解 #### 一、RMI简介与背景 - **RMI (Remote Method Invocation)** 是一种允许在不同的Java虚拟机(JVM)之间调用方法的技术。它使得开发人员能够像调用本地对象一样调用远程对象的方法,极...

    RMI原理及应用详解

    **RMI原理及应用详解** 远程方法调用(Remote Method Invocation,简称RMI)是Java平台提供的一种分布式计算技术,允许在不同的Java虚拟机(JVM)之间进行对象方法的透明调用。RMI的核心思想是使Java对象能够跨越...

    RMI原理及实现

    **RMI原理及实现** 远程方法调用(Remote Method Invocation,简称RMI)是Java平台上的一个核心特性,它允许Java对象在不同的JVM之间进行交互。RMI为分布式计算提供了一个简单而强大的模型,使得开发者可以像调用...

    RMI原理及实现(JAVA)

    【RMI原理详解】 远程方法调用(RMI,Remote Method Invocation)是Java提供的一种用于在分布式环境中调用远程对象的方法。RMI的核心思想是使客户端可以像调用本地对象一样调用远程对象,实现这一目标的关键在于...

    rmi原理-chn-pdf

    ### RMI原理详解 #### 前言与背景 RMI(Remote Method Invocation,远程方法调用)是一种Java平台上的技术,它允许开发者在不同JVM间的对象间进行方法调用,就像是本地方法调用一样简单。这项技术的出现极大地简化...

    rmi原理与入门demo.zip

    在“rmi原理与入门demo”这个压缩包中,你可能找到以下内容: 1. **源码示例**:包含了客户端和服务器端的Java源代码,展示了如何创建远程接口、实现远程对象、注册远程对象以及进行远程方法调用。 2. **编译与...

    RMI原理.xls

    RMI原理.xls

    RMI原理及实现,ppt格式

    以下是对RMI原理和实现的详细解释: 1. **RMI的基本概念**: - RMI是Java中的一个特性,允许对象在不同的网络节点之间进行交互,执行远程对象的方法。 - RMI调用对最终用户是透明的,意味着用户无需关心方法实际...

    RMI原理详解

    **远程方法调用(Remote Method Invocation,RMI)原理详解** 远程方法调用(RMI)是Java平台上的一个核心特性,它允许Java程序在不同的Java虚拟机(JVM)之间进行分布式通信,使得对象可以像调用本地方法一样调用...

    基于JAVA RMI的聊天室

    JAVA RMI原理 RMI允许Java对象在不同的Java虚拟机之间进行方法调用,就像是在同一台机器上操作本地对象一样。它包括三个主要组件:远程接口、远程对象和RMI注册表。远程接口定义了可以在远程对象上调用的方法,...

    java rmi HelloWorld版(源码)

    详细的学习过程可以参考提供的博客链接,其中应该包含了如何编译、运行和测试这个HelloWorld示例的步骤,以及更深入的RMI原理和技术细节。通过这个简单的例子,你可以理解RMI的工作机制,并为更复杂的分布式系统打下...

    liaotianshi.rar_RMI聊天室_java 网络_rmi _rmi 聊天_网络聊天室

    **RMI原理:** RMI的核心思想是将对象的实例化和方法调用过程解耦,使得远程对象可以像本地对象一样被调用。在RMI中,服务器端创建远程对象并注册到RMI注册表,客户端通过查找注册表获得远程对象引用,然后就可以像...

    Spring-RMI.rar_spring rmi

    1.1 RMI原理:RMI的核心在于Java的`java.rmi`包,它定义了接口和类来创建远程对象并进行调用。远程对象需继承`java.rmi.Remote`接口,并声明所有远程方法抛出`java.rmi.RemoteException`。 1.2 Spring的RMI支持:...

    dubbo_ demo、角色_ RPC_原理 _RMI .zip

    RMI原理包括以下关键部分: 1. **接口定义**:服务提供者和消费者共享相同的接口定义,确保调用的一致性。 2. ** stub和skeleton**:Stub作为客户端代理,负责将本地调用转换为网络消息;Skeleton在服务端接收这些...

    RMI RMI-IIOP 客户端服务器交互

    **RMI原理:** 1. **对象序列化**:RMI的核心在于将Java对象转换为字节流,以便在网络中传输。这个过程称为序列化。 2. **接口定义**:服务端定义一个远程接口,该接口包含可被远程调用的方法。客户端通过此接口与...

    基于RMI和Socket的带数据库的java聊天软件 客户端和服务器端

    1. **RMI原理与应用**: RMI的核心思想是将Java对象作为服务暴露在网络中,客户端通过接口调用远程对象的方法。在Java聊天软件中,服务器端可能会创建一个`ChatServer`类,实现了`ChatService`接口,该接口定义了如...

    分布式计算-Java RMI实践

    **RMI原理** RMI的核心概念是远程对象,这些对象可以像本地对象一样被调用,但实际上它们可能位于网络的另一端。以下为RMI的工作流程: 1. **定义接口**:首先,我们需要定义一个Java接口,该接口声明了可远程调用...

    RMI远程下载文件

    通过上述分析,我们可以看出"RMI远程下载文件"涉及到Java网络编程的核心技术,包括RMI原理、接口设计、文件操作、安全策略以及客户端与服务器端的交互流程。理解并掌握这些知识点对于开发分布式系统或进行远程服务...

    JAVA-RMI使用快速入门.doc

    RMI原理与介绍** RMI的核心在于,它让Java开发者能够像调用本地方法一样调用远程对象的方法。JRMP协议是专门为Java远程对象设计的,因此RMI系统完全基于Java,具备高度的可移植性和安全性。不过,由于协议的特定性...

Global site tag (gtag.js) - Google Analytics