A. RMI 如何實現同步數據傳遞
RMI,遠程方法調用(Remote Method Invocation)是Enterprise JavaBeans的支柱,是建立分布式Java應用程序的方便途徑。RMI是非常容易使用的,但是它非常的強大。
RMI的基礎是介面,RMI構架基於一個重要的原理:定義介面和定義介面的具體實現是分開的。下面我們通過具體的例子,建立一個簡單的遠程計算服務和使用它的客戶程序
一個正常工作的RMI系統由下面幾個部分組成:
● 遠程服務的介面定義
● 遠程服務介面的具體實現
● 樁(Stub)和框架(Skeleton)文件
● 一個運行遠程服務的伺服器
● 一個RMI命名服務,它允許客戶端去發現這個遠程服務
● 類文件的提供者(一個HTTP或者FTP伺服器)
● 一個需要這個遠程服務的客戶端程序
下面我們一步一步建立一個簡單的RMI系統。首先在你的機器里建立一個新的文件夾,以便放置我們創建的文件,為了簡單起見,我們只使用一個文件夾存放客戶端和服務端代碼,並且在同一個目錄下運行服務端和客戶端。
如果所有的RMI文件都已經設計好了,那麼你需要下面的幾個步驟去生成你的系統:
1、 編寫並且編譯介面的Java代碼
2、 編寫並且編譯介面實現的Java代碼
3、 從介面實現類中生成樁(Stub)和框架(Skeleton)類文件
4、 編寫遠程服務的主運行程序
5、 編寫RMI的客戶端程序
6、 安裝並且運行RMI系統
1、 介面
第一步就是建立和編譯服務介面的Java代碼。這個介面定義了所有的提供遠程服務的功能,下面是源程序:
//Calculator.java
//define the interface
import java.rmi.Remote;
public interface Calculator extends Remote
{
public long add(long a, long b)
throws java.rmi.RemoteException;
public long sub(long a, long b)
throws java.rmi.RemoteException;
public long mul(long a, long b)
throws java.rmi.RemoteException;
public long div(long a, long b)
throws java.rmi.RemoteException;
}
注意,這個介面繼承自Remote,每一個定義的方法都必須拋出一個RemoteException異常對象。
建立這個文件,把它存放在剛才的目錄下,並且編譯。
>javac Calculator.java
2、 介面的具體實現
下一步,我們就要寫遠程服務的具體實現,這是一個CalculatorImpl類文件:
//CalculatorImpl.java
//Implementation
import java.rmi.server.UnicastRemoteObject
public class CalculatorImpl extends UnicastRemoteObject implements Calculator
{
// 這個實現必須有一個顯式的構造函數,並且要拋出一個RemoteException異常
public CalculatorImpl()
throws java.rmi.RemoteException {
super();
}
public long add(long a, long b)
throws java.rmi.RemoteException {
return a + b;
}
public long sub(long a, long b)
throws java.rmi.RemoteException {
return a - b;
}
public long mul(long a, long b)
throws java.rmi.RemoteException {
return a * b;
}
public long div(long a, long b)
throws java.rmi.RemoteException {
return a / b;
}
}
同樣的,把這個文件保存在你的目錄里然後編譯他。
這個實現類使用了UnicastRemoteObject去聯接RMI系統。在我們的例子中,我們是直接的從UnicastRemoteObject這個類上繼承的,事實上並不一定要這樣做,如果一個類不是從UnicastRmeoteObject上繼承,那必須使用它的exportObject()方法去聯接到RMI。
如果一個類繼承自UnicastRemoteObject,那麼它必須提供一個構造函數並且聲明拋出一個RemoteException對象。當這個構造函數調用了super(),它久激活UnicastRemoteObject中的代碼完成RMI的連接和遠程對象的初始化。
3、 樁(Stubs)和框架(Skeletons)
下一步就是要使用RMI編譯器rmic來生成樁和框架文件,這個編譯運行在遠程服務實現類文件上。
>rmic CalculatorImpl
在你的目錄下運行上面的命令,成功執行完上面的命令你可以發現一個Calculator_stub.class文件,如果你是使用的Java2SDK,那麼你還可以發現Calculator_Skel.class文件。
4、 主機伺服器
遠程RMI服務必須是在一個伺服器中運行的。CalculatorServer類是一個非常簡單的伺服器。
//CalculatorServer.java
import java.rmi.Naming;
public class CalculatorServer {
public CalculatorServer() {
try {
Calculator c = new CalculatorImpl();
Naming.rebind("rmi://localhost:1099/CalculatorService", c);
} catch (Exception e) {
System.out.println("Trouble: " + e);
}
}
public static void main(String args[]) {
new CalculatorServer();
}
}
建立這個伺服器程序,然後保存到你的目錄下,並且編譯它。
5、 客戶端
客戶端源代碼如下:
//CalculatorClient.java
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.net.MalformedURLException;
import java.rmi.NotBoundException;
public class CalculatorClient {
public static void main(String[] args) {
try {
Calculator c = (Calculator)
Naming.lookup(
"rmi://localhost
/CalculatorService");
System.out.println( c.sub(4, 3) );
System.out.println( c.add(4, 5) );
System.out.println( c.mul(3, 6) );
System.out.println( c.div(9, 3) );
}
catch (MalformedURLException murle) {
System.out.println();
System.out.println(
"MalformedURLException");
System.out.println(murle);
}
catch (RemoteException re) {
System.out.println();
System.out.println(
"RemoteException");
System.out.println(re);
}
catch (NotBoundException nbe) {
System.out.println();
System.out.println(
"NotBoundException");
System.out.println(nbe);
}
catch (
java.lang.ArithmeticException
ae) {
System.out.println();
System.out.println(
"java.lang.ArithmeticException");
System.out.println(ae);
}
}
}
保存這個客戶端程序到你的目錄下(注意這個目錄是一開始建立那個,所有的我們的文件都在那個目錄下),並且編譯他。
6、 運行RMI系統
現在我們建立了所有運行這個簡單RMI系統所需的文件,現在我們終於可以運行這個RMI系統啦!來享受吧。
我們是在命令控制台下運行這個系統的,你必須開啟三個控制台窗口,一個運行伺服器,一個運行客戶端,還有一個運行RMIRegistry。
首先運行注冊程序RMIRegistry,你必須在包含你剛寫的類的那麼目錄下運行這個注冊程序。
>rmiregistry
好,這個命令成功的話,注冊程序已經開始運行了,不要管他,現在切換到另外一個控制台,在第二個控制台里,我們運行伺服器CalculatorService,因為RMI的安全機制將在服務端發生作用,所以你必須增加一條安全策略。以下是對應安全策略的例子
grant {
permission java.security.AllPermission "", "";
};
注意:這是一條最簡單的安全策略,它允許任何人做任何事,對於你的更加關鍵性的應用,你必須指定更加詳細安全策略。
現在為了運行服務端,你需要除客戶類(CalculatorClient.class)之外的所有的類文件。確認安全策略在policy.txt文件之後,使用如下命令來運行伺服器。
> java -Djava.security.policy=policy.txt CalculatorServer
這個伺服器就開始工作了,把介面的實現載入到內存等待客戶端的聯接。好現在切換到第三個控制台,啟動我們的客戶端。
為了在其他的機器運行客戶端程序你需要一個遠程介面(Calculator.class) 和一個stub(CalculatorImpl_Stub.class)。 使用如下命令運行客戶端
prompt> java -Djava.security.policy=policy.txt CalculatorClient
如果所有的這些都成功運行,你應該看到下面的輸出:
1
9
18
3
如果你看到了上面的輸出,恭喜你,你成功了,你已經成功的創建了一個RMI系統,並且使他正確工作了。即使你運行在同一個計算機上,RMI還是使用了你的網路堆棧和TCP/IP去進行通訊,並且是運行在三個不同的Java虛擬機上。這已經是一個完整的RMI系統。
B. 如何java判斷ftp伺服器上路徑是否存在
要注意的是程序有可能和FTP不再同一台伺服器上,所以要多做一些工作,先要根據獲取FTP的IP,根據這個IP的FTP目錄在進行判斷
代碼如下
=======介面部分===============
IMPORT JAVA.RMI.REMOTE;
IMPORT JAVA.RMI.REMOTEEXCEPTION;
PUBLIC INTERFACE IDOREMOTE EXTENDS REMOTE {
PUBLIC INT GETSERVERTIME() THROWS REMOTEEXCEPTION;
}
=======介面實現===============
PUBLIC CLASS DOREMOTEIMPL EXTENDS UNICASTREMOTEOBJECT IMPLEMENTS IDOREMOTE {
/**
* @THROWS REMOTEEXCEPTION
*/
PROTECTED DOREMOTEIMPL() THROWS REMOTEEXCEPTION {
SUPER();
}
PRIVATE STATIC FINAL LONG SERIALVERSIONUID = -8158779541912069375L;
/**
* @SEE CN.SHIY.TEST.REMOTESERVER.IDOREMOTE#GETSERVERTIME()
*/
PUBLIC INT GETSERVERTIME() THROWS REMOTEEXCEPTION {
RETURN INTEGER.PARSEINT(NEW SIMPLEDATEFORMAT("YYYYMMDD").FORMAT(NEW DATE()));
// RETURN NEW DATE();
}
========SERVER端綁定===============
PUBLIC STATIC VOID MAIN(STRING[] ARGS) {
TRY {
LOCATEREGISTRY.CREATEREGISTRY(8808);
DOREMOTEIMPL SERVER = NEW DOREMOTEIMPL();
NAMING.REBIND("//LOCALHOST:8808/DATE-SERVER", SERVER);
} CATCH (JAVA.NET.MALFORMEDURLEXCEPTION ME) {
SYSTEM.OUT.PRINTLN("MALFORMED URL: " + ME.TOSTRING());
} CATCH (REMOTEEXCEPTION RE) {
SYSTEM.OUT.PRINTLN("REMOTE EXCEPTION: " + RE.TOSTRING());
}
}
===========客戶端的調用方式============
STRING URL = "//LOCALHOST:8808/DATE-SERVER";
IDOREMOTE RMIOBJECT = (IDOREMOTE) NAMING.LOOKUP(URL);
SYSTEM.OUT.PRINTLN(" SERVER DATE: " + RMIOBJECT.GETSERVERTIME());
C. 如何獲取jboss的rmi埠
jboss常常出現1098埠被占,不能正常起動的錯誤:
10:28:57,000 WARN [ServiceController] Problem starting service jboss:service=Naming
java.rmi.server.ExportException: Portalreadyinuse: 1098; nested exception is:
java.net.BindException: Address already in use: JVM_Bind
at sun.rmi.transport.tcp.TCPTransport.listen(TCPTransport.java:310)
at sun.rmi.transport.tcp.TCPTransport.exportObject(TCPTransport.java:218)
也不知道是哪個程序佔用了這個埠。可以通過修改jboss的配置文件,讓jboss使用另外一個埠,來修正這個問題。方法如下:
1,打開jboss的jboSs-service.xml文件,在我機上位於D:\prog\jboss-4.2.2.GA\server\default\conf 目錄。
2,搜索1098,找到 <attribute name=」RmiPort」>1098</attribute>,修改這個埠號為一個一般不會被用到的埠號,比如12345。
再重啟jboss應該就OK了。
如果還是沖突,修改<attribute name=」Port」>標簽里的值,改到不沖突為止。
本文轉自:http://kxyyt2000.blog.163.com/blog/static/65806401201141610500986/
D. java RMI客戶端也要實現服務端的介面嗎
兩邊是通過介面來交換信息的,當然都需要介面和它的 Stub。
你做實驗時可以考慮創建3個項目:
1、介面項目,只包括介面和介面編譯後的 Stub 類
2、服務端項目,只包括伺服器類,它依賴介面項目。
3、客戶端項目,只包括客戶端,它依賴介面項目。
如果是從命令行運行它們,那麼服務端需要服務端項目和介面項目兩個 jar,客戶端需要客戶端項目和介面項目兩個 jar,我們需要面向介面編程減少耦合程度,不要把所有類全部放在同一個項目中編譯,將來會碰到很多麻煩事,比如包名太多就可能不支持 OSGi 這種方式。
在遠程調用類的應用中,使用靜態方法調用時一般需要介面類對應的Stub,我們 lookup 得到的其實是 Stub (它只包括了連接到伺服器的參數,然後把你想調用的」服務「 + 」參數「 發送給伺服器並將從伺服器返回的結果返回給客戶端程序,因此,它其實並沒有什麼」針對你的程序和伺服器的特殊特性),使用動態的調用方式就完全可以做到不需要特定的 Stub 而用一個通用的方式 (也就是 RMI 編譯生成的那個 Stub 類的內容我們來自己寫成一個框架。
上面一段是廢話,來說說怎麼配置環境測試它們。
客戶端項目中只需要有介面 TestServer 和 TestServerStub 兩個類,如果你的參數本身也是一個 Remote 子類,那麼參數類也需要有相應的 Stub。
另外,我們客戶端也可以僅自帶介面類而不自帶Stub,在運行的時候可以」請求從伺服器上下載一份 Stub",如下:
System.setSecurityManager(newRMISecurityManager());
然後在命令行添加額外參數:
-Djava.security.policy=$policy文件
-Djava.rmi.server.codebase=file:///C:/service-interface/classes/
這樣就可以啟用RMIClassLoader來自動從codebase對應的地方查找Stub類,這裡面codebase可以是一個Http或Ftp協議,注意這個codebaseURL後面一個/是必須的。那個$policy文件可以用JDKinpolicytool.exe來生成一個。
E. alfresco ftp 埠怎麼用
一、 系統環境
操作系統
WINDOWS7
伺服器
TOMCAT7
資料庫
MYsql5.5
Alfresco版本
Alfresco4.0
alfresco-solr版本
alfresco-solr-4.2.c
二、 准備工作
Alfresco4.0安裝文件
alfresco-community-4.2.c-installer-win-x64.exe
單獨部署SOLR的包
alfresco-community-solr-4.2.c.zip
SOLR的TOMCAT
TOMCAT7,埠8080
資料庫
MYSQL5.5
MYSQL連接JAR
mysql-connector-java-5.1.7-bin.jar
三、 安裝Alfresco
創建資料庫
在mysql中創建名alfresco的資料庫,編碼使用UTF-8
安裝alfresco
1. 打開alfresco-community-4.2.c-installer-win-x64.exe
2. 選擇語言
3. 一直前進到設置頁面
4. 選擇高級-主要為了修改資料庫
5. Postgresql的勾取消,我們使用mysql資料庫,使用postgresql會報錯。
6. 選擇安裝的位置
7. 配置資料庫連接
將配置改為mysql
JDBCURL連接串
jdbc:mysql://127.0.0.1:3306/alfresco?autoConnect=true&useUnicode=true&characterEncoding=utf-8
JDBC驅動
com.mysql.jdbc.Driver
資料庫名稱
root (資料庫訪問用戶名)
密碼
資料庫訪問密碼
驗證
驗證資料庫訪問密碼
8. 配置自帶TOMCAT屬性,開始准備的tomcat的埠是8080,所以我在這里設計的時候埠都+1
9. 設置FTP埠,默認就可以
10. 設置RMI埠,默認就可以
11. 登錄系統的管理原密碼,一定要記住
12. 設置SharePoint埠 默認就可以
13. 設置LIBREOFFICE埠 默認就可以
14. 設置啟動方式,選擇手動吧,啟動比較慢
15. 開始安裝等待
16. 安裝完成
17. 在啟動前要講MYSQL的連接JAR復制到alfreco中
將mysql-connector-java-5.1.7-bin.jar復制到C:\Alfresco\tomcat\lib
18. 啟動alfeco
在開始里找到Manager tool
點擊start
第一次啟動比較慢,會在資料庫中建立表並插入數據
19. 打開alfresco,也可在ie中輸入http://127.0.0.1:8081/share/
20. 登錄
用戶名:admin 密碼:安裝中配置的密碼
F. 大數據所謂的分布式運算是指什麼
分布式計算是一種計算方法,和集中式計算是相對的。分布式計算將該應用分解成許多小的部分,分配給多台計算機進行處理。這樣可以節約整體計算時間,大大提高計算效率。
分布式計算可以分為以下幾類:
傳統的C/S模型。如HTTP/FTP/SMTP/POP/DBMS等伺服器。客戶端向伺服器發送請求,伺服器處理請求,並把結果返回給客戶端。客戶端處於主動,伺服器處於被動。
集群技術。一種稱集群的技術出現了,它把多台伺服器連接起來,當成一台伺服器來用。這種技術的好處就是,不但對客戶來說是透明的,對伺服器軟體來說也是透明的,軟體不用做任何修改就可以在集群上運行。
通用型分布式計算環境。如CORBA/DCOM/ RMI/ DBUS等,這些技術(規范)差不多都有具有網路透明性,被調用的方法可能在另外一個進程中,也可能在另外一台機器上。調用者基本上不用關心是本地調用還是遠程調用。