rmi入门实例

1.定义业务接口

package cn.rmi;import java.rmi.Remote;import java.rmi.RemoteException;/**远程业务接口*/public interface Business extends Remote{public String echo(String message) throws RemoteException;}

?

?

2.实现业务并配置

package cn.rmi;import java.rmi.AlreadyBoundException;import java.rmi.RemoteException;import java.rmi.registry.LocateRegistry;import java.rmi.registry.Registry;import java.rmi.server.UnicastRemoteObject;public class BusinessImpl implements Business{public String echo(String message) throws RemoteException {if("quit".equalsIgnoreCase(message)){System.out.println("远程调用结束!!");System.exit(0);}System.out.println("client :"+message);return "remote server response:"+message;}public static void main(String[] args) throws RemoteException, AlreadyBoundException {int port=9527;Business business=new BusinessImpl();UnicastRemoteObject.exportObject(business, port);Registry registry=LocateRegistry.createRegistry(1099);registry.bind("businessdemo", business);}}

?

?

3.客户端远程调用

package cn.rmi;import java.rmi.NotBoundException;import java.rmi.RemoteException;import java.rmi.registry.LocateRegistry;import java.rmi.registry.Registry;public class RmiClient {public static void main(String[] args) throws RemoteException, NotBoundException {Registry registry=LocateRegistry.getRegistry("localhost");Business business=(Business) registry.lookup("businessdemo");String message=business.echo("hello!");System.out.println(message);}}

?