posts - 495,comments - 227,trackbacks - 0
一 .RMI概述
RMI(Remote Method Invocation)
    RMI是分布式对象软件包,它简化了在多台计算机上的JAVA应用之间的通信。必须在jdk1.1以上

RMI用到的类
     java.rmi.Remote                   所有可以被远程调用的对象都必须实现该接口
     java.rmi.server.UnicastRemoteObject  所有可以被远程调用的对象都必须扩展该类
 
什么是RMI
    远程方法调用是一种计算机之间对象互相调用对方函数,启动对方进程的一种机制,
使用这种机制,某一台计算机上的对象在调用另外一台计算机上的方法时,使用的程
序语法规则和在本地机上对象间的方法调用的语法规则一样。

优点
这种机制给分布计算的系统设计、编程都带来了极大的方便。
只要按照RMI规则设计程序,可以不必再过问在RMI之下的网络细节了,如:TCP和Socket等等。
任意两台计算机之间的通讯完全由RMI负责。调用远程计算机上的对象就像本地对象一样方便。
 
1、面向对象:
RMI可将完整的对象作为参数和返回值进行传递,而不仅仅是预定义的数据类型。
也就是说,可以将类似Java哈西表这样的复杂类型作为一个参数进行传递。
 
2、可移动属性:
RMI可将属性从客户机移动到服务器,或者从服务器移动到客户机。
 
3、设计方式:
对象传递功能使您可以在分布式计算中充分利用面向对象技术的强大功能,如二层和三层结构系统。
如果用户能够传递属性,那么就可以在自己的解决方案中使用面向对象的设计方式。
所有面向对象的设计方式无不依靠不同的属性来发挥功能,如果不能传递完整的对象——包括实现和类型
——就会失去设计方式上所提供的优点。
 
4、安全性:
RMI使用Java内置的安全机制保证下载执行程序时用户系统的安全。
RMI使用专门为保护系统免遭恶意小程序侵害而设计的安全管理程序。
5、便于编写和使用
RMI使得Java远程服务程序和访问这些服务程序的Java客户程序的编写工作变得轻松、简单。
远程接口实际上就是Java接口。
为了实现RMI的功能必须创建远程对象任何可以被远程调用的对象必须实现远程接口。但远程
接口本身并不包含任何方法。因而需要创建一个新的接口来扩展远程接口。
新接口将包含所有可以远程调用的方法。远程对象必须实现这个新接口,由于新的接口扩展了
远程接口,实现了新接口,就满足了远程对象对实现远程接口的要求,所实现的每个对象都将
作为远程对象引用。
 
个人总结:
    RMI说白了,就是提供了一种远程的方法调用。 这种调用简单方便,可以传递复杂java对象。现在流行的j2ee中的EJB的底层实现技术就是RMI,EJB的调用就是经过封装的,更高级的RMI调用。


下面我们就来写一个RMI的程序:
 
一.创建RMI程序的6个步骤:
1、定义一个远程接口的接口,该接口中的每一个方法必须声明它将产生一个RemoteException异常。
2、定义一个实现该接口的类。
3、使用RMIC程序生成远程实现所需的残根和框架。
4、创建一个服务器,用于发布2中写好的类。
5. 创建一个客户程序进行RMI调用。
6、启动rmiRegistry并运行自己的远程服务器和客户程序。
 
二. 程序详细说明
 
1.定义一个远程接口的接口,该接口中的每一个方法必须声明它将产生一个RemoteException异常。
 
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface I_Hello extends java.rmi.Remote   //需要从Remote继承
{
       public String SayHello() throws RemoteException;   //需要抛出remote异常
}

   上面例子我们定义一个返回字符串的远程方法 SayHello(),这个远程接口 I_Hello必须是public的 ,它必须从java.rmi.Remote继承而来,接口中的每一个方法都必须抛出远程异常java.rmi.RemoteException。

抛出这个异常的原因
由于任何远程方法调用实际上要进行许多低级网络操作,因此网络错误可能在调用过程中随时发生。
因此,所有的RMI操作都应放到try-catch块中。
  
2、定义一个实现该接口的类。
 
 import java.io.PrintStream;
import java.rmi.*;
import java.rmi.server.UnicastRemoteObject;
 
public class Hello extends UnicastRemoteObject   //必须从UnicastRemoteObject  继承
                   implements I_Hello
{
        public Hello() throws RemoteException     //需要一个抛出Remote异常的默认初始化方法
        {
        }
 
        public String SayHello()     //这个是实现I_Hello接口的方法
        {
           return "Hello world !!";
        }
}
 
实现接口的类必须继承UnicastRemoteObject类。
扩展java.rmi.server.UnicastRemoteObject
UnicastRemoteObject顾名思义,是让客户机与服务器对象实例建立一对一的连接。
 
