這篇文章主要介紹“.net hbase怎么使用”，在日常操作中，相信很多人在.net hbase怎么使用問(wèn)題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”.net hbase怎么使用”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧！

為環(huán)江等地區(qū)用戶提供了全套網(wǎng)頁(yè)設(shè)計(jì)制作服務(wù)，及環(huán)江網(wǎng)站建設(shè)行業(yè)解決方案。主營(yíng)業(yè)務(wù)為成都網(wǎng)站制作、成都網(wǎng)站設(shè)計(jì)、環(huán)江網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠(chéng)的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會(huì)得到認(rèn)可，從而選擇與我們長(zhǎng)期合作。這樣，我們也可以走得更遠(yuǎn)！

一、開(kāi)篇

1.背景

在大數(shù)據(jù)時(shí)代，HBase 數(shù)據(jù)庫(kù)是個(gè)繞不開(kāi)的熱門(mén)話題。由于其使用 Java 作為主要開(kāi)發(fā)語(yǔ)言，并且依賴大量的 Java 組件（如 Hadoop、zooKeep），使得其他技術(shù)棧想要有一個(gè)對(duì)應(yīng)的 hbase 客戶端變得有一定難度。在 .net 的世界中，一直缺乏能夠直接訪問(wèn) hbase 的客戶端。

2.歷程

Apache Thrift作為社區(qū)內(nèi)比較有名的支持多語(yǔ)言的 Api 服務(wù)，可以解決跨語(yǔ)言訪問(wèn) HBase 數(shù)據(jù)庫(kù)的痛點(diǎn)。在以往的文章中業(yè)也介紹過(guò) C#如何使用 thrift 訪問(wèn) hbase，但在真正的生產(chǎn)環(huán)境中，該方式的訪問(wèn)效率和原生 Java 客戶端比起來(lái)真著實(shí)讓人心灰意冷。此外，thrift 也要求服務(wù)端和客戶端版本一致。

Protocol BuffersHBase 提供基于 Protocol 的數(shù)據(jù)訪問(wèn)，這以一種相對(duì)高效緊湊的數(shù)據(jù)交換規(guī)則?；诖?，我們能夠造出屬于 .net 的 hbase 客戶端。

這是一個(gè)造輪子的過(guò)程，中間雖有著許多難點(diǎn)就不再贅述。下面直接介紹該項(xiàng)目的使用。

二、HBaseNet 使用

1.HBase 數(shù)據(jù)庫(kù)準(zhǔn)備

作為項(xiàng)目使用演示，我們就不討論如何搭建 HBase 集群了，一切以簡(jiǎn)單便捷為前提，直接使用別人構(gòu)建好的 docker 鏡像就可以輕松獲取 HBase 數(shù)據(jù)庫(kù)的使用。

在 dockerhub 中搜索 hbase 或者命令行：docker search hbase。結(jié)果中找到dajobe/hbase，將其 pull 到本地就行?？梢园凑兆髡呓坛踢M(jìn)行部署。其核心操作也就幾個(gè)簡(jiǎn)單命令，現(xiàn)作一簡(jiǎn)單摘抄：

docker pull dajobe/hbase # 拉取鏡像到本地
mkdir data # 創(chuàng)建名為data的目錄
id=$(docker run --name=hbase-docker -h hbase-docker -d -v $PWD/data:/data dajobe/hbase) #將hbase-docker設(shè)置為主機(jī)名運(yùn)行，并將docker容器id賦值給id

命令行docker inspect hbase-docker|grep IPAddress查看 hbase 主機(jī)地址：

"SecondaryIPAddresses": null,
"IPAddress": "172.17.0.2",
       "IPAddress": "172.17.0.2",

可以看到我的在 172.17.0.2 上，我們可以直接瀏覽器訪問(wèn)http://172.17.0.2:16010/，看到habse的主頁(yè)說(shuō)明部署成功。此外，最好將本地物理機(jī)的hosts修改以作映射，文件中添加一行172.17.0.2 hbase-docker即可。

2.HBaseNet 簡(jiǎn)單演示

演示項(xiàng)目創(chuàng)建

首先創(chuàng)建控制臺(tái)項(xiàng)目dotnet new console -o HBaseNetTest，然后添加 HBaseNet 客戶端 nuget dotnet add package HBaseNet --version 0.1.0-rc2-final。

