agendaserver.java

使用java rmi编写的一个议程服务系统

import java.io.*;
import java.net.MalformedURLException;
import java.rmi.*;
import java.rmi.registry.Registry;
import java.rmi.registry.LocateRegistry;

import agendaServer.*;

/**
 * 议程服务系统的服务端入口程序，实现对象的注册、绑定
 * @author Crise.Lee
 * @version 1.0
 */
public class AgendaServer {
	public static void main(String[] args)
	{
		IOInput input=new IOInput();
		int portNum;
		String rmiPort=null;
		String registryURL=null,agendaURL=null;
		try {
			portNum=input.inputPort();
			System.out.println("portNum="+portNum);
			rmiPort=String.valueOf(portNum);
			System.out.println("rmiPort="+rmiPort);
			
			startRegistry(portNum);
			
			userManagerImplement pm=new userManagerImplement();
			agendaManagerImplement mm=new agendaManagerImplement();
			
			registryURL="rmi://localhost:"+portNum+"/user";
			agendaURL="rmi://localhost:"+portNum+"/agenda";
			
			java.rmi.Naming.rebind(registryURL, pm);
			java.rmi.Naming.rebind(agendaURL, mm);
			
			listRrgistry(registryURL);
		}catch (IOException e) {
			e.printStackTrace();
		} 
	}
	
	/**
	 * 注册端口号
	 * @param port
	 * @throws RemoteException
	 */
	private static void startRegistry(int port) throws RemoteException
	{
		Registry registry=null;
		try {
			registry=LocateRegistry.getRegistry(port);
			registry.list();
		} catch (RemoteException e) {
			System.out.println("RMI 还没有在"+port+"端口注册");
		    registry=LocateRegistry.createRegistry(port);
			System.out.println("RMI 在端口"+port+"注册成功");
			//e.printStackTrace();
		}
	}
	
	/**
	 * 打印绑定的信息
	 * @param registryURL
	 * @throws RemoteException
	 * @throws MalformedURLException
	 */
	public static void listRrgistry(String registryURL) throws RemoteException, MalformedURLException
	{
		System.out.println("registry "+registryURL+" contains:");
		String[] names=Naming.list(registryURL);
		for(int i=0;i<names.length;i++)
		{
			System.out.println("names["+i+"]="+names[i]);
		}
	}

}