3、使用RMIC程序生成远程实现所需的残根Stub 和 框架。
   2中的Hello 编译好以后,我们就可以用RMIC命令来生成残根Stub
   在Dos窗口里,到Hello.class 所在目录,运行以下命令:
   rmic Hello
   
   命令执行完以后,将会在当前目录生成一个 Hello_Stub.class 这个就是我们远程调用时需要的类
 
参考:
在RMI中,客户机上生成的调动调用参数和反调动返回值的代码称为残根。有的书上称这部分代码为“主干”。
服务器上生成的反调动调用参数和进行实际方法调用调动返回值的代码称为框架。
生成残根和框架的工具
Rmic命令行工具(RMI Compiler)
格式:
Rmic classname
 
4、创建一个服务器,用于发布2中写好的类。
 
    import java.rmi.*;
public class RMI_Server
{
    public static void main(String[] args)
    {
        try
        {
            Hello hello = new Hello();                //实例化要发布的类
            Naming.rebind("RMI_Hello", hello);      //绑定RMI名称 进行发布
            System.out.println("=== Hello server Ready === ");
        }
        catch(Exception exception)
        {
            exception.printStackTrace();
        }
    }
}
 
5. 创建一个客户程序进行RMI调用。
 
import java.rmi.*;
public class RMI_Client {
    public static void main(String[] args) {
        try
        {
           I_Hello hello = (I_Hello) Naming.lookup("RMI_Hello");  //通过RMI名称查找远程对象
            System.out.println(hello.SayHello());                        //调用远程对象的方法
        } catch (Exception e)
        {
          e.printStackTrace();
        }
    }

}

Naming.lookup("RMI_Hello") 其中的参数“RMI_Hello”只是针对本机的RMI查找,如果是异地的RMI调用请参照  rmi://127.0.0.1:1099/RMI_Hello       端口1099是默认的RMI端口,如果你启动 rmiregistry 的时候(见第6点)没有指定特殊的端口号,默认就是1099
 
到此 我们 所有的代码编写都完成了,不过不要急着去运行,请跟随第6点去运行,因为rmi 调用还会遇到一些特别的情况,偶花了牛劲,才找到原因的,许多刚用RMI的人,常常被这些问题搞得吐血
 
6、启动rmiRegistry并运行自己的远程服务器和客户程序。
 1)服务器的运行
    先在DOS下运行 rmiregistry     这个命令是开启RMI的注册服务,开启以后我们的server程序才能调用rebing方法发布我们的类
 
    然后,运行我们的server程序  RMI_Server    这里是最容易出错的,参见下面注意事项。
     注意:
         如果提示找不到Stub类,这个需要用下面的命令来运行
 java.exe -Djava.rmi.server.codebase=file:/E:\MIS_Interface\momo\TestEasy\classes/  RMI_Server
 
蓝字部分指定了stub类的路径。
 
  有人会问,我已经把stub 通过-classpath 加到类路径里面了,为什么还没有提示这个错误呢?原因是这样的: 这里提示的找不到stub类,不是由你写的RMI_Server这个程序引起的,是由rmi注册服务器报告的异常,也就是我们前面启动的 rmiregistry ,因为你写的RMI_Server 要求RMI注册服务器注册一个新的类,自然RMI服务器必须知道你的类放在哪里,所以我们通过  -Djava.rmi.server.codebase 这个运行参数来指定
  你也可以通过修改操作系统的classpath 环境变量 来指定stub的位置,只不过太麻烦
 
2) 客户端的运行
      直接运行RMI_Client  即可  注意 把 Stub 和 接口 I_Hello 加到类路径里
  
    通常第一次运行 客户端都会报一个错误:   Access  XXXX 不记得具体的了,反正就是“访问权限限制”, 这是因为RMI的服务需要授权,外部程序才能访问,所以我们要改动 jre的安全配置文件,来开放权限,  具体如下:
 
   打开你的jdk目录下的这个文件 C:\Program Files\Java\jdk1.5.0_04\jre\lib\security\java.policy
在文件最后加入下面代码:
 grant {
           permission java.net.SocketPermission "*:1024-65535",
                "connect,accept";
           permission java.net.SocketPermission "*:80","connect";
        };
此代码,开放了端口的connect访问权限
 
注意 你应该修改服务器那台机子的安全配置文件,也就是你运行 rmiregistry 和 RMI_Server的机子
另外,很多人修改完以后,仍然报这个错误,多数情况是由于你没有修改到正确的jdk 下的文件,而是修改到其他jdk的文件, 我们安装oracle , Weblogic等等软件的时候都会自带一个 jdk,他们会自动在操作系统的环境变量里面 加入jdk的路径,所以,你先要确定你运行服务器端程序是用哪个jdk,再修改这个jdk下的配置文件,确定当前jdk的路径很简单  开始 -》运行-》rmiregistry 看看这个DOS窗口标题 的路径,就是你当前系统默认jdk的路径了
 
