RMI使用学习 小结

答案：四年前也是 Java  的 fans，也曾如火如荼的追求着 sun，追求着 java. 当然 RMI 肯定不会放过，但到目前为止还没有在任何一个项目中用过，昨天听了一个 java 老师的课，本来不去想听，可想想我交了这么多 money，最后还是去。最叫人恶心的是他讲的 RMI 一点实用价值都没有，而且有的理论也不对。真的误导人啊，学术理论和实践是不能够分离的，老师是这样的，只能靠学生自己动手丰衣足食了。昨天晚上用了一点时间，从新研究了一下 RMI。举个例子作为 RMI 学习的终结吧。 
        在写这篇文章前也访问了中国电信的高级工程师，根据他的介绍，RMI 有很多实现方式，而且现在他发现 RMI 在大规模分布式系统中，效率和性能不是很好。目前他带领的团队正在自行开发分布式应用。 
        随着 web 2.0 时代的到来，SOA 开发思想的普及应用。分布式应用，将又一次走向易做图。 
        RMI  开发步骤大家都很清楚，这里举个不用手动启动 rmiRegistry, 也不要指定 codebase 和web server 的例子.底层 TCP/IP 细节我们不用去管他，你就把他看成像 SOAP、JNDI 等一样的基于注册服务的东西就行了  . 

1. 远程接口 
import java.rmi.Remote; 
import java.rmi.RemoteException; 

public inte易做图ce IRMI extends Remote { 
 public Object invoke(ITask task) throws RemoteException; 
} 
2.远程接口实现 

/** 
 * @author Jack.Wang 
 *  
 */ 
import java.rmi.RemoteException; 
import java.rmi.server.UnicastRemoteObject; 

public class IRMIImpl extends UnicastRemoteObject implements IRMI { 

 protected IRMIImpl() throws RemoteException { 
  super(); 
 } 

 public Object invoke(ITask task) throws RemoteException { 
  System.out.println("注意：这是一个远程调用"); 
  Object obj = task.doWork(); 
  System.out.println("调用ITask.doWork()方法的返回值：" + obj.toString()); 
  // 客户端调用，可以在服务器端播放需要的音乐 
  ProcessCaller.callMp3(); 
  return obj; 
 } 
} 
3.  任务接口 
/** 
 * @author Jack.Wang 
 *  
 */ 
import java.io.Serializable; 
public inte易做图ce ITask extends Serializable { 
 public Object doWork(); 
} 
4.  任务实现类 
/** 
 * @author Jack.Wang 
 *  
 */ 
public class TaskImpl implements ITask { 

 public Object doWork() { 
  System.out.println("当前程序处于远程调用中"); 
  return Thread.currentThread().getName() + " " 
    + new Date(System.currentTimeMillis()); 
 } 
} 
5.在java中调用windows程序 
public class ProcessCaller { 

 public static void callMp3() { 
  Runtime ru = Runtime.getRuntime(); 
  try { 
   // 调用播放器文件播放指定MP3 
   Process p1 = ru 
     .exec("C:\\Program Files\\Windows Media Player\\wmplayer D:\\Jack\\Mp3\\5.秋天不回来-王强.mp3"); 
  } catch (Exception e) {  

  } 
 } 
} 
6. Server 端代码  
/** 
 * @author Jack.Wang 
 *  
 */ 
import java.rmi.Naming; 
import java.rmi.registry.LocateRegistry; 
import java.rmi.registry.Registry;  

public class RMIServer { 

 public static void registRemoteObject() throws Exception { 
  IRMIImpl impl = new IRMIImpl(); 
  Naming.rebind("rmi://210.43.109.25:1111/mytask", impl); 
  System.out.println("bound success!"); 
 }  

 private static Registry createRegistry() { 
  Registry registry = null; 
  int port = 1111; 
  try { 
   registry = LocateRegistry.getRegistry("210.43.109.25", port); 
   registry.list(); 
   System.out.println("Register the exist server!"); 
  } catch (final Exception e) { 
   try { 
    registry = LocateRegistry.createRegistry(port); 
    System.out.println("Register the exist server!port=" + port); 
   } catch (final Exception ee) { 
    ee.printStackTrace(); 
   } 
  } 
  return registry; 
 }  

 /** 
  * 将对象注册到rmi服务器上 
  */ 
 public static void bind() { 
  Registry registry = null; 
  registry = createRegistry(); 
  try { 
   IRMIImpl impl = new IRMIImpl(); 
   registry.rebind("mytask", impl); 
   System.out.println("mytask server start!"); 
  } catch (Exception e) { 
   e.printStackTrace(); 
  } 
 }  

 /** 
  * @param args 
  */ 
 public static void main(String[] args) { 
  try { 
   bind(); 
  } catch (Exception e) { 
   e.printStackTrace(); 
  } 
 }  

} 
7. Client 端代码 

/** 
 * @author Jack.Wang 
 *  
 */  
public class RMIClient { 
 public static void getRemoteObject() throws Exception { 
  IRMI obj = (IRMI) Naming.lookup("rmi://210.43.109.28:1111/mytask"); // 得到远程发布的服务 
  TaskImpl task = new TaskImpl(); 
  Object result = obj.invoke(task); // 调用远程服务的方法 
  System.out.println(result.toString()); 
 }  

 public static void main(String[] args) { 
  try { 
   getRemoteObject(); 
  } catch (Exception e) { 
   e.printStackTrace(); 
  } 
 } 
} 

小结： 
        建议把以上程序打包成 jar 文件，你可以在不同机子间测试。 
        RMI 就这么简单，如果你觉得他不爽，就自己封装 socket. 到时候要通知我哦，我也学习学习。 

上一个：一个实用的JSP分页代码第1/2页
下一个：JSP中include指令和include行为的区别