分布式(基础)-RMI简单的应用

RMI的简单的应用

远程通信：不同的jvm之间进行通信，不同的虚拟机就是跨服务的通信。

RMI:jdk自带的远程通信的一个接口，java本身提供的远程通信框架，称不上rpc。RMI是依赖于jvm，不依赖于apache。

常见的rpc框架有：Dubbo,Thrift,WebService(WSDL)=>http+XML：而现在都替换成http+json的方式来进行通信了。

写一个RMI的实例：底层就是用的Socket来进行通信的，但是它不支持跨语言，基于JRMP协议的，rmi的性能很高的。

RMI是WebService的根基。

1、新建两个java工程，一个代表客户端，一个代表服务端：

2、在server端提供一个UserDao的接口，代码如下：

1. package dao;
   
2. 
   
3. import java.rmi.RemoteException;
   
4. 
   
5. /**
   
6. * 接口里的方法必须抛RemoteException的异常
   
7. */
   
8. public interface UserDao extends java.rmi.Remote {
   
9.     String addUser(String name) throws RemoteException;
   
10. }
    

2.1、UserDao的实现类如下：

1. package dao;
   
2. 
   
3. import java.rmi.RemoteException;
   
4. import java.rmi.server.UnicastRemoteObject;
   
5. 
   
6. //UnicastRemoteObject这个类用于RemoteImpl这个类发布出去做一个序列化的处理,继承这个类的话，会在主类的时候会开启一个线程
   
7. public class UserDaoImpl extends UnicastRemoteObject implements UserDao {
   
8.    public UserDaoImpl() throws RemoteException {
   
9.    }
   
10. 
    
11.    @Override
    
12.    public String addUser(String name) throws RemoteException {
    
13.        return "添加的用户名称为"+name;
    
14.    }
    
15. }
    

2.2、server端的主类的代码如下：绑定的是接口，然后会生成一个代理，通过这个代理，然后和客户端的代理进行通信的去实现网络通信的操作。

1. package rmi;
   
2. 
   
3. import dao.UserDao;
   
4. import dao.UserDaoImpl;
   
5. 
   
6. import java.net.MalformedURLException;
   
7. import java.rmi.AlreadyBoundException;
   
8. import java.rmi.Naming;
   
9. import java.rmi.RemoteException;
   
10. import java.rmi.registry.LocateRegistry;
    
11. 
    
12. public class RmiServer {
    
13.    public static void main(String[] args) throws InterruptedException, RemoteException {
    
14.        //创建接口引用的实例
    
15.        UserDao remote=new UserDaoImpl();
    
16.        try {
    
17.            //注册要被客户端监听的端口
    
18.            LocateRegistry.createRegistry(8888);
    
19.            try {
    
20.                //rmi:是固定的写法
    
21.                Naming.bind("rmi://localhost:8888/user",remote);
    
22.                System.out.println("server starting...........");
    
23.            } catch (AlreadyBoundException e) {
    
24.                e.printStackTrace();
    
25.            } catch (MalformedURLException e) {
    
26.                e.printStackTrace();
    
27.            }
    
28.        } catch (RemoteException e) {
    
29.            e.printStackTrace();
    
30.        }
    
31.    }
    
32. }
    

启动server端：

3、客户端的接口的代码和server端的接口是一样，因为需要把接口给暴漏出去，代码如下：

1. package dao;
   
2. 
   
3. import java.rmi.RemoteException;
   
4. 
   
5. /**
   
6. * 接口里的方法必须抛RemoteException的异常
   
7. */
   
8. public interface UserDao extends java.rmi.Remote {
   
9.     String addUser(String name) throws RemoteException;
   
10. }
    

3.1、客户端的主类的代码如下Naming是命,lookup寻找地址是否存在。

1. package rmi.client;
   
2. import dao.UserDao;
   
3. import java.net.MalformedURLException;
   
4. import java.rmi.Naming;
   
5. import java.rmi.NotBoundException;
   
6. import java.rmi.RemoteException;
   
7. public class RmiClient {
   
8.    public static void main(String[] args) {
   
9.        try {
   
10.            UserDao userDao = (UserDao)Naming.lookup("rmi://localhost:8888/user");
    
11.            System.out.println(userDao.addUser("weizhaoyang"));
    
12.        } catch (NotBoundException e) {
    
13.            e.printStackTrace();
    
14.        } catch (MalformedURLException e) {
    
15.            e.printStackTrace();
    
16.        } catch (RemoteException e) {
    
17.            e.printStackTrace();
    
18.        }
    
19.    }
    
20. }
    

启动客户端：

注意：如下，服务端的接口和客户端的接口的路径必须一样，否则也会报错。

因为需要 代理是实现类应该是一样的。

未完待续！！如果哪里写的有问题，请指出。xxxxxxxxxxxxxxxxxxx谢谢。