RMI例子

对RMI知识做个总结，顺便练习自己的博客水平。

RMI的总结规划如下：1  一个简单的RMI例子   2 一个简单的Sping-remoting RMI例子  3 给出一个使用注解减少RMI配置的一个例子  4  简单分析Spring-remoting RMI的源码  5 简单分析下RMI的Registry,Naming,Activation Framework等。需要注意的是给出的例子基于JDK5.0+，不使用rmic编译器。

第一篇：一个简单的RMI 例子
定义：RMI是RPC的JAVA实现，服务提供者和服务使用者都必须是JAVA实现。RMI使用序列化机制通过Socket进行信息的传递。关于RMI的QoS在后面会有简单的讨论。

 

应用层工作模型（仅限于Registry机制，不考虑Activation）:

• 服务提供者（RemoteObject）
• 服务映射和暴露策略（Naming Service和Registry）
• 服务使用者（RemoteRef）

服务提供者就是提供远程服务的对象，在代码中表现为接口及其实现类，请看下面代码：

 

package com.neil.server.service;

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

/**
 * 服务接口必须extends Remote
 * @author nei.zhang
 * 
 */
public interface IAccountService extends Remote
{
    /**
     * 接口方法必须throws RemoteException
     */
    int account(int a, int b)
        throws RemoteException;
    
}





package com.neil.server.service.impl;

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

import com.neil.server.service.IAccountService;

/**
 * 
 * @author nei.zhang 实现类必须
 */
public class AccountServiceImpl extends UnicastRemoteObject implements IAccountService
{
    
    public AccountServiceImpl()
        throws RemoteException
    {
        super();
    }
    
    /**
     * serialVersionUID
     */
    private static final long serialVersionUID = 1L;
    
    public int account(int a, int b)
        throws RemoteException
    {
        // 简单返回result
        return a + b;
    }
    
    // 可以订制序列化
    
}

 

 

 

服务映射和暴露策略是把对象注册到指定的Registry。RMI中的Registry可以简单理解成key-value的字典。key是serviceName，value是一个RemoteRef即一个服务对象（serviceObject）的引用。具体请看代码：

 

package com.neil.server.core;

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

import com.neil.server.service.IAccountService;
import com.neil.server.service.impl.AccountServiceImpl;

/**
 * 完成server的注册，暂时不考虑SecurityManager
 * @author nei.zhang
 * 
 */
public class StartupServer
{
    public static void main(String[] args)
        throws Exception
    {
        
        LocateRegistry.createRegistry(1099);
        
        IAccountService accountService = new AccountServiceImpl();
        
        // 绑定service，这里写死了IP，在生产环境下需要注意是IP和机器名的对应关系，否则容易见到常见的Connection refused异常
        Naming.rebind("//192.168.1.254:1099/accountService", accountService);
        
        //请原谅这个sysout
        System.out.println("bind service successful!");
        
        while (true)
        {
            // 占用CPU
        }
        
    }
}

 

 

 

服务使用者可以理解成就是客户端。使用者无法感知远程对象的存在。使用者是通过Registry去获取一个RemoteRef，然后进行相应的业务逻辑操作。使用例子可以看如下的代码：

 

package com.neil.client;

import java.rmi.Naming;

import com.neil.server.service.IAccountService;

/**
 * client端启动类
 * 
 * @author nei.zhang
 * 
 */
public class StartupClient
{
    public static void main(String[] args)
        throws Exception
    {
        
        IAccountService accountService = (IAccountService)Naming.lookup("//192.168.1.254:1099/accountService");
        
        System.out.println("result is :" + accountService.account(1, 2));
        
    }
}

 

 

部署即可运行。需要注意的是安全策略需要全部允许。可以在服务提供者的启动参数中加上-Djava.security.policy=java.security.AllPermission

 

总结如下：

RMI实现在应用层可以理解为：编写远程服务接口及实现---->注册发布服务对象---->获取远程对象引用进行业务操作。

 

扩展：前文特别注明例子是使用JDK5.0+环境不需要使用rmic编译器，而在经典的RMI例子中都会提到Stub和Skeleton。现在引入这两个概念。

存在位置：

Skeleton：服务提供者前端，可以简单理解为ServerSocket持有者

Stub：服务使用者前端，可以简单理解为客户端的Socket持有者

为了清晰，直接上图：

以上就是简单的RMI的一个例子。下一篇准备讲讲Stub和Skeletion以及动态下载机制。

 

以上请各位斧正。