Ⅰ rpc的實現機制是什麼
RPC 的全稱是 Remote Procere Call 是一種進程間通信方式。它允許程序調用另一個地址空間（通常是共享網路的另一台機器上）的過程或函數，而不用程序員顯式編碼這個遠程調用的細節。即無論是調用本地介面/服務的還是遠程的介面/服務，本質上編寫的調用代碼基本相同。
比如兩台伺服器A，B，一個應用部署在A伺服器上，想要調用B伺服器上應用提供的函數或者方法，由於不在一個內存空間，不能直接調用，這時候需要通過就可以應用RPC框架的實現來解決。
RPC 會隱藏底層的通訊細節（不需要直接處理Socket通訊或Http通訊）
RPC 是一個請求響應模型。客戶端發起請求，伺服器返回響應（類似於Http的工作方式）
RPC 在使用形式上像調用本地函數（或方法）一樣去調用遠程的函數（或方法）。
二、常見RPC框架
幾種比較典型的RPC的實現和調用框架。
（1）RMI實現，利用java.rmi包實現，基於Java遠程方法協議(Java Remote Method Protocol)
和java的原生序列化。
（2）Hessian，是一個輕量級的remoting onhttp工具，使用簡單的方法提供了RMI的功能。 基於HTTP協議，採用二進制編解碼。
（3）THRIFT是一種可伸縮的跨語言服務的軟體框架。thrift允許你定義一個描述文件，描述數據類型和服務介面。依據該文件，編譯器方便地生成RPC客戶端和伺服器通信代碼。
二、RPC框架實現原理
在RPC框架中主要有三個角色：Provider、Consumer和Registry。如下圖所示：
RPC框架面試總結-RPC原理及實現
節點角色說明：
* Server: 暴露服務的服務提供方。
* Client: 調用遠程服務的服務消費方。
* Registry: 服務注冊與發現的注冊中心。
三、RPC調用流程
RPC基本流程圖：
RPC框架面試總結-RPC原理及實現
一次完整的RPC調用流程（同步調用，非同步另說）如下：
1）服務消費方（client）調用以本地調用方式調用服務；
2）client stub接收到調用後負責將方法、參數等組裝成能夠進行網路傳輸的消息體；
3）client stub找到服務地址，並將消息發送到服務端；
4）server stub收到消息後進行解碼；
5）server stub根據解碼結果調用本地的服務；
6）本地服務執行並將結果返回給server stub；
7）server stub將返回結果打包成消息並發送至消費方；
8）client stub接收到消息，並進行解碼；
9）服務消費方得到最終結果。
RPC框架的目標就是要2~8這些步驟都封裝起來，讓用戶對這些細節透明。
四、服務注冊&發現
RPC框架面試總結-RPC原理及實現
服務提供者啟動後主動向注冊中心注冊機器ip、port以及提供的服務列表；
服務消費者啟動時向注冊中心獲取服務提供方地址列表，可實現軟負載均衡和Failover；
五、使用到的技術
1、動態代理
生成 client stub和server stub需要用到 Java 動態代理技術 ，我們可以使用JDK原生的動態代理機制，可以使用一些開源位元組碼工具框架 如：CgLib、Javassist等。
2、序列化
為了能在網路上傳輸和接收 Java對象，我們需要對它進行 序列化和反序列化操作。
* 序列化：將Java對象轉換成byte[]的過程，也就是編碼的過程；
* 反序列化：將byte[]轉換成Java對象的過程；
可以使用Java原生的序列化機制，但是效率非常低，推薦使用一些開源的、成熟的序列化技術，例如：protobuf、Thrift、hessian、Kryo、Msgpack
關於序列化工具性能比較可以參考：jvm-serializers
3、NIO
當前很多RPC框架都直接基於netty這一IO通信框架，比如阿里巴巴的HSF、bbo，Hadoop Avro，推薦使用Netty 作為底層通信框架。
4、服務注冊中心
可選技術：
* Redis
* Zookeeper
* Consul
* Etcd
Ⅱ Java rpc調用報Connection refused: connect；這個是問題導致的如何解決
看猜啟顫看是不是埠沒打開旁仿，
unix linux osx下在命穗敗令行中使用lsof -i:20382 查看
windows下在cmd中使用netstat -ano|findstr 20382查看
Ⅲ JAVA 遠程 調用的幾種實現方式簡析 詳細�0�3
基本原理 要實現網路機器間的通訊，首先得來看看計算機系統網路通信的基本原理，在底層層面去看，網路通信需要做的就是將流從一台計算機傳輸到另外一台計算機，基於傳輸協議和網路 IO 來實現，其中傳輸協議比較出名的有 http、tcp、 udp 等等，http、tcp、udp 都是在基於Socket 概念上為某類應用場景而擴展出的傳輸協議，網路IO，主要有bio、nio、aio 三種方式，所有的分布式應用通訊都基於這個原理而實現，只是為了應用的易用，各種語言通常都會提供一些更為貼近應用易用的應用層協議。 應用級協議 遠程服務通訊，需要達到的目標是在一台計算機發起請求，另外一台機器在接收到請求後進行相應的處理並將結果返回給請求端，這其中又會有諸如 onewayrequest、同步請求、非同步請求等等請求方式，按照網路通信原理，需要實現這個需要做的就是將請求轉換成流，通過傳輸協議傳輸至遠端，遠端計算機在接收到請求的流後進行處理，處理完畢後將結果轉化為流，並通過傳輸協議返回給調用端。原理是這樣的，但為了應用的方便，業界推出了很多基於此原理之上的應用級的協議，使得大家可以不用去直接操作這么底層的東西，通常應用級的遠程通信協議會提供: 1.為了避免直接做流操作這么麻煩，提供一種更加易用或貼合語言的標准傳輸格式;2.網路通信機制的實現，就是替你完成了將傳輸格式轉化為流，通過某種傳輸協議傳輸至遠端計算機，遠端計算機在接收到流後轉化為傳輸格式，並進行存儲或以某種方式通知遠端計算機。 所以在學習應用級的遠程通信協議時，我們可以帶著這幾個問題進行學習: 1.傳輸的標准格式是什麼?2.怎麼樣將請求轉化為傳輸的流?3.怎麼接收和處理流?4.傳輸協議是? 不過應用級的遠程通信協議並不會在傳輸協議上做什麼多大的改進，主要是在流操作方面，讓應用層生成流和處理流的這個過程更加的貼合所使用的語言或標准，至於傳輸協議則通常都是可選的，在java 領域中知名的有:RMI、 XML-RPC、Binary-RPC、SOAP、CORBA、JMS，來具體的看看這些遠程通信的應用級協議: RMIRMI 是個典型的為java 定製的遠程通信協議，我們都知道，在 singlevm 中，我們可以通過直接調用javaobjectinstance 來實現通信，那麼在遠程通信時，如果也能按照這種方式當然是最好了，這種遠程通信的機製成為RPC(RemoteProcereCall)，RMI 正是朝著這個目標而誕生的。 來看下基於RMI 的一次完整的遠程通信過程的原理: 1.客戶端發起請求，請求轉交至RMI 客戶端的stub 類;2.stub 類將請求的介面、方法、參數等信息進行序列化;3.基於socket 將序列化後的流傳輸至伺服器端;4.伺服器端接收到流後轉發至相應的skelton 類;5.skelton 類將請求的信息反序列化後調用實際的處理類;6.處理類處理完畢後將結果返回給 skelton 類;7.Skelton 類將結果序列化，通過socket 將流傳送給客戶端的 stub;8.stub 在接收到流後反序列化，將反序列化後的JavaObject 返回給調用者。 根據原理來回答下之前學習應用級協議帶著的幾個問題: 1.傳輸的標准格式是什麼?是JavaObjectStream。2.怎麼樣將請求轉化為傳輸的流?基於Java 串列化機制將請求的javaobject 信息轉化為流。3.怎麼接收和處理流?根據採用的協議啟動相應的監聽埠，當有流進入後基於Java 串列化機制將流進行反序列化，並根據RMI 協議獲取到相應的處理對象信息，進行調用並處理，處理完畢後的結果同樣基於java 串列化機制進行返回。4.傳輸協議是?Socket。 XML-RPCXML-RPC 也是一種和RMI 類似的遠程調用的協議，它和RMI 的不同之處在於它以標準的 xml 格式來定義請求的信息(請求的對象、方法、參數等)，這樣的好處是什麼呢，就是在跨語言通訊的時候也可以使用。 來看下XML-RPC 協議的一次遠程通信過程: 1.客戶端發起請求，按照XML-RPC 協議將請求信息進行填充;2.填充完畢後將xml 轉化為流，通過傳輸協議進行傳輸;3.接收到在接收到流後轉換為xml，按照XML-RPC 協議獲取請求的信息並進行處理;4.處理完畢後將結果按照XML- RPC 協議寫入xml 中並返回。 同樣來回答問題: 1.傳輸的標准格式是?標准格式的XML。2.怎麼樣將請求轉化為傳輸的流? 將XML 轉化為流。3.怎麼接收和處理流?通過監聽的埠獲取到請求的流，轉化為XML，並根據協議獲取請求的信息，進行處理並將結果寫入XML 中返回。4. 傳輸協議是?Http。 Binary-RPCBinary-RPC 看名字就知道和XML-RPC 是差不多的了，不同之處僅在於傳輸的標准格式由XML 轉為了二進制的格式。 同樣來回答問題: 1.傳輸的標准格式是?標准格式的二進制文件。2.怎麼樣將請求轉化為傳輸的流?將二進制格式文件轉化為流。3.怎麼接收和處理流?通過監聽的埠獲取到請求的流，轉化為二進制文件，根據協議獲取請求的信息，進行處理並將結果寫入XML 中返回。4.傳輸協議是?Http。 SOAPSOAP 原意為SimpleObjectAccessProtocol，是一個用於分布式環境的、輕量級的、基於XML 進行信息交換的通信協議，可以認為SOAP 是XMLRPC 的高級版，兩者的原理完全相同，都是http+XML，不同的僅在於兩者定義的XML 規范不同，SOAP 也是Webservice 採用的服務調用協議標准，因此在此就不多加闡述了。 (公用對象請求代理[調度]程序體系結構)，是一組用來定義"分布式對象系統"的標准，由 OMG(ObjectMenagementGroup)作為發起和標准制定單位。CORBA 的目的是定義一套協議，符合這個協議的對象可以互相交互，不論它們是用什麼樣的語言寫的，不論它們運行於什麼樣的機器和操作系統。CORBA 在我看來是個類似於SOA 的體系架構，涵蓋可選的遠程通信協議，但其本身不能列入通信協議這里來講，而且CORBA 基本淘汰，再加上對CORBA 也不怎麼懂，在此就不進行闡述了。 JMSJMS 呢，是實現java 領域遠程通信的一種手段和方法，基於JMS 實現遠程通信時和RPC 是不同的，雖然可以做到RPC 的效果，但因為不是從協議級別定義的，因此我們不認為JMS 是個RPC 協議，但它確實是個遠程通信協議，在其他的語言體系中也存在著類似JMS 的東西，可以統一的將這類機制稱為消息機制，而消息機制呢，通常是高並發、分布式領域推薦的一種通信機制，這里的主要一個問題是容錯(詳細見ErLang 論文)。 來看JMS 中的一次遠程通信的過程: 1.客戶端將請求轉化為符合JMS 規定的Message;2.通過JMSAPI 將Message 放入JMSQueue 或Topic 中;3.如為JMSQueue，則發送中相應的目標Queue 中，如為Topic，則發送給訂閱了此Topic 的JMSQueue。4.處理端則通過輪訓 JMSQueue，來獲取消息，接收到消息後根據JMS 協議來解析Message 並處理。 回答問題: 1.傳輸的標准格式是?JMS 規定的Message。2.怎麼樣將請求轉化為傳輸的流?將參數信息放入Message 中即可。3.怎麼接收和處理流?輪訓JMSQueue 來接收Message，接收到後進行處理，處理完畢後仍然是以Message 的方式放入 Queue 中發送或Multicast。4.傳輸協議是?不限。 基於JMS 也是常用的實現遠程非同步調用的方法之一。
Ⅳ RPC 調用和 HTTP 調用的區別
在說RPC和HTTP的區別之前，我覺的有必要了解一下OSI的七層網路結構模型。
實際應用過程中，五層協議結構裡面是沒有表示層和會話層的。應該說它們和應用層合並了。
我們應該將重點放在 應用層 和 傳輸層 這兩個層面。
RPC需要從三個角度來介紹RPC：
先說說RPC服務的基本架構吧，見下圖:
一個完整的RPC架構裡麵包含了四個核心的組件，分別是Client , Server, Client Stub以及Server Stub。
這個Stub大家可以理解為存根。
什麼是同步調用？什麼是非同步調用？
同步調用就是客戶端等待調用執行完成並返回結果。
非同步調用就是客戶端不等待調用執行完成漏卜返回結果，不過依然可以通過回調函數等接收到返回結果的通知。如果客戶端並不關心結果，則可以變成一個單向的調用。
這個過程有點類似於Java中的callable和runnable介面，我們進行非同步執行的時候，如果需要知道執行的結果，就謹凱可以使用callable介面，並且可以通過Future類獲取到非同步執行的結果信息。如果不關心執行的結果，直接使用runnable介面就可以了，因為它不返回結果，當然啦，callable也是可以的，我們不去獲取Future就可以了。
目前流行的開源RPC框架還是比較多的。下面重點介紹三種：
大部分企業開發的模式一直為HTTP介面開發，也就是我們常說的RESTful風格的服務介面。
的確，對於在介面不多、系統與系統交互較少的情況下，解決信息孤島初期常使用的一種通信手段；
優點就是簡單、直接、開發方便。
利用現成的http協議進行傳輸。
比如下面這個例子：
POST http://www.httpexample.com/restful/buyer/info/shar
介面可能返回一個JSON字元串或者是XML文檔。然後客戶端再去處理這個返回的信息，從而可以比較快速地進行開發。
對於大型企業來說，內部子系統較多、介面非常多的情況下，RPC框架的好處就顯示出來了
RPC服務和HTTP服務還是存在很多的不同點的。
一般來說，RPC服務主要是針對大返晌穗型企業的
HTTP服務主要是針對小企業的，因為RPC效率更高，而HTTP服務開發迭代會更快。
總之，選用什麼樣的框架不是按照市場上流行什麼而決定的，而是要對整個項目進行完整地評估，
從而在仔細比較兩種開發框架對於整個項目的影響，最後再決定什麼才是最適合這個項目的。
一定不要為了使用RPC而每個項目都用RPC，而是要因地制宜，具體情況具體分析。
Ⅳ java怎麼遠程調用webservice介面
Java通過WSDL文件來調用webservice：
注意，以下的代碼並沒有經過真正的測試，只是說明這些情況，不同版本的Axis相差很大，大家最好以apache網站上的例子為准，這里僅僅用於說明其基本用法。
1,直接AXIS調用遠程的web service
這種方法比較適合那些高手，他們能直接看懂XML格式的WSDL文件，我自己是看不懂的，尤其我不是專門搞這行的，即使一段時間看懂，後來也就忘記了。直接調用模式如下：
import java.util.Date;
import java.text.DateFormat;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import javax.xml.namespace.QName;
import java.lang.Integer;
import javax.xml.rpc.ParameterMode;
public class caClient {
public static void main(String[] args) {
try {
String endpoint = "http://localhost:8080/ca3/services/caSynrochnized?wsdl";
//直接引用遠程的wsdl文件
//以下都是套路
Service service = new Service();
Call call = (Call) service.createCall();
call.setTargetEndpointAddress(endpoint);
call.setOperationName("addUser");//WSDL裡面描述的介面名稱
call.addParameter("userName", org.apache.axis.encoding.XMLType.XSD_DATE,
javax.xml.rpc.ParameterMode.IN);//介面的參數
call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//設置返回類型
String temp = "測試人員";
String result = (String)call.invoke(new Object[]{temp});
//給方法傳遞參數，並且調用方法
System.out.println("result is "+result);
}
catch (Exception e) {
System.err.println(e.toString());
}
}
}
2,直接SOAP調用遠程的webservice
這種模式我從來沒有見過，也沒有試過，但是網路上有人貼出來，我也轉過來
import org.apache.soap.util.xml.*;
import org.apache.soap.*;
import org.apache.soap.rpc.*;
import java.io.*;
import java.net.*;
import java.util.Vector;
public class caService{
public static String getService(String user) {
URL url = null;
try {
url=new URL("http://192.168.0.100:8080/ca3/services/caSynrochnized");
} catch (MalformedURLException mue) {
return mue.getMessage();
}
// This is the main SOAP object
Call soapCall = new Call();
// Use SOAP encoding
soapCall.setEncodingStyleURI(Constants.NS_URI_SOAP_ENC);
// This is the remote object we're asking for the price
soapCall.setTargetObjectURI("urn:xmethods-caSynrochnized");
// This is the name of the method on the above object
soapCall.setMethodName("getUser");
// We need to send the ISBN number as an input parameter to the method
Vector soapParams = new Vector();
// name, type, value, encoding style
Parameter isbnParam = new Parameter("userName", String.class, user, null);
soapParams.addElement(isbnParam);
soapCall.setParams(soapParams);
try {
// Invoke the remote method on the object
Response soapResponse = soapCall.invoke(url,"");
// Check to see if there is an error, return "N/A"
if (soapResponse.generatedFault()) {
Fault fault = soapResponse.getFault();
String f = fault.getFaultString();
return f;
} else {
// read result
Parameter soapResult = soapResponse.getReturnValue ();
// get a string from the result
return soapResult.getValue().toString();
}
} catch (SOAPException se) {
return se.getMessage();
}
}
}
3,使用wsdl2java把WSDL文件轉成本地類，然後像本地類一樣使用，即可。
這是像我這種懶人最喜歡的方式，仍然以前面的global weather report為例。
首先 java org.apache.axis.wsdl.WSDL2Java http://www.webservicex.net/globalweather.asmx.WSDL
原本的網址是http://www.webservicex.net/globalweather.asmx?WSDL，中間個各問號，但是Linux下面它不能解析，所以去掉問號，改為點號。
那麼就會出現4個文件：
GlobalWeather.java GlobalWeatherLocator.java GlobalWeatherSoap.java GlobalWeatherSoapStub.java
其中GlobalWeatherSoap.java是我們最為關心的介面文件，如果你對RMI等SOAP實現的具體細節不感興趣，那麼你只需要看介面文件即可，在使用的時候，引入這個介面即可，就好像使用本地類一樣。
Ⅵ java protobuf 定義rpc服務怎麼調用
1.，選擇其中的win版本下載，我選擇的是protoc-2.4.1-win32.zip
2.下載一個protobuf-java-2.4.1.jar文件(注意，要與你剛才下的proto.exe版本相同)
然後就開始開發了。
步驟：
1.用記事本編寫一個.proto文件：
}如：編寫的是test.proto
package protobuf;
option java_package = "仿租com.sq.protobuf";
option java_outer_classname = "FirstProtobuf";
message testBuf {
required int32 ID = 1;
required string Url = 2;
}
將其放在與剛解壓的protoc.exe同級目錄中。
2.在cmd中，到protoc-2.4.1-win32文件夾下，
執行
E:\protoc-2.4.1-win32> protoc.exe --java_out=./ test.proto
則可以找到的一個生成的FirstProtobuf.java文件備伍兆。
3.在MyEclipse中新建一個java project，建立包com.sq.protobuf，然後將剛才生成的FirstProtobuf.java文件放在其下面。
此時會報錯，因為沒有引入jar包，在package視圖下，將protobuf-java-2.4.1.jar引入，橘畝即可解決問題。
Ⅶ JSON-RPC輕量級遠程調用協議介紹及使用
json-rpc是基於json的跨語言遠程調用協議。比xml-rpc、webservice等基於文本的協議數據傳輸格小；相對hessian、java-rpc等二進制協議便於調試、實現、擴展，是很優秀的一種遠程調用協議。眼下主流語言都已有json-rpc的實現框架，java語言中較好的json-rpc實現框架有jsonrpc4j、jpoxy、json-rpc。三者之中jsonrpc4j既可獨立使用。又可與spring無縫集合，比較適合於基於spring的項目開發。
json-rpc協議很easy，發起遠程調用時向服務端數據傳輸格式例如以下：
{ "method": "sayHello", "params": ["Hello JSON-RPC"], "id": 1}
參數說明：
method： 調用的方法名
params： 方法傳入的參數。若無參數則傳入 []
id ： 調用標識符。用於標示一次遠程調用過程
server其收到調用請求，處理方法調用，將方法效用結果效應給調用方；返回數據格式：
參數說明:
result: 方法返回值。若無返回值。則返回null。
若調用錯誤，返回null。
error ：調用時錯誤，無錯誤返回null。
id : 調用標識符，與調用方傳入的標識符一致。
以上就是json-rpc協議規范，很easy，小巧。便於各種語言實現。
2.1、server端Java調用演示樣例
jsonrpc4jserver端java演示樣例：
2.2、Javaclient調用演示樣例
jsonrpc4j的Javaclient調用演示樣例：
2.3、JavaScriptclient調用演示樣例
基於jsonrpcjs的JavaScriptclient調用演示樣例：
2.4、直接GET請求進行調用
無需不論什麼client。僅僅需手工拼接參數進行遠程調用，請求URL例如以下：
參數說明:
method : 方法名
params ：調用參數。json的數組格式[], 將參數需先進行url編碼，再進行base64編碼
id : 調用標識符，隨意值。
json-rpc是一種很輕量級的跨語言遠程調用協議。實現及使用簡單。
僅需幾十行代碼，就可以實現一個遠程調用的client。方便語言擴展client的實現。
server端有php、java、python、ruby、.net等語言實現，是很不錯的及輕量級的遠程調用協議。
Ⅷ Java調用wsdl，怎麼實現
java調用wsdl的步驟如下，主要是使用第三方框架：
步驟如下：
1.下載AXIS2類庫，AXIS2是目前java調用webservice的一個主要方法（由於更新較頻繁，請自行google該類庫的網址）
2.由於是第三方webservice，直接引入AXIS2的包就可以用了，代碼如下：
importjava.rmi.RemoteException;
importjavax.xml.rpc.ParameterMode;
importjavax.xml.rpc.ServiceException;
importorg.apache.axis.client.Call;
importorg.apache.axis.client.Service;
importorg.apache.axis.encoding.XMLType;
publicclasswebServiceTest{
publicStringinvokeRemoteFuc(){
Stringendpoint="http://localhost:8080/webservice/services/helloworld";
Stringresult="noresult!";
Serviceservice=newService();
Callcall;
Object[]object=newObject[1];
object[0]="DearImissyou";//Object是用來存儲方法的參數
try{
call=(Call)service.createCall();
call.setTargetEndpointAddress(endpoint);//遠程調用路徑
call.setOperationName("say");//調用的方法名
//設置參數名:
call.addParameter("str1",//參數名
XMLType.XSD_STRING,//參數類型:String
ParameterMode.IN);//參數模式：'IN'or'OUT'
//設置返回值類型：
call.setReturnType(XMLType.XSD_STRING);//返回值類型：String
result=(String)call.invoke(object);//遠程調用
}catch(ServiceExceptione){
e.printStackTrace();
}catch(RemoteExceptione){
e.printStackTrace();
}
returnresult;
}
publicstaticvoidmain(String[]args){
webServiceTestt=newwebServiceTest();
Stringresult=t.invokeRemoteFuc();
System.out.println(result);
}
}
該方法的原理很簡單，通過AXIS2封裝好的類設置URL和參數，直接調用就好了，我們要關注的就是設置URL，方法，還有方法的參數，其他的&paste好啦，很簡單吧，再看看其他的方法，我勒個去了，害我瞎搞兩天。遲點上個源碼共大家參考！