Hadoop技术内幕HDFS-笔记4之远程调用

package test.rmi;

import java.io.Serializable;
import java.rmi.Remote;
import java.rmi.RemoteException;

//必须继承Remote接口
//必须实现Serializable，增加序列化功能
public interface RMIQueryStatus extends Remote,Serializable{
	
	//方法必须抛出RemoteException异常
	String getFileName(String fileName) throws RemoteException;
}

2、定义一个远程对象的实现类
package test.rmi;

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

public class RMIQueryStatusImpl extends UnicastRemoteObject 
	implements RMIQueryStatus{
	//声明一个版本ID（必须要有吗？可以试试）
	private static final long serialVersionUID = 1L;

	public RMIQueryStatusImpl() throws RemoteException {
		super();
		// TODO Auto-generated constructor stub
	}

	@Override
	public String getFileName(String fileName) throws RemoteException {
		// TODO Auto-generated method stub
		return fileName+" ,good,you get it!";
	}
}

3、开启JAVA RMI注册服务
	在cmd下运行rmiregistry （使用默认端口12090）可以增加 如rmiregistry 10000,即使用10000端口
5、	编写服务端主程序

package test.rmi;

import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;

public class RMIQueryStatusServer {

	public static void main(String[] args) throws Exception {
		//创建远程对象实例
		RMIQueryStatusImpl rmiObj = new RMIQueryStatusImpl();
		//使用本地端口，12090
		LocateRegistry.createRegistry(12090);
		//绑定远程对象到名字
		Naming.rebind("RMI_URL", rmiObj);
		System.out.println("Server is ready.");
	}
}

package test.rmi;

import java.rmi.Naming;

public class RMIQueryStatusClient {

	public static void main(String[] args) throws Exception{
		//从注册点获取一个远程对象
		RMIQueryStatus remoteObj = (RMIQueryStatus) Naming.lookup("RMI_URL");
		//调用方法
		String res = remoteObj.getFileName("hello");
		//输出结果
		System.out.println(res);
	}
}