Java RMI 实现示例

远程对象接口

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

/**
 * 定义RMI远程对象接口，
 * 1.继承Remote
 * 2.所有方法必须抛出RemoteException
 */
public interface IRmiObj extends Remote {
    public void sayHello( String name) throws RemoteException;
    public String getHello( String name) throws RemoteException;

}

远程对象接口实现类

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

/**
 * 接口IRmiObj实现类
 * 1.接口实现类同时要实现Serializable接口，继承UnicastRemoteObject类，间接实现了serializable接口
 * 2.因为构造方法需要抛出RemoteException，所以不能缺省使用隐含的无参构造方法，而应该自己显式定义构造方法。
 */
public class RmiObjImpl extends UnicastRemoteObject implements IRmiObj {
    /**
     * 因为构造方法需要抛出RemoteException，所以不能缺省使用隐含的无参构造方法，而应该自己显式定义构造方法。
     *
     * @throws RemoteException
     */
    public RmiObjImpl() throws RemoteException {
        super();
    }

    public void sayHello(String name) throws RemoteException {
        System.out.println("welcome " + name);
    }

    public String getHello(String name) throws RemoteException {
        return "Hello " + name;
    }
}

RMI服务端

import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;

/**
 * Rmi服务端
 */
public class RmiServer {
    public static void main(String[] args) throws RemoteException {
        // 创建一个远程对象
        IRmiObj rmi = new RmiObjImpl();
        // 生成远程对象注册表Registry实例，并指定端口为8888,默认为1099
        // 同一个端口的对象只能生成一次
        LocateRegistry.createRegistry(8888);

        try {
            // 把远程对象注册到RMI注册服务器上，并命名为rmi
            Naming.bind("rmi://192.168.21.1:8888/rmi", rmi);
            System.out.println("rmi://192.168.21.1:8888/rmi is runnig...");
        } catch (AlreadyBoundException e) {
            e.printStackTrace();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        }
    }
}

RMI客户端

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

/**
 * Rmi客户端
 */
public class RmiClient {
    public static void main(String[] args) {
        System.out.println("Hello World!");
        try {
            IRmi rmi = (IRmi) Naming.lookup("rmi://192.168.21.1:8888/rmi");
            String res = rmi.getHello("zhangsan");
            System.out.println(res);
            rmi.sayHello("zhangsan");
        } catch (NotBoundException e) {
            e.printStackTrace();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (RemoteException e) {
            e.printStackTrace();
        }
    }
}