码迷,mamicode.com
首页 > 其他好文 > 详细

RMI学习笔记

时间:2016-04-07 18:32:53      阅读:194      评论:0      收藏:0      [点我收藏+]

标签:

一个//ip:port/name可以唯一定位一个RMI服务器上的发布了的对象

其中 host 是注册表所在的主机(远程或本地),port 是注册表接受调用的端口号,name 是未经注册表解释的简单字符串。host 和 port 两者都是可选项。如果省略了 host,则主机默认为本地主机。如果省略了 port,则端口默认为 1099,该端口是 RMI 的注册表 rmiregistry 使用的“著名”端口。

 

简单说下工作的原理:

这里假设RMI有3个部分构成,第一个是RMIService即JDK提供的一个可以独立运行的程序(bin目录下的rmiregistry),第二个是RMIServer即我们自己编写的一个java项目,这个项目对外提供服务。第三个是RMIClient即我们自己编写的另外一个java项目,这个项目远程使用RMIServer提供的服务。

首先,RMIService必须先启动并开始监听对应的端口。

其次,RMIServer将自己提供的服务的实现类注册到RMIService上,并指定一个访问的路径(或者说名称)供RMIClient使用。

最后,RMIClient使用事先知道(或和RMIServer约定好)的路径(或名称)到RMIService上去寻找这个服务,并使用这个服务在本地的接口调用服务的具体方法。

通俗的讲完了再稍微技术的讲下:

首先,在一个JVM中启动rmiregistry服务,启动时可以指定服务监听的端口,也可以使用默认的端口。

其次,RMIServer在本地先实例化一个提供服务的实现类,然后通过RMI提供的Naming,Context,Registry等类的bind或rebind方法将刚才实例化好的实现类注册到RMIService上并对外暴露一个名称。

最后,RMIClient通过本地的接口和一个已知的名称(即RMIServer暴露出的名称)再使用RMI提供的Naming,Context,Registry等类的lookup方法从RMIService那拿到实现类。这样虽然本地没有这个类的实现类,但所有的方法都在接口里了,想怎么调就怎么调吧。

值得注意的是理论上讲RMIService,RMIServer,RMIClient可以部署到3个不同的JVM中,这个时候的执行的顺序是RMIService---RMIServer—RMIClient。另外也可以由RMIServer来启动RMIService这时候执行的顺序是RMIServer—RMIService—RMIClient。

除了这些外再说几点理论上的废话:

1、使用RMI的时候RMIClient需要知道RMIServer注册时暴露出来的路径或名称。

2、RMIClient要有实现类的接口。

3、接口一定要继承Remote。

4、实现类除了实现接口外还要实现Serializable接口,有需要的话还要继承UnicastRemoteObject

 

 

RMI的基础是接口,RMI构架基于一个重要的原理:定义接口和定义接口的具体实现是分开的。 

一个简单的RMI系统,一般可以分成4个文件,下面来介绍各个文件的创建和作用 

第一步:创建一个远程对象接口 

import java.rmi.Remote; 
import java.rmi.RemoteException; 

/* 
* 这个接口继承自Remote,每一个定义的方法都必须抛出一个RemoteException异常对象 
* 我们可供远程调用的方法就是通过这里开公开 
*/ 
public interface IRMI extends Remote{ 
    public String invoke() throws RemoteException; 


第二步:创建接口的具体实现类 

import java.rmi.RemoteException; 
import java.rmi.server.UnicastRemoteObject; 

/* 
* 远程对象的实现 
* 公开方法的具体实现就是这里定义的 
*/ 
public class IRMIImpl extends UnicastRemoteObject implements IRMI { 
    
    protected IRMIImpl() throws RemoteException { 
        super(); // 这个实现必须有一个显式的构造函数,并且要抛出一个RemoteException异常 
    } 
    
    private static final long serialVersionUID = 6131922116577454476L; 
    
    public String invoke() throws RemoteException {  //该方法公开 
        return "hello,world!"; 
    } 
    
    public String tryInvoke() throws RemoteException{ //该方法未公开,若要公开请在接口中定义 
       return "try to remote me"; 
    } 


第三步:创建RMI服务器 

import java.rmi.Naming; 
import java.rmi.registry.LocateRegistry; 
import java.rmi.registry.Registry; 

/* 
* 远程对象的注册类 该类应该在服务器端执行,执行之后 
* 该机器将变为RMI服务器 客户端可以通过正确的url来访问 
* 服务器上的远程对象,执行对外报露的方法 
*/ 

public class RMIServer { 
    static int port = 8888; 
   
    /* 
     * 创建一个Registry对象. 
     * LocateRegistry用于获取名字服务或创建名字服务. 
     * 调用LocateRegistry.createRegistry(int port)方法可以在某一特定端口创建名字服务,从而用户无需再手工启动rmiregistry 
     * @return 返回一个Registry对象 
     */ 
    private static Registry createRegistry() { 
        Registry registry = null; 
        try { 
            registry = LocateRegistry.getRegistry(port); //如果该端口未被注册,则抛异常 
            registry.list(); //拿到该端口注册的rmi对象 
        } catch (final Exception e) { 
            try { 
                registry = LocateRegistry.createRegistry(port);//捕获异常,端口注册 
            } catch (final Exception ee) { 
                ee.printStackTrace(); 
            } 
        } 
        return registry; 
    } 

    /** 
     * 将对象注册到rmi服务器上 
     */ 
    public static void bind() { 
        Registry registry =  createRegistry(); 
        try { 
            IRMIImpl impl = new IRMIImpl(); 
            registry.rebind("mytask", impl); //这就是绑定,client里lookup必须和"mytast"一样才能远程调用impl 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 

   public static void main(String[] args) { 
        try { 
            bind(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 


上面是一种比较好的写法,如果只是要测试,可以直接在main()方法中写: 

    ImplementClass ic = new ImplementClass(); //具体实现类 
    Registry r = LocateRegistry.createRegistry(8888); 
    r.bind("mytask", ic); 
    //Naming.rebind("rmi://localhost:8888/mytask", ic); 可替换上句 

1.注册一个端口  2.在注册端口绑定taskName和implementClass  3.客户端就可以通过url和taskName来找到implementClass。 

第四步:创建RMI客户端 

import java.rmi.Naming; 

public class RMIClient { 
    /** 
     * 调用远程对象中的方法 
     * @throws Exception 
     */ 
    public static void getRemoteObject() throws Exception{ 
    
    /*得到远程发布的服务 
    返回与指定 name 关联的远程对象的引用(一个stub)*/ 
        IRMI obj = (IRMI)Naming.lookup("rmi://localhost:"+RMIServer.port+"/mytask");  //注:通过接口拿 

        System.out.println(obj.invoke()); //调用远程服务的方法 
    } 

    public static void main(String[] args) { 
        try { 
            getRemoteObject(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 


实际使用过程中遇到奇怪情况

registry.rebind("bpserver", ic);绑定服务就一直不动

换成Naming.rebind("rmi://localhost:2005/bpserver", ic); 就可以,其中原理待研究?

 

参考

http://skanion.iteye.com/blog/1168747

http://blog.sina.com.cn/s/blog_4918a7d90100oftg.html

RMI学习笔记

标签:

原文地址:http://www.cnblogs.com/luluQQ/p/5364705.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!