专栏首页蓝天HBase & thrift & C++编程

HBase & thrift & C++编程

1. 前言

本文目的是介绍使用C++如何操作HBase。从HBase 0.94开始,HBase新增thrift2,本文只介绍和讨论thrift2相关的。hbase-1.1.2使用的thrift估计是thrift-0.9.0版本。

2. 启动和停止thrift2

2.1. 启动thrift2

登录HBase master机器,执行以下命令启动thrift2:hbase-daemon.sh start thrift2。

thrift默认的监听端口是9090,可以通过参数“-p”指定其它端口。默认使用的Server是TThreadPoolServer。默认使用的Protocol是TBinaryProtocol。

注意客户端使用的Protocol和Transport和服务端的要保持一致,否则客户端在调用时,可能遇到“EAGAIN (timed out)”等错误。

2.2. 停止thrift2

hbase-daemon.sh stop thrift2

2.3. 启动参数

使用“hbase-daemon.sh start thrift2”时,还可以带以下参数:

参数名

是否默认

参数说明

-h, --help

显示帮助信息

-b, --bind

绑定指定地址,但不支持TNonblockingServer和THsHaServer,两者总是使用“0.0.0.0”

-p, --port

9090

绑室指定端口,默认为9090

-f, --framed

使用TFramedTransport

-c, --compact

使用TCompactProtocol,默认是TBinaryProtocol

-threadpool

使用TThreadPoolServer,为默认Server

-nonblocking

使用实现了FramedTransport的TNonblockingServer

-hsha

使用实现了FramedTransport的THsHaServer

客户端和hbase thrift2的Transport和Protocol需保持一致,比如客户端为FramedTransport,则也需以“-f”启动hbase thrift2。

否则客户端在调用时,可能会遇到“EAGAIN (timed out)”等错误。

启动参数信息来源于官网的页面:

https://hbase.apache.org/devapidocs/org/apache/hadoop/hbase/thrift2/package-summary.html

以上参数不是给hbase-daemon.sh使用,而是被hbase thrift2使用,可以浏览相关源代码了解细节:

hbase-thrift\src\main\java\org\apache\hadoop\hbase\thrift2\ThriftServer.java

hbase-thrift\src\main\java\org\apache\hadoop\hbase\thrift2\ThriftHBaseServiceHandler.java

? 启动示例:

hbase-daemon.sh start thrift2 --framed -nonblocking

3. hbase.thrift

hbaser.thrift文件在hbase源代码包(以hbase-1.1.2为例)中的位置:

hbase-thrift\src\main\resources\org\apache\hadoop\hbase\thrift2\hbase.thrift

3.1. 编译hbase.thrift

保持机器上已安装好thrift(经测试hbase-1.1.2和thrift-0.9.0兼容),然后使用下列命令编译:thrift --gen cpp -out . hbase.thrift,编译成功后,会在“-out”指定的目录下生成以下五个文件:

THBaseService.h

THBaseService.cpp

hbase_types.h

hbase_types.cpp

hbase_constants.h

hbase_constants.cpp

其中供客户端使用的是位于文件THBaseService.h中的类THBaseServiceClient。

4. thrift_helper.h

为了简化C++客户端的编程,可以使用thrift_helper.h:

https://github.com/eyjian/mooon/blob/master/common_library/include/mooon/net/thrift_helper.h,它可以帮助简化对HBase thrift2的调用:

// thrift客户端辅助类
//
// 使用示例:
// mooon::net::CThriftClientHelper client(rpc_server_ip, rpc_server_port);
// try
// {
//     client.connect();
//     client->foo();
// }
// catch (apache::thrift::transport::TTransportException& ex)
// {
//     MYLOG_ERROR("thrift exception: (%d)%s\n", ex.getType(), ex.what());
// }
// catch (apache::thrift::transport::TApplicationException& ex)
// {
//     MYLOG_ERROR("thrift exception: %s\n", ex.what());
// }
// catch (apache::thrift::TException& ex)
// {
//     MYLOG_ERROR("thrift exception: %s\n", ex.what());
// }
// Transport除默认的TFramedTransport (TBufferTransports.h),还可选择:
// TBufferedTransport (TBufferTransports.h)
// THttpTransport
// TZlibTransport
// TFDTransport (TSimpleFileTransport)
//
// Protocol除默认的apache::thrift::protocol::TBinaryProtocol,还可选择:
// TCompactProtocol
// TJSONProtocol
// TDebugProtocol
template
class Protocol=apache::thrift::protocol::TBinaryProtocol,
class Transport=apache::thrift::transport::TFramedTransport>
class CThriftClientHelper

5. 示例代码

