一:基本原理 主要是要實(shí)現(xiàn)網(wǎng)絡(luò)之間的通訊,
網(wǎng)絡(luò)通信需要做的就是將流從一臺(tái)計(jì)算機(jī)傳輸?shù)搅硗庖慌_(tái)計(jì)算機(jī),基于傳輸協(xié)議和網(wǎng)絡(luò)IO來實(shí)現(xiàn),其中傳輸協(xié)議比較出名的有http、 tcp、udp等等,http、tcp、udp都是在基于Socket概念上為某類應(yīng)用場(chǎng)景而擴(kuò)展出的傳輸協(xié)議,網(wǎng)絡(luò)IO,主要有bio、nio、aio 三種方式,所有的分布式應(yīng)用通訊都基于這個(gè)原理而實(shí)現(xiàn)。
二:實(shí)踐
在分布式服務(wù)框架中,一個(gè)最基礎(chǔ)的問題就是遠(yuǎn)程服務(wù)是怎么通訊的,在Java領(lǐng)域中有很多可實(shí)現(xiàn)遠(yuǎn)程通訊的技術(shù):RMI、MINA、ESB、Burlap、Hessian、SOAP、EJB和JMS
既然引入出了這么多技術(shù),那我們就順道深入挖掘下去,了解每個(gè)技術(shù)框架背后的東西:
1.首先看RMI
RMI主要包含如下內(nèi)容:
遠(yuǎn)程服務(wù)的接口定義
·遠(yuǎn)程服務(wù)接口的具體實(shí)現(xiàn) ·樁(Stub)和框架(Skeleton)文件 ·一個(gè)運(yùn)行遠(yuǎn)程服務(wù)的服務(wù)器 ·一個(gè)RMI命名服務(wù),它允許客戶端去發(fā)現(xiàn)這個(gè)遠(yuǎn)程服務(wù) ·類文件的提供者(一個(gè)HTTP或者FTP服務(wù)器) ·一個(gè)需要這個(gè)遠(yuǎn)程服務(wù)的客戶端程序 來看下基于RMI的一次完整的遠(yuǎn)程通信過程的原理:
1)客戶端發(fā)起請(qǐng)求,請(qǐng)求轉(zhuǎn)交至RMI客戶端的stub類;
2)stub類將請(qǐng)求的接口、方法、參數(shù)等信息進(jìn)行序列化;
3)基于tcp/ip將序列化后的流傳輸至服務(wù)器端;
4)服務(wù)器端接收到流后轉(zhuǎn)發(fā)至相應(yīng)的skelton類;
5)skelton類將請(qǐng)求的信息反序列化后調(diào)用實(shí)際的處理類;
6)處理類處理完畢后將結(jié)果返回給skelton類;
7)Skelton類將結(jié)果序列化,通過tcp/ip將流傳送給客戶端的stub;
8)stub在接收到流后反序列化,將反序列化后的Java Object返回給調(diào)用者。
RMI應(yīng)用級(jí)協(xié)議內(nèi)容:
1、傳輸?shù)臉?biāo)準(zhǔn)格式是什么?
2、怎么樣將請(qǐng)求轉(zhuǎn)化為傳輸?shù)牧鳎?/div>
基于Java串行化機(jī)制將請(qǐng)求的java object信息轉(zhuǎn)化為流。
根據(jù)采用的協(xié)議啟動(dòng)相應(yīng)的監(jiān)聽端口,當(dāng)有流進(jìn)入后基于Java串行化機(jī)制將流進(jìn)行反序列化,并根據(jù)RMI協(xié)議獲取到相應(yīng)的處理對(duì)象信息,進(jìn)行調(diào)用并處理,處理完畢后的結(jié)果同樣基于java串行化機(jī)制進(jìn)行返回。
tcp/ip。
原理講了,開始實(shí)踐:
創(chuàng)建RMI程序的6個(gè)步驟: 1、定義一個(gè)遠(yuǎn)程接口的接口,該接口中的每一個(gè)方法必須聲明它將產(chǎn)生一個(gè)RemoteException異常。 2、定義一個(gè)實(shí)現(xiàn)該接口的類。 3、使用RMIC程序生成遠(yuǎn)程實(shí)現(xiàn)所需的殘根和框架。 4、創(chuàng)建一個(gè)服務(wù)器,用于發(fā)布2中寫好的類。 5. 創(chuàng)建一個(gè)客戶程序進(jìn)行RMI調(diào)用。 6、啟動(dòng)rmiRegistry并運(yùn)行自己的遠(yuǎn)程服務(wù)器和客戶程序 1)首先創(chuàng)建遠(yuǎn)程接口:
/** * 遠(yuǎn)程接口
*
* @author mike
*
* @since 2012-3-14
*/
public interface Hello extends Remote {
/**
* 測(cè)試rmi
*
* @return hello
* @throws RemoteException
*/
public String hello()throws RemoteException;
}
2)創(chuàng)建接口實(shí)現(xiàn)
package com.gewara.rmi;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
/**
* 遠(yuǎn)程接口實(shí)現(xiàn)
*
* @author mike
*
* @since 2012-3-14
*/
public class HelloImpl extends UnicastRemoteObject implements Hello {
/**
* seria id
*/
private static final long serialVersionUID = -7931720891757437009L;
protected HelloImpl() throws RemoteException {
super();
}
/**
* hello實(shí)現(xiàn)
*
* @return hello world
* @throws RemoteException
*/
public String hello() throws RemoteException {
return "hello world";
}
}
3)創(chuàng)建服務(wù)器端
package com.gewara.rmi;
import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;
public class Server {
private static final String RMI_URL="rmi://192.168.2.89:10009/server";
/**
* RMI Server
*/
public Server() {
try {
//創(chuàng)建遠(yuǎn)程對(duì)象
Hello hello=new HelloImpl();
//啟動(dòng)注冊(cè)表
LocateRegistry.createRegistry(10009);
//將名稱綁定到對(duì)象
Naming.bind(RMI_URL, hello);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* @param args
*/
public static void main(String[] args) {
new Server();
}
}
4)創(chuàng)建客服端
package com.gewara.rmi;
import java.rmi.Naming;
public class Client {
private static final String RMI_URL="rmi://192.168.2.89:10009/server";
/**
* @param args
*/
public static void main(String[] args) {
try {
String result=((Hello)Naming.lookup(RMI_URL)).hello();
System.out.println(result);
} catch (Exception e) {
e.printStackTrace();
}
}
}
5)先啟動(dòng)服務(wù)器端,然后再啟動(dòng)客戶端
顯示結(jié)果:hello world
由于涉及到的內(nèi)容比較多,打算每一篇里講一個(gè)遠(yuǎn)程通訊框架,繼續(xù)詳解RMI
三:詳解RMI內(nèi)部原理
1. RMI基本結(jié)構(gòu):包含兩個(gè)獨(dú)立的程序,服務(wù)器和客戶端,服務(wù)器創(chuàng)建多個(gè)遠(yuǎn)程對(duì)象,讓遠(yuǎn)程對(duì)象能夠被引用,等待客戶端調(diào)用這些遠(yuǎn)程對(duì)象的方法。客戶端從服務(wù)器獲取到一個(gè)或則多個(gè)遠(yuǎn)程對(duì)象的引用,然后調(diào)用遠(yuǎn)程對(duì)象方法,主要涉及到RMI接口、回調(diào)等技術(shù)。
2.RMI回調(diào):服務(wù)器提供遠(yuǎn)程對(duì)象引用供客戶端調(diào)用,客戶端主動(dòng)調(diào)用服務(wù)器,如果服務(wù)器主動(dòng)打算調(diào)用客戶端,這就叫回調(diào)。
3.命名遠(yuǎn)程對(duì)象:客戶端通過一個(gè)命名或則一個(gè)查找服務(wù)找到遠(yuǎn)程服務(wù),遠(yuǎn)程服務(wù)包含Java的命名和查找接口(Java Naming and Directory Interface)JNDI
RMI提供了一種服務(wù):RMI注冊(cè)rmiregistry,默認(rèn)端口:1099,主機(jī)提供遠(yuǎn)程服務(wù),接受服務(wù),啟動(dòng)注冊(cè)服務(wù)的命令:start rmiregistry
客戶端使用一個(gè)靜態(tài)類Naming到達(dá)RMI注冊(cè)處,通過方法lookup()方法,客戶來詢問注冊(cè)。