源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

RMI使用学习 小结

  • 时间:2022-07-04 05:43 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要: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 interface 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 interface 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. 到时候要通知我哦,我也学习学习。
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部