[轉]Java遠程方法調用

Java遠程方法調用，即Java RMI（Java Remote Method Invocation）是Java編程語言裏，一種用於實現遠程過程調用的應用程序編程接口。它使客戶機上運行的程序能夠調用遠程服務器上的對象。遠程方法調用特性使Java編程人員可以在網絡環境中分佈操做。RMI所有的宗旨就是儘量簡化遠程接口對象的使用。

Java RMI極大地依賴於接口。在須要建立一個遠程對象的時候，程序員經過傳遞一個接口來隱藏底層的實現細節。客戶端獲得的遠程對象句柄正好與本地的根代碼鏈接，由後者負責透過網絡通訊。這樣一來，程序員只需關心如何經過本身的接口句柄發送消息。

接口的兩種常見實現方式是：最初使用JRMP（Java Remote Message Protocol，Java遠程消息交換協議）實現；此外還能夠用與CORBA兼容的方法實現。RMI通常指的是編程接口，也有時候同時包括JRMP和API（應用程序編程接口），而RMI-IIOP則通常指RMI接口接管絕大部分的功能，以支持CORBA的實現。

最初的RMI API設計爲通用地支持不一樣形式的接口實現。後來，CORBA增長了傳值（pass by value）功能，以實現RMI接口。然而RMI-IIOP和JRMP實現的接口並不徹底一致。

所使用Java包的名字是java.rmi。

你也能夠參考一篇博文 http://6221123.blog.51cto.com/6211123/1112619 它會一步一步教你如何搭建一個真正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. 到時候要通知我哦，我也學習學習。