客户端正常运行以后,就会出现以下结果:
Hello world !!

这些字符是通过RMI调用远程服务器的类返回的结果 

RMI 实例

 

Calculator.java

import java.rmi.Remote;

public interface Calculator  extends Remote 


 
    
public long add(long a, long b)  throws java.rmi.RemoteException ;
 
    
public long sub(long a, long b)  throws java.rmi.RemoteException ; 
   
    
public long mul(long a, long b)  throws java.rmi.RemoteException ; 
    
    
public long div(long a, long b)  throws java.rmi.RemoteException ; 
  
}
 

CalculatorClient.java:

import java.rmi.Naming; 
import java.rmi.RemoteException; 
import java.net.MalformedURLException; 
import java.rmi.NotBoundException; 

public class CalculatorClient 

    
public static void main(String[] args) 
        
try 
         Calculator c 
= (Calculator)
                           Naming.lookup(
                 
"rmi://localhost/CalculatorService"); 
            System.out.println( c.sub(
43) ); 
            System.out.println( c.add(
45) ); 
            System.out.println( c.mul(
36) ); 
            System.out.println( c.div(
93) ); 
        }
 
        
catch (MalformedURLException murle) 
            System.out.println(); 
            System.out.println(
              
"MalformedURLException"); 
            System.out.println(murle); 
        }
 
        
catch (RemoteException re) 
            System.out.println(); 
            System.out.println(
                        
"RemoteException"); 
            System.out.println(re); 
        }
 
        
catch (NotBoundException nbe) 
            System.out.println(); 
            System.out.println(
                       
"NotBoundException"); 
            System.out.println(nbe); 
        }
 
        
catch (
            java.lang.ArithmeticException
                                      ae) 

            System.out.println(); 
            System.out.println(
             
"java.lang.ArithmeticException"); 
            System.out.println(ae); 
        }
 
    }
 
}
 


CalculatorImpl.java:

import java.rmi.server.UnicastRemoteObject;

public class CalculatorImpl extends UnicastRemoteObject implements Calculator


    
// 这个实现必须有一个显式的构造函数,并且要抛出一个RemoteException异常 
    public CalculatorImpl() 
        
throws java.rmi.RemoteException 
        
super(); 
    }
 

    
public long add(long a, long b) 
        
throws java.rmi.RemoteException 
        
return a + b; 
    }
 

    
public long sub(long a, long b) 
        
throws java.rmi.RemoteException 
        
return a - b; 
    }
 

    
public long mul(long a, long b) 
        
throws java.rmi.RemoteException 
        
return a * b; 
    }
 

    
public long div(long a, long b) 
        
throws java.rmi.RemoteException 
        
return a / b; 
    }
 
}
 


CalculatorRemoteClient.java:


import java.rmi.Naming; 
import java.rmi.RemoteException; 
import java.net.MalformedURLException; 
import java.rmi.NotBoundException; 

public class CalculatorRemoteClient 

    
public static void main(String[] args) 
        
try 
            Calculator c 
= (Calculator)
                           Naming.lookup(
                 
"rmi://10.10.11.209/CalculatorService"); 
            System.out.println( c.sub(
43) ); 
            System.out.println( c.add(
45) ); 
            System.out.println( c.mul(
36) ); 
            System.out.println( c.div(
93) ); 
        }
 
        
catch (MalformedURLException murle) 
            System.out.println(); 
            System.out.println(
              
"MalformedURLException"); 
            System.out.println(murle); 
        }
 
        
catch (RemoteException re) 
            System.out.println(); 
            System.out.println(
                        
"RemoteException"); 
            System.out.println(re); 
        }
 
        
catch (NotBoundException nbe) 
            System.out.println(); 
            System.out.println(
                       
"NotBoundException"); 
            System.out.println(nbe); 
        }
 
        
catch (
            java.lang.ArithmeticException
                                      ae) 

            System.out.println(); 
            System.out.println(
             
"java.lang.ArithmeticException"); 
            System.out.println(ae); 
        }
 
    }
 
}
 


CalculatorServer.java:

import java.rmi.Naming;

public class CalculatorServer {

   
public CalculatorServer() {
     
try {
       Calculator c 
= new CalculatorImpl();
       Naming.rebind(
"rmi://localhost:1099/CalculatorService", c);
     }
 catch (Exception e) {
       System.out.println(
"Trouble: " + e);
     }

   }


   
public static void main(String args[]) {
     
new CalculatorServer();
   }

}


 

第二个

服务端代码

Multi.java
import java.rmi.*;

public interface Multi extends Remote {
    
int multi(int a, int b) throws RemoteException;
}



Plus.java
import java.rmi.*;

public interface Plus extends Remote{
    
int plus(int a, int b) throws RemoteException;
}


