【0】README

0.1）本文旨在對(duì)http://blog.csdn.net/PacosonSWJTU/article/details/50705192? 中的代碼進(jìn)行實(shí)踐（如何部署一個(gè)使用RMI框架的程序以進(jìn)行遠(yuǎn)程調(diào)用）；

0.2） for complete source code, please visit ?https://github.com/pacosonTang/core-java-volume/tree/master/coreJavaAdvanced/chapter11/rmi_test

0.3）目錄結(jié)構(gòu)如下：?

【1】部署前的準(zhǔn)備

step1）創(chuàng)建兩個(gè)目錄， 分別存放用于啟動(dòng)server 和 client 的類：

server/ ? ? WarehouseServer.class ? ? Warehouse.class
? ? WarehouseImpl.class
client/ ? ??WarehouseClient.class ? ? Warehouse.class step2）創(chuàng)建download 目錄，用于存放 NanoHTTPD web server?

【1】部署步驟如下

step1）打開一個(gè)新的控制臺(tái)窗口，轉(zhuǎn)到download目錄，然后將NanoHTTPD.java（NanoHTTPD web 服務(wù)器）復(fù)制到這個(gè)目錄中。（NanoHTTPD web 服務(wù)器的源代碼 ，參見， https://github.com/pacosonTang/core-java-volume/tree/master/coreJavaAdvanced/chapter11/rmi_test）

<span style="font-size:14px;">package com.corejava.chapter11.download;import java.io.IOException;public class NanoHTTPDMain extends NanoHTTPD {public NanoHTTPDMain() throws IOException{super(8080);start(NanoHTTPD.SOCKET_READ_TIMEOUT, false); System.out.println("\n nano http web server is running! Point your browers to http://localhost:8080/ \n"); }public static void main(String[] args){try{new NanoHTTPDMain(); } catch (Exception e){e.printStackTrace();}} } </span>

step2）在server 程序中通過代碼注冊(cè)通訊端口和注冊(cè)通訊路徑

<span style="font-size:14px;">public class WarehouseServer {public static void main(String[] args){try{WarehouseImpl warehouseService = new WarehouseImpl();// 注冊(cè)通訊端口LocateRegistry.createRegistry(1099);// 注冊(cè)通訊路徑Naming.rebind("rmi://localhost:1099/warehouseService", warehouseService);System.out.println("warehouse service starts");} catch (Exception e){e.printStackTrace();}} }</span>

<span style="font-size:14px;">// 這個(gè)WarehouseImpl類是遠(yuǎn)程方法調(diào)用的目標(biāo)，因?yàn)樗^承自UnicastRemoteObject， // 這個(gè)類的構(gòu)造器使得它的對(duì)象可供遠(yuǎn)程訪問; public class WarehouseImpl extends UnicastRemoteObject implements Warehouse {private Map<String, Double> prices;public WarehouseImpl() throws RemoteException{prices = new HashMap<>();prices.put("A", 24.95);prices.put("B", 49.95);}public double getPrice(String description) throws RemoteException{Double price = prices.get(description);return price == null ? 0 : price;} }</span> <span style="font-size:14px;">// 遠(yuǎn)程對(duì)象的接口必須擴(kuò)展Remote接口 public interface Warehouse extends Remote { double getPrice(String description) throws RemoteException; } </span>

step3）現(xiàn)在已經(jīng)準(zhǔn)備好啟動(dòng)服務(wù)器了。打開第三個(gè)控制臺(tái)窗口，轉(zhuǎn)到server目錄，并執(zhí)行下面的命令：

java -Djava.rmi.server.codebase=http://localhost:8080/ WarehouseServer // java.rmi.server.codebase屬性指出了服務(wù)類文件的URL。服務(wù)器程序?qū)⑦@個(gè)URL傳遞給RMI注冊(cè)表。

step4）最后，打開第四個(gè)控制臺(tái)窗口，轉(zhuǎn)到client目錄，運(yùn)行：

<span style="font-size:14px;">// 客戶端如何獲得遠(yuǎn)程倉庫對(duì)象的存根，并調(diào)用遠(yuǎn)程的getPrice方法。 public class WarehouseClient {public static void main(String[] args){try{Context namingContext = new InitialContext();// NameClassPair是一個(gè)助手類：　它包含綁定對(duì)象的名字和該對(duì)象所屬類的名字。Enumeration<NameClassPair> e = namingContext.list("rmi://localhost:1099/");while (e.hasMoreElements())System.out.println(e.nextElement().getName());// 客戶端可以通過下面的方式，來指定服務(wù)器和遠(yuǎn)程對(duì)象的名字，以此獲得訪問遠(yuǎn)程對(duì)象所需的存根：String url = "rmi://localhost:1099/warehouseService";Warehouse centralWarehouse = (Warehouse) namingContext.lookup(url);String descr = "A";double price = centralWarehouse.getPrice(descr);System.out.println(descr + ": " + price);} catch (Exception e){e.printStackTrace();}}}</span>

總結(jié)

以上是生活随笔為你收集整理的java分布式对象RMI应用测试用例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。