點(diǎn)擊上方藍(lán)色“小哈學(xué)Java”，選擇“設(shè)為星標(biāo)”

來(lái)源 | my.oschina.net/keking/blog/3037372

• rocksdb
• RestExpress
• 實(shí)現(xiàn)kedis
• 結(jié)語(yǔ)

今天主要介紹兩個(gè)開(kāi)源項(xiàng)目，然后創(chuàng)建應(yīng)用最終實(shí)現(xiàn)的效果就像簡(jiǎn)版的redis服務(wù)那樣，通過(guò)http的get請(qǐng)求，能夠插入和獲取數(shù)據(jù)，項(xiàng)目暫取名為kedis，源碼后面會(huì)上傳到git倉(cāng)庫(kù)。他們分別是Facebook開(kāi)源的Rocksdb和netty實(shí)現(xiàn)的http容器RestExpress。通過(guò)實(shí)現(xiàn)這樣的一個(gè)key/value系統(tǒng)實(shí)例來(lái)學(xué)習(xí)這兩個(gè)框架的使用。

rocksdb

項(xiàng)目地址：https://github.com/facebook/rocksdb

RocksDB是一個(gè)帶key/value接口的存儲(chǔ)引擎，其中鍵和值是任意字節(jié)流。它是一個(gè)C ++庫(kù)。它是在Facebook基于google開(kāi)源的LevelDB（https://github.com/google/LevelDB）開(kāi)發(fā)的，并為L(zhǎng)evelDB API提供向后兼容的支持。

RocksDB支持各種存儲(chǔ)硬件，最初的重點(diǎn)是快速閃存。它使用日志結(jié)構(gòu)化數(shù)據(jù)庫(kù)引擎進(jìn)行存儲(chǔ)，完全用C ++編寫(xiě)，并有一個(gè)名為RocksJava的Java包裝器。

RocksDB可以適應(yīng)各種生產(chǎn)環(huán)境，包括純內(nèi)存，閃存，硬盤(pán)或遠(yuǎn)程存儲(chǔ)。在RocksDB無(wú)法自動(dòng)適應(yīng)的情況下，提供了高度靈活的配置設(shè)置，以允許用戶(hù)為其進(jìn)行調(diào)整。它支持各種壓縮算法和生產(chǎn)支持和調(diào)試的好工具。

特征

• 專(zhuān)為希望在本地或遠(yuǎn)程存儲(chǔ)系統(tǒng)上存儲(chǔ)多達(dá)數(shù)TB數(shù)據(jù)的應(yīng)用程序服務(wù)器而設(shè)計(jì)。
• 優(yōu)化用于在快速存儲(chǔ) - 閃存設(shè)備或內(nèi)存中存儲(chǔ)中小尺寸鍵值
• 它適用于具有多個(gè)內(nèi)核的處理器

RocksDB就是這樣的一個(gè)key/value存儲(chǔ)引擎，facebook基于RocksDB這個(gè)項(xiàng)目寫(xiě)了MyRocks，一個(gè)使用RocksDB實(shí)現(xiàn)的msyql數(shù)據(jù)庫(kù)引擎。通過(guò)RocksDB的壓縮技術(shù)相比InnoDB能夠節(jié)省很大的存儲(chǔ)空間。newsql數(shù)據(jù)庫(kù)tidb組件tikv也使用了RocksDB作為底層數(shù)據(jù)存儲(chǔ)。

RestExpress

項(xiàng)目地址：https://github.com/RestExpress/RestExpress

RESTExpress是一個(gè)非常高效的小型http容器，可以在Java中創(chuàng)建性能非常高，可擴(kuò)展的RESTful服務(wù)。使用牛逼的Netty框架編寫(xiě)，RESTExpress使用非阻塞I / O來(lái)處理請(qǐng)求，同時(shí)利用Executor來(lái)服務(wù)后端邏輯服務(wù)（可能是阻塞）操作。

實(shí)現(xiàn)kedis

創(chuàng)建服務(wù)并綁定端口

/**
?*?@author:?kl?@kailing.pub
?*?@date:?2019/4/12
?*/
public?class?Main?{

????public?static?void?main(String[]?args)?{
????????Configs?configs?=?new?Configs();
????????configs.fromArgs(args);
????????RestExpress?server?=?new?RestExpress()
????????????????.setName("kedis-server")
????????????????.setBaseUrl("http://localhost:"?+configs.getPort());
????????KedisCore?core?=new?KedisCore(configs.getDbPath());
????????Routes.define(server,core);
????????server.bind(configs.getPort());
????????server.awaitShutdown();
????}
}

創(chuàng)建RocksDB引擎api操作類(lèi)

/**
?*?@author:?kl?@kailing.pub
?*?@date:?2019/4/12
?*/
public?class?KedisCore?{

????private?RocksDB?db;

????public?KedisCore(String?path)?{
????????RocksDB.loadLibrary();
????????try?{
????????????final?Options?options?=?new?Options().setCreateIfMissing(true);
????????????this.db?=?RocksDB.open(options,?path);
????????}?catch?(RocksDBException?ex)?{
????????????ex.printStackTrace();
????????}
????}

????public?String?put(Request?request,?Response?response)?throws?Exception?{
????????Map?map?=?request.getQueryStringMap();
????????String?key?=?map.get("key");
????????String?value?=?map.get("value");
????????db.put(key.getBytes(),?value.getBytes());
????????return?"ok";
????}

????public?String?get(Request?request,?Response?response)?throws?Exception?{
????????Map?map?=?request.getQueryStringMap();
????????String?key?=?map.get("key");
????????byte[]?values?=?db.get(key.getBytes());
????????if(values?!=?null){
????????????return?new?String(values,"utf-8");
????????}else?{
???????????return?null;
????????}
????}
}

設(shè)置請(qǐng)求路由

/**
?*?@author:?kl?@kailing.pub
?*?@date:?2019/4/12
?*/
public?abstract?class?Routes?{
???public?static?void?define(RestExpress?server,KedisCore?core){
???????server.uri("/put",?core).action("put",?HttpMethod.GET).noSerialization();
???????server.uri("/get",?core).action("get",?HttpMethod.GET).noSerialization();
???}
}

代碼地址：https://gitee.com/kailing/kedis

mvn install打包后，進(jìn)入target目錄會(huì)有kedis-1.0.jar。CMD下分別執(zhí)行如下腳本啟動(dòng)驗(yàn)證

啟動(dòng)

java?-jar?kedis-1.0.jar?--port?8081

插入數(shù)據(jù)

curl?http://localhost:8081/put?key=name&value=ckl

獲取數(shù)據(jù)

curl?http://localhost:8081/get?key=name

結(jié)語(yǔ)

RocksDB和RestExpress這兩個(gè)項(xiàng)目都很有特點(diǎn)，RocksDB作為嵌入式的微存儲(chǔ)引擎java包裝器的大小僅有10M左右，主要是C++編譯后的dll和so文件，其本身功能非常強(qiáng)大，強(qiáng)大到可以作為mysql的底層存儲(chǔ)引擎，對(duì)底層存儲(chǔ)做了很多的優(yōu)化。RestExpress雖很輕量但五臟俱全，非常適合一些小工具暴露http的服務(wù)。