/**
 * 用戶信息，用于遠程調(diào)用傳輸，必須實現(xiàn)Serializable接口
 * 
 * @author andy
 *
 */
public class User implements Serializable {
  private static final long serialVersionUID = 1L;

  private String name;

  private int age;

  public String getName() {
    return name;
  }

  public void setName(String name) {
    this.name = name;
  }

  public int getAge() {
    return age;
  }

  public void setAge(int age) {
    this.age = age;
  }

  @Override
  public String toString() {
    return "name : " + this.name + ", age : " + this.age;
  }
}

import java.rmi.Remote;
import java.rmi.RemoteException;

import pers.andy.rmi.bean.User;

/**
 * 定義一個遠程接口，必須繼承Remote接口，其中需要遠程調(diào)用的方法必須拋出RemoteException異常
 * 
 * @author andy
 *
 */
public interface IHello extends Remote {

  /**
   * 更新user信息
   * @param user
   * @return
   * @throws RemoteException
   */
  public User updateUser(User user) throws RemoteException;
}

/**
 * 遠程的接口的實現(xiàn)，繼承了UnicastRemoteObject，表明該類作為一個遠程對象
 * 
 * @author andy
 *
 */
public class HelloImpl extends UnicastRemoteObject implements IHello {
  /**
   * 
   */
  private static final long serialVersionUID = 1L;

  /**
   * 因為UnicastRemoteObject的構(gòu)造方法拋出了RemoteException異常，因此這里默認的構(gòu)造方法必須寫，必須聲明拋出RemoteException異常
   * 
   * @throws RemoteException
   */
  public HelloImpl() throws RemoteException {
  }

  public User updateUser(User user) throws RemoteException {
    System.out.println("-------------- 客戶端發(fā)送的user為" + user.toString());
    user.setName("andy2");
    user.setAge(30);
    return user;
  }
}

/**
 * 服務(wù)端啟動類
 * 
 * @author andy
 *
 */
public class HelloServer {
  public static void main(String args[]) {
    try {
　　　　　　　// 本地主機上的遠程對象注冊表Registry的實例，并指定端口為8888，這一步必不可少（Java默認端口是1099）
      LocateRegistry.createRegistry(8888);
      // 把遠程對象注冊到RMI注冊服務(wù)器上，并命名為RHello
      // 綁定的URL標準格式為：rmi://host:port/name(其中協(xié)議名可以省略，下面兩種寫法都是正確的）
      Naming.bind("rmi://localhost:8888/RHello", rhello);
      // Naming.bind("http://localhost:8888/RHello",rhello);
      System.out.println("------------遠程對象IHello注冊成功，等待客戶端調(diào)用...");
    } catch (RemoteException e) {
      System.out.println("創(chuàng)建遠程對象發(fā)生異常！");
      e.printStackTrace();
    } catch (AlreadyBoundException e) {
      System.out.println("發(fā)生重復(fù)綁定對象異常！");
      e.printStackTrace();
    } catch (MalformedURLException e) {
      System.out.println("發(fā)生URL畸形異常！");
      e.printStackTrace();
    }
  }
}

protected UnicastRemoteObject() throws RemoteException
  {
    this(0);
  }
  protected UnicastRemoteObject(int port) throws RemoteException
  {
    this.port = port;
    exportObject((Remote) this, port);
  }

...
// 創(chuàng)建一個遠程對象
IHello rhello = new HelloImpl();
//HelloImpl不需要繼承UnicastRemoteObject類，通過exportObject將其顯示導(dǎo)出
UnicastRemoteObject.exportObject(rhello,0);
...

/**
 * 客戶端啟動類
 * 
 * @author andy
 *
 */
public class HelloClient {
  public static void main(String args[]) {
    try {
      // 在RMI服務(wù)注冊表中查找名稱為RHello的對象，并調(diào)用其上的方法
      IHello rhello = (IHello) Naming.lookup("rmi://localhost:8888/RHello");　　　　　　　// 構(gòu)造user對象，測試遠程對象傳輸
      User user = new User();
      user.setAge(20);
      user.setName("andy");
      System.out.println("-------------- 服務(wù)端返回的的user為" + rhello.updateUser(user).toString());
    } catch (NotBoundException e) {
      e.printStackTrace();
    } catch (MalformedURLException e) {
      e.printStackTrace();
    } catch (RemoteException e) {
      e.printStackTrace();
    }
  }
}