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);
	}

}