2019獨角獸企業重金招聘Python工程師標準>>>

導入包：

理解：rpc是一種“遠程過程調用協議”

RPC采用客戶機/服務器模式。請求程序就是一個客戶機，而服務提供程序就是一個服務器。首先，客戶機調用進程發送一個有進程參數的調用信息到服務進程，然后等待應答信息。在服務器端，進程保持睡眠狀態直到調用信息到達為止。當一個調用信息到達，服務器獲得進程參數，計算結果，發送答復信息，然后等待下一個調用信息，最后，客戶端調用進程接收答復信息，獲得進程結果，然后調用執行繼續進行。

?

具體使用：方面可以理解為，例如一個公司的后臺數據支持此公司多個平臺的使用，如果每個平臺都寫一套調用邏輯，如果后臺邏輯做調整則每個平臺都需要涉及；如果把各個平臺訪問后端的操作提前出來，放在服務端，來提供服務，則各個平臺都可以使用；并且對平臺開發也隱藏了后端。

開發注意：

rpc服務端和rpc客戶端的通信協議接口。服務端和客戶端都必須有，且路徑一致

實例如下：

一：建兩個項目：

客戶端項目：democlient

服務器端項目：demonamenode

在服務器端和客戶端開發都需要建相同的接口：網絡通信雙方都要遵循的協議

1>開發路徑一致；--hadoop.rpctest

2>名稱一致。 ? ? ? --DemoNamenodeProtocol.java

服務器端需要一個協議的實現類：例如DemoNamenodeImpl.java;

服務器端還需要把協議的實現發布到RPC服務上

這里測試實現：ServerPublisher.java

二：服務端項目實現后，需要 打包 ?Runnable JAR,并上傳到服務器上，

發布： ?java -jar ? ***.jar

?

三：服務器端發布后，則客戶端可以調用此服務。

?

代碼實現附上：

---------------------------------------------------------------------start
自定義協議接口：DemoNamenodeProtocol

package hadoop.rpctest; /** 接口定義網絡通信雙方共同遵循的約定或協議*/ public interface DemoNamenodeProtocol {//定義通信上方一致的版本號public static final long versionID = 1L; //定義通信雙方可以調用的方法public String getMetaData(String filePath); }

--------------------------------------------------------------end

---------------------------------------------------------------------start
服務器端 實現類：DemoNamenodeImpl

package hadoop.rpctest; public class DemoNamenodeImpl implements DemoNamenodeProtocol{public String getMetaData(String filePath) {return filePath + "-----我給你開玩笑呢" ;} }

--------------------------------------------------------------end

---------------------------------------------------------------------start
服務發布類：ServerPublisher

package hadoop.rpctest; import java.io.IOException; import org.apache.hadoop.HadoopIllegalArgumentException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.ipc.RPC; import org.apache.hadoop.ipc.RPC.Builder; import org.apache.hadoop.ipc.RPC.Server; //用于把我們定義的業務功能發布為rpc服務 public class ServerPublisher {public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {// TODO Auto-generated method stub//獲取一個創建rpc服務的builderBuilder builder = new RPC.Builder(new Configuration());//通過Builder與我名定義的業務功能建立關系//設置服務端服務實例實現的接口--及通信雙方功能遵循的協議builder.setProtocol(DemoNamenodeProtocol.class);//設置提供業務服務的具體實例對象builder.setInstance(new DemoNamenodeImpl());//設置服務進程所綁定的地址信息builder.setBindAddress("hadoop02");//設置服務進程的端口builder.setPort(10000);//用builder來創建一個服務 （socket服務）Server server = builder.build();//啟動服務，這樣就可以被客戶端調用了server.start();} }

--------------------------------------------------------------end

客戶端訪問測試：DemoClient

package clienttest; import java.io.IOException; import java.net.InetSocketAddress; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.ipc.RPC; import hadoop.rpctest.DemoNamenodeProtocol; public class DemoClient { public static void main(String[] args) throws IOException {//客戶端訪問rpc服務器代碼實現InetSocketAddress addr = new InetSocketAddress("hadoop02",10000);DemoNamenodeProtocol demoNamenodeImpl = RPC.getProxy(DemoNamenodeProtocol.class, 1L, addr, new Configuration());String MetaData = demoNamenodeImpl.getMetaData("獲取RPC服務：hello world");System.out.println(MetaData); } }

?

轉載于:https://my.oschina.net/u/3420885/blog/1634814

總結

以上是生活随笔為你收集整理的Hadoop 中RPC使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。