java rmi

RMI网络编程开发之二 如何搭建基于JDK1.5的分布式JAVA RMI 程序

http://6221123.blog.51cto.com/6211123/1112619

这里讲述的是基于JDK1.5的RMI程序搭建，更简单的说是一个 HelloWorld RMI。

1. 这里是基于JDK1.5的，节省了繁琐的手工编译（生成桩和骨架）。不像1.4之前的RMI。

2. 这里是把客户端和服务器端的两个程序，分布在两个独立的程序里面，而不是同一个package下面。是真正的分布式。

3. 这里不过多阐述原理，这只是一个Hello World！！

好，以下是步骤：

1. 在Eclipse里面创建一个server 端的project。然后，创建一个接口，这个接口是你要向client端开放的方法定义。它叫做：UserManagerInterface，而且必须继承Remote接口。

packagedataserver.rmi.stub;

importjava.rmi.Remote;
importjava.rmi.RemoteException;

importdataserver.rmi.bean.Account;

publicinterfaceUserManagerInterfaceextendsRemote{
publicStringgetUserName()throwsRemoteException;
publicAccountgetAdminAccount()throwsRemoteException;
}

2. 为了证明RMI中，“面向对象”或者是“无缝传递JAVA Object”是何等简单，我们需要定义一个Account类，该类是一个Bean，必须实现implements Serializable序列化接口。这是一个可以在client和server传输的可序列化对象。

packagedataserver.rmi.bean;

importjava.io.Serializable;

publicclassAccountimplementsSerializable,Cloneable{

/**
*
*/
privatestaticfinallongserialVersionUID=-1858518369668584532L;
privateStringusername;
privateStringpassword;

publicStringgetUsername(){
returnusername;
}
publicvoidsetUsername(Stringusername){
this.username=username;
}
publicStringgetPassword(){
returnpassword;
}
publicvoidsetPassword(Stringpassword){
this.password=password;
}

}

3. 此时，需要实现你已经开放的接口：

packagedataserver.rmi;

importjava.rmi.RemoteException;

importdataserver.rmi.bean.Account;
importdataserver.rmi.stub.UserManagerInterface;

publicclassUserManagerImplimplementsUserManagerInterface{

publicUserManagerImpl()throwsRemoteException{
//super();
//TODOAuto-generatedconstructorstub
//UnicastRemoteObject.exportObject(this);
}

/**
*
*/
privatestaticfinallongserialVersionUID=-3111492742628447261L;

publicStringgetUserName()throwsRemoteException{
//TODOAuto-generatedmethodstub
return"TommyLee";
}

publicAccountgetAdminAccount()throwsRemoteException{
//TODOAuto-generatedmethodstub
Accountaccount=newAccount();
account.setUsername("admin");
account.setPassword("admin");
returnaccount;
}

}

4. 定义一个主程序入口，注册你已经实现的RMI接口，包括开放端口等。其实很简单：

把我们的接口名称，命名为“userManager”,方便client进行调用

packagedataserver.entry;

importjava.rmi.AlreadyBoundException;
importjava.rmi.RemoteException;
importjava.rmi.registry.LocateRegistry;
importjava.rmi.registry.Registry;
importjava.rmi.server.UnicastRemoteObject;

importdataserver.rmi.UserManagerImpl;
importdataserver.rmi.stub.UserManagerInterface;

publicclassEntry{

publicstaticvoidmain(String[]args)throwsAlreadyBoundException,RemoteException{


UserManagerImpluserManager=newUserManagerImpl();
UserManagerInterfaceuserManagerI=(UserManagerInterface)UnicastRemoteObject.exportObject(userManager,0);
//Bindtheremoteobject'sstubintheregistry
Registryregistry=LocateRegistry.createRegistry(2001);
registry.rebind("userManager",userManagerI);
System.out.println("serverisready");
}
}

5. Server端的代码已经全部写完，但是还要把bean类（Account）和接口类（UserMangerInterface）打包成jar，以便可以在下面导入进client端的项目中。

项目--》右键--》导出--》jar--》选择bean和interface--》命名为RmiServerInterface.jar--》finish

6. 开始创建client端的程序。新建一个project。创建完成后，把刚才jar包导入进client的项目中。

7. 导入我们的接口jar以后，可以开始编写一个client端的主程序，并调用server端的方法。

packageweiblog.rmi;
importjava.rmi.NotBoundException;
importjava.rmi.RemoteException;
importjava.rmi.registry.LocateRegistry;
importjava.rmi.registry.Registry;

importdataserver.rmi.stub.UserManagerInterface;

publicclassEntry2{

publicstaticvoidmain(String[]args){

try{
Registryregistry=LocateRegistry.getRegistry("localhost",2001);
UserManagerInterfaceuserManager=(UserManagerInterface)registry.lookup("userManager");
System.out.println(""+userManager.getAdminAccount().getUsername()
+userManager.getAdminAccount().getPassword());
}catch(RemoteExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}catch(NotBoundExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

}
}

8. 启动server端的主程序，然后启动client端的主程序。

server控制台打印：server is ready

client控制台打印：adminadmin