使用 AdminClient 創(chuàng)建 HBase 表

直接在主函數(shù)中寫(xiě)下如下代碼:

static async Task Main(string[] args)
{
   // 注意在hosts中添加地址映射
   var ZkQuorum = "hbase-docker";
   var admin = await new AdminClient(ZkQuorum).Build();
   if (admin == null) return;
   var table = "products";
   var cols = new[] { new ColumnFamily("info") };//名為info的列簇
   var create = new CreateTableCall(table, cols)
   {
       SplitKeys = new[] { "8" }// 預(yù)分區(qū)
   };
   //簡(jiǎn)單判斷表是否存在
   var tables = await admin.ListTableNames(new ListTableNamesCall { Regex = table });
   if (true != tables?.Any())
   {
       //使用高級(jí)客戶端創(chuàng)建products表
       var createResult = await admin.CreateTable(create);
       Console.WriteLine($"創(chuàng)建表{table}的結(jié)果:{createResult}.");
   }
   else
   {
       Console.WriteLine($"表{table}已經(jīng)存在");
   }
}

運(yùn)行后控制臺(tái)輸出創(chuàng)建表products的結(jié)果:True.。我們?cè)俨榭粗黜?yè)http://hbase-docker:16010/，找到Tables，可以看到 products 表已經(jīng)被創(chuàng)建：

default	products	ENABLED	2	0	0	0	0	0	0	0	'products', {NAME => 'info', VERSIONS => '3', DATA_BLOCK_ENCODING => 'FAST_DIFF', BLOCKCACHE => 'False', METADATA => {'TTl' => '2147483647'}}

使用 StandardClient 進(jìn)行數(shù)據(jù)的寫(xiě)入和查詢

var client = await new StandardClient(ZkQuorum).Build();
if (client == null) return;
var rowKey = "123";
var values = new Dictionary>
{
   {
       "info", new Dictionary
       {
           {"key", "value".ToUtf8Bytes()}
       }
   }
};
//放入一條數(shù)據(jù)
var rs = await client.Put(new MutateCall(table, rowKey, values));
Console.WriteLine($"放入數(shù)據(jù)key:{rowKey},結(jié)果:{rs.HasProcessed}");
// 根據(jù)rowkey獲取一條數(shù)據(jù)
var getResult = await client.Get(new GetCall(table, rowKey));
Console.WriteLine($"獲取數(shù)據(jù)結(jié)果key:{rowKey}");
// 使用scanner進(jìn)行數(shù)據(jù)掃描
var sc = new ScanCall(table, "1", "")
{
   NumberOfRows = 1000
};
using var scanner = client.Scan(sc);
var scanResults = new List();
while (scanner.CanContinueNext)
{
   var per = await scanner.Next();
   if (true != per?.Any()) continue;
   scanResults.AddRange(per);
}
Console.WriteLine($"掃描數(shù)據(jù)共返回結(jié)果:{scanResults.Count}行");

控制臺(tái)輸出:

放入數(shù)據(jù)key:123,結(jié)果:True
獲取數(shù)據(jù)結(jié)果key:123
掃描數(shù)據(jù)共返回結(jié)果:1行

日志配置

為了方便友好，建議還是開(kāi)啟日志進(jìn)行使用。這里就以使用Serilog為例，添加以下 nuget 包：

dotnet add package Serilog --version 2.10.0-dev-01226
dotnet add package Serilog.Sinks.Console --version 4.0.0-dev-00839
dotnet add package Microsoft.Extensions.DependencyInjection --version 5.0.0-preview.7.20364.11

在主函數(shù)最上面添加:

Log.Logger = new LoggerConfiguration()
   .Enrich.FromLogContext()
   .MinimumLevel.Debug()
   .WriteTo.Console(
       outputTemplate: "[{Timestamp:yyyy-MM-dd HH:mm:ss} {Level:u3}] {Message:lj}{NewLine}{Exception}")
   .CreateLogger();
HBaseConfig.Instance.ServiceProvider = new ServiceCollection()
   .AddLogging(cfg => cfg.AddSerilog(Log.Logger))
   .BuildServiceProvider();

到此，關(guān)于“.net hbase怎么使用”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！