第一个RMI程序

第一步：接口（客户端与服务器端共享）

//Product.java
import java.rmi.*;
public interface Product extends Remote
{
 String getDescription() throws RemoteException;
}

>javac Product.java

第二步：接口实现

//ProductImpl.java
import java.rmi.*;
import java.rmi.server.*;
public class ProductImpl extends UnicastRemoteObject implements Product
{
 public ProductImpl(String n) throws RemoteException
 {
  name=n;
 }
 
 public String getDescription() throws RemoteException
 {
  return “I am a “+name+”. Buy me!”;
 }
 private String name;
}

>javac ProductImpl.java

第三步：存根类生成（生成ProductImpl_Stub.class，需要客户端和服务器端共享）

>rmic ProductImpl

第四步：服务器端

//ProductServer.java
import java.rmi.*;
import java.rmi.server.*;
import javax.naming.*;
public class ProductServer {

 /**
  * @param args
  */
 public static void main(String[] args) {
  // TODO 自动生成方法存根
  try
  {
   System.out.println(”Constructing server implementations…”);
   ProductImpl p1=new ProductImpl(”Blackwell Toaster”);
   ProductImpl p2=new ProductImpl(”ZapXpress Microwave Oven”);
   
   System.out.println(”Binding server implements to registry…”);
   Naming.rebind(”rmi://localhost:1099/toaster”,p1);
   Naming.rebind(”rmi://localhost:1099/microwave”,p2);
   System.out.println(”Waiting for invocations from clients…”);
  }
  catch(Exception e)
  {
   e.printStackTrace();
  }
 }

}

>javac ProductServer.java

第五步：配置服务器段

修改权限：在%JRE_HOME%\lib\security\java.policy文件最后添加

grant {
  permission java.net.SocketPermission “*:1024-65535″, “connect”;
};

启动rmi注册：>start rmiregistry

启动服务端程序：>start java ProductServer

第六步：客户端

//ProductClient.java
import java.rmi.*;
import java.rmi.server.*;
import javax.naming.*;
public class ProductClient {
 
 public static void main(String[] args)
 {
  System.setProperty(”java.security.policy”,”client.policy”);
  System.setSecurityManager(new RMISecurityManager());
  String url=”rmi://localhost/”;
  try
  {
   Context namingContext=new InitialContext();
   Product c1=(Product)namingContext.lookup(url+”toaster”);
   Product c2=(Product)namingContext.lookup(url+”microware”);
   
   System.out.println(c1.getDescription());
   System.out.println(c2.getDescription());
  }
  catch(Exception e)
  {
   e.printStackTrace();
  }
 }

}

>javac ProductClient

>java ProductClient

其他：

测试服务器提供的服务

//ShowBindings.java
import java.rmi.*;
import java.rmi.server.*;
import javax.naming.*;

public class ShowBindings
{
 public static void main(String[] args)
 {
  try
  {
   Context namingContext=new InitialContext();
   NamingEnumeration<nameclasspair></nameclasspair> e=namingContext.list(”rmi:”);
   while(e.hasMore())
    System.out.println(e.next().getName());
  }
  catch(Exception e)
  {
   e.printStackTrace();
  }
 }
}

>javac ShowBindings.java

>java ShowBindings

参考资料：《Java2核心技术 卷2 高级特性》