// HBase thrift2 C++编程示例
#include "THBaseService.h"
#include  // PRIu64
#include
#include
#include
// 请注意客户端使用的thrift的Transport和Protocol要和hbase thrift2服务端保持一致,
// 否则调用时,可能总是报超时,或其它错误!!!
//
// 运行之前,请通过HBase shell创建好表:create 'test','cf1','cf2'
// 或指定版本数:create 'test',{NAME=>'cf1',VERSIONS=>2},{NAME=>'cf2',VERSIONS=>3}
// 删除表,按顺序执行以下两条HBase shell命令:
// disable 'test'
// drop 'test'
STRING_ARG_DEFINE(hbase_ip, "192.168.0.1", "hbase thrift ip");
INTEGER_ARG_DEFINE(uint16_t, hbase_port, 9090, 1000, 50000, "hbase thrift port");
int main(int argc, char* argv[])
{
std::string errmsg;
if (!mooon::utils::parse_arguments(argc, argv, &errmsg))
{
fprintf(stderr, "parameter error: %s\n", errmsg.c_str());
exit(1);
}
using namespace apache;
using namespace apache::hadoop;
std::string hbase_ip = mooon::argument::hbase_ip->value();
uint16_t hbase_port = mooon::argument::hbase_port->value();
mooon::net::CThriftClientHelper hbase_client(hbase_ip, hbase_port);
try
{
hbase_client.connect(); // 连接hbase thrift2 server
fprintf(stdout, "connect %s:%d ok\n", hbase_ip.c_str(), hbase_port);
std::string tablename = "test";     // 表名,确保运行之前已创建好
std::string rowkey = "row1";        // 行Key
std::string family = "cf1";         // 例族名
std::string columnname = "f1";      // 例名
std::string columnvalue = "value1"; // 例值
// 插入参数设置
std::vector columns_value(1);
columns_value[0].__set_family(family);
columns_value[0].__set_qualifier(columnname);
columns_value[0].__set_value(columnvalue);
hbase::thrift2::TPut put;
put.__set_row(rowkey);
put.__set_columnValues(columns_value);
hbase_client->put(tablename, put); // 插入,出错抛异常hbase::thrift2::TIOError
// 查询参数设置
hbase::thrift2::TGet input;
input.__set_row(rowkey);
hbase::thrift2::TResult result; // 查询结果存放在这里
hbase_client->get(result, tablename, input); // 查询,出错抛异常hbase::thrift2::TIOError
// 显示查询结果
for (int i=0; i
{
const hbase::thrift2::TColumnValue& column_value_ref = result.columnValues[i];
fprintf(stdout, "family[%s]/qualifier[%s]/timestamp[%"PRIu64"]: %s\n", column_value_ref.family.c_str(),
column_value_ref.qualifier.c_str(),
column_value_ref.timestamp,
column_value_ref.value.c_str());
}
}
catch (hbase::thrift2::TIOError& ex)
{
fprintf(stderr, "IOError: %s\n", ex.what());
}
catch (apache::thrift::transport::TTransportException& ex)
{
// 如果和服务端的Transport和Protocol不同,这里的错误是“EAGAIN (timed out)”
fprintf(stderr, "(%d)%s\n", ex.getType(), ex.what());
}
catch (apache::thrift::TApplicationException& ex)
{
fprintf(stderr, "%s\n", ex.what());
}
catch (thrift::TException& ex)
{
fprintf(stderr, "%s\n", ex.what());
}
return 0;
}

如果thrift客户端报如下错误,有可能是因为一次写入的数据太多,导致包过大:

Thrift: Fri Apr 22 17:30:41 2016 TSocket::write_partial() send() Connection reset by peer

Thrift: Fri Apr 22 17:30:41 2016 TSocket::write_partial() send() Connection reset by peer

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • HBase快照迁移数据失败原因及解决办法

    机房裁撤,需将源HBase集群的数据迁移到目标HBase集群,采用快照迁移方式。

    一见
  • 编译hbase-1.2.3源代码

    确保机器可以正常访问Internet,如能正常访问https://repo.maven.apache.org等,如果是代理方式则需要设置好eclipse和m...

    一见
  • 致命错误: zlib.h:没有那个文件或目录

    下面这个错误是因为zlib包没有安装,安装后问题即可解决。但有一点请注意安装命令是:sudo apt-get install zlib1g-dev,而非sudo...

    一见
  • python学习教程:模拟登录知乎

    python学习教程
  • 关于Lorem ipsum

    Wikipedia上的解释是,这只是一段用来测试排版效果的占位文字,没有实际的含义。据说,16世纪的时候就有人开始用了。当时的某个印刷工人,从古罗马政治家西塞罗...

    ruanyf
  • 你知道吗,Flutter内置了10多种show

    builder通常返回Dialog组件,比如SimpleDialog和AlertDialog。

    老孟Flutter
  • 你知道吗,Flutter内置了10多种show

    builder通常返回Dialog组件,比如SimpleDialog和AlertDialog。

    老孟Flutter
  • python机器学习入门资料梳理

    在python基本语法入门之后,就要准备选一个研究方向了。马上就要进行春季实习招聘了,加油!总结一下python机器学习方面的资料吧。 1、数据处理 1....

    机器学习AI算法工程
  • 如何在Jupyter Notebook中使用Python虚拟环境?

    如何在使用Jupyter Notebook时,解决Python虚拟环境间的切换问题?本文一步步帮你拆解。希望你能够避免踩坑的痛苦,把更多的时间花在愉快的编程上。

    王树义
  • 随机产生和为S的N个正整数

    针对该问题,解决的方法有很多种。在这篇文章中,我将为大家给出两种比较好理解的解决方法:一个是“尺子法”;另外一个是“锯木头法”。(名字随便取的,主要是方便理解用...

    孟君

扫码关注云+社区

领取腾讯云代金券