RMI实现RPC

迈不过友情╰ 2022-10-27 01:53 219阅读 0赞

### 目录 ###

*   *  一、RMI简介
     *  二、执行流程
     *  三、API介绍
     *  四、代码实现
     *   *  1. 服务端（提供服务）
         *  2. 客户端（使用服务）

## 一、RMI简介 ##

*  RMI(Remote Method Invocation) 远程方法调用。
 *  RMI是从JDK1.2推出的功能，它可以实现在一个Java应用中可以像调用本地方法一样调用另一个服务器中Java应用（JVM）中的内容。
 *  RMI 是Java语言的远程调用，无法实现跨语言。

## 二、执行流程 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70]

*  Registry(注册表)是放置所有服务器对象的命名空间。 每次服务端创建一个对象时，它都会使用bind()或rebind()方法注册该对象。 这些是使用称为绑定名称的唯一名称注册的。
 *  要调用远程对象，客户端需要该对象的引用。即通过服务端绑定的名称从注册表中获取对象(lookup()方法)。

## 三、API介绍 ##

*  **Remote**：`java.rmi.Remote`  
    定义了此接口为远程调用接口。如果接口被外部调用，需要继承此接口。
    
        public interface Remote{}
 *  **RemoteException**：`java.rmi.RemoteException`  
    继承了Remote接口的接口中，如果方法是允许被远程调用的，需要抛出此异常。
 *  **UnicastRemoteObject**：`java.rmi.server.UnicastRemoteObject`  
    此类实现了Remote接口和Serializable接口。  
    自定义接口实现类除了实现自定义接口还需要继承此类。
 *  **LocateRegistry**：`java.rmi.registry.LocateRegistry`  
    可以通过LocateRegistry在本机上创建Registry，通过特定的端口就可以访问这个Registry。
 *  **Naming**：`java.rmi.Naming`  
    Naming定义了发布内容可访问RMI名称。也是通过Naming获取到指定的远程方法。

## 四、代码实现 ##

### 1. 服务端（提供服务） ###

新建一个Maven项目：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70 1]

创建Service接口，接口要继承Remote接口，方法要抛出RemoteException异常。

package com.veeja.service;
    
    import java.rmi.Remote;
    import java.rmi.RemoteException;
    
    /** * @Author veeja * 2021/2/3 9:58 */
    public interface DemoService extends Remote { 
    
        String demo(String param) throws RemoteException;
    
    }

Service实现类：

package com.veeja.service.impl;
    
    import com.veeja.service.DemoService;
    
    import java.rmi.RemoteException;
    import java.rmi.server.UnicastRemoteObject;
    
    /** * * 继承 UnicastRemoteObject, * 实现 DemoService * * @Author veeja * 2021/2/3 10:02 */
    public class DemoServiceImpl extends UnicastRemoteObject implements DemoService { 
    
        /** * 将构造方法变为public，就不会报错了 */
        public DemoServiceImpl() throws RemoteException { 
    
        }
    
        /** * 方法的实现，很简单， 将传进来的字符串+abc返回 * * @param param * @return * @throws RemoteException */
        @Override
        public String demo(String param) throws RemoteException { 
            return param + "abc";
        }
    }

Server：

package com.veeja;
    
    import com.veeja.service.DemoService;
    import com.veeja.service.impl.DemoServiceImpl;
    
    import java.net.MalformedURLException;
    import java.rmi.AlreadyBoundException;
    import java.rmi.Naming;
    import java.rmi.RemoteException;
    import java.rmi.registry.LocateRegistry;
    
    /** * @Author veeja * 2021/2/3 10:21 */
    public class DemoServer { 
    
        public static void main(String[] args) { 
            try { 
                // 创建接口实例
                DemoService demoService = new DemoServiceImpl();
                // 创建注册变
                LocateRegistry.createRegistry(8989);
                // 绑定服务
                Naming.bind("rmi://localhost:8989/demoService", demoService);
                System.out.println("服务器已启动...");
            } catch (RemoteException e) { 
                e.printStackTrace();
            } catch (AlreadyBoundException e) { 
                e.printStackTrace();
            } catch (MalformedURLException e) { 
                e.printStackTrace();
            }
        }
    }

然后我们运行一下上面的main方法：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70 2]

### 2. 客户端（使用服务） ###

新建一个Maven项目：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70 3]  
引入DemoService接口：

调用远程方法：

package com.veeja;
    
    import com.veeja.service.DemoService;
    
    import java.net.MalformedURLException;
    import java.rmi.Naming;
    import java.rmi.NotBoundException;
    import java.rmi.RemoteException;
    
    /** * @Author veeja * 2021/2/3 10:44 */
    public class ClientDemo { 
        public static void main(String[] args) { 
            try { 
                DemoService demoService = (DemoService) Naming.lookup("rmi://localhost:8989/demoService");
                String result = demoService.demo("aaa");
                System.out.println(result);
            } catch (NotBoundException e) { 
                e.printStackTrace();
            } catch (MalformedURLException e) { 
                e.printStackTrace();
            } catch (RemoteException e) { 
                e.printStackTrace();
            }
        }
    }

执行结果：

aaaabc

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70]: /images/20221024/0fb6ea4d3c3c4cf481d7bf3ba448c238.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70 1]: /images/20221024/fb46ddb6526a454cb6361678710685d7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70 2]: /images/20221024/a23550ba72934e2a8ab34bcd7441a3e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ1NjUxMjc_size_16_color_FFFFFF_t_70 3]: /images/20221024/0138b123deab4cc7aa50156f761918ec.png