MultiImpl.java
import java.rmi.*;
import java.rmi.server.UnicastRemoteObject;

public class MultiImpl extends UnicastRemoteObject implements Multi{
    
private String name;
    
public MultiImpl(String s) throws Exception{
        
super();
        name 
= s;
    }

    
    
public int multi(int a, int b) throws RemoteException {
        System.out.println(
"Invoke the multiply");
        
return (a * b);
    }

}


PlusImpl.java
import java.rmi.*;
import java.rmi.server.UnicastRemoteObject;

public class PlusImpl extends UnicastRemoteObject implements Plus {
    
private String name;
    
public PlusImpl (String s) throws RemoteException {
        
super();
        name 
= s;
    }

    
    
public int plus(int a, int b) throws RemoteException {
        System.out.println(
"Invoke the add");
        
return (a + b);
    }

}


CMSServer.java
import java.rmi.*;

public class CMSServer {
    
public CMSServer(){
        
super();
    }

    
    
public static void main (String[] args) {
        
//SYstem.setSecurityManager(new RMISecurityManager());
        try{
            
new CMSServer();
            MultiImpl mI 
= new MultiImpl("MultiServer");
            PlusImpl pI 
= new PlusImpl("PlusServer");
            
            Naming.rebind(
"pluscxx",pI);
            Naming.rebind(
"multicxx",mI);
            System.out.println(
"pluscxx and multicxx bound in registry");
        
        }
 catch(Exception e) {
            System.out.println(
"pluscxx and multicxx err: " + e.getMessage());
        }

    }

}


客户端代码

Multi.java
import java.rmi.*;

public interface Multi extends Remote {
    
int multi(int a, int b) throws RemoteException;
}


Plus.java
import java.rmi.*;

public interface Plus extends Remote{
    
int plus(int a, int b) throws RemoteException;
}


Frame1.java
import java.awt.*;
import java.rmi.*;
import java.awt.event.*;
import javax.swing.*;


public class Frame1 extends JFrame {
    Container container;
    
    
private JTextField jTextFields[];
    
private JLabel jLabels[];
    
private JButton jButton;
    
private String[] labelsName = {"    Num1""    Num2""    Num3" ,"    plus then multiply" };
    
    
    
public Frame1() {
        
super("sigle client multi server");
        
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        
//enableEvents(AWTEvent.WINDOW_EVENT_MASK);
        container = getContentPane();
        container.setLayout(
new GridLayout(5,2,10,10));
        jLabels 
= new JLabel[4];
        jTextFields 
= new JTextField[4];
        
int i = 0;
        
for(i = 0; i < 4; i++{
            jLabels[i] 
= new JLabel(labelsName[i]);
            jTextFields[i] 
= new JTextField("jTextField" + i);
            
//jTextFields[i].addActionListener(new Handler());
            container.add(jLabels[i]);
            container.add(jTextFields[i]);
        }

        jButton 
= new JButton("Compute");
        container.add(jButton);
        jButton.addActionListener(
new Handler());
        
        
this.setSize(new Dimension(400300));
        
this.setVisible(true);
    }

    
    
private class Handler implements ActionListener{
        
public void actionPerformed(ActionEvent ae) {
            
if(ae.getActionCommand().equals("Compute")) {
                
int[] num = new int [3];
                
int i = 0;
                
for(i = 0; i < 3; i++{
                    num[i] 
= Integer.parseInt(jTextFields[i].getText());
                }

                
try{
                    Plus p 
= (Plus)Naming.lookup("pluscxx");
                    System.out.println(
"Found plus object");    
                    
int sum = p.plus(num[0], num[1]);
                    System.out.println(
"Add the first two number");
                    Multi m 
= (Multi)Naming.lookup("multicxx");
                    System.out.println(
"Found multi object");
                    
int multiply2 = m.multi(sum, num [2]);
                    System.out.println(
"Multi with the last number");
                    System.out.println(
"result is:" + multiply2);
                    jTextFields[
3].setText("" + multiply2);
                    
//container.validate();
                    System.out.println("OK");
                }
 catch(Exception ex) {
                    System.out.println(ex.getMessage());
                }

            }

        }
        
    }

    
    
public static void main(String[] args) {
        
new Frame1();
    }

}



引用地址:http://blog.csdn.net/tgeh23/archive/2008/03/14/2183746.aspx 

 

posted on 2008-04-03 13:32 SIMONE 阅读(1177) 评论(2)  编辑  收藏 所属分类: rmi

FeedBack:
# re: java RMI 相关
2011-12-02 15:56 | 劳资
你这里好像有点小问题,我自己解决了,不错。  回复  更多评论
  
# re: java RMI 相关
2013-08-22 16:32 | ekkny
@劳资
服务端和客户端分离,怎么通信 ?  回复  更多评论
  

只有注册用户登录后才能发表评论。


网站导航: