手寫實現RPC 框架

乙個簡易的rpc框架,別的先不多說上github

github

gitee

註冊中心

: zookeeper (使用curator 操作)

通訊框架

: netty (4.1.25版本)

序列化

: kryo

以下只寫了大體專案流程,以及展示部分**,具體上方github ,**裡基本都寫了注釋

本rpc框架,有乙個統一的框架容器,用來初始化,zookeeper的連線,以及快取一些遠端服務.這樣方便負載均衡呼叫,以及不用每次呼叫都去zookeeper上獲取遠端伺服器,如果遠端伺服器掛機,或者新增新的遠端伺服器,使用watch機制,重新整理到快取中.

//創造rpc應用容器,建議使用單列 //如果有提供者,設定乙個通訊埠,等待呼叫者來訪問 //把服務註冊進rpc容器,資訊寫入zk, //引數1是服務唯一的名字 //userserviceimp實現了介面userservice //也能這麼註冊,只是註冊的名字是userservice介面的全路徑 //根據服務的名字,去zk中獲取當前提供了該遠端服務的ip位址和埠,存入快取 //同時開啟watch,如果該遠端服務的提供者變動,zk將會推送,然後重新整理快取 //生成**物件,用的jdk動態**. //執行了動態**的**方法,將會呼叫netty去傳送請求. //引數和返回值,講會使用kryo去序列化,然後tcp傳輸 service.xx(...)

注意點:

@override
public object invoke(object proxy, method method, object args) throws throwable 
//呼叫模版方法,正真遠端呼叫
object result = dorpchandle(remoteservices, method, args);
return result;
}

在動態**的時候,一定要過濾了 object的自帶方法.不然在整合spring的時候,spring會自動呼叫equals() 方法,導致異常

netty這邊,沒什麼好說的.重點在於,管道的使用

服務提供者 :

eventloopgroup work = new nioeventloopgroup();
eventloopgroup child = new nioeventloopgroup();
//serializationhandle serializationhandle = new serializationhandle();
serverbootstrap serverbootstrap = new serverbootstrap();
serverbootstrap.group(work,child)
.channel(nioserversocketchannel.class)
.childhandler(new channelinitializer() 
});channelfuture channelfuture = null;
try catch (interruptedexception e) finally

呼叫者,和提供者,類似.

框架介紹,到此就結束了.乙個很簡單的rpc框架.具體實現細節.請移步github,**上都有注釋

手寫實現RPC 框架

手寫實現bind

RPC 手寫乙個RPC框架

實現RPC框架

手寫實現RPC 框架

手寫實現bind

RPC 手寫乙個RPC框架

實現RPC框架

相關推薦