前言

上周六,接了一个紧急任务,说实现使用 C++ 访问 HBase 进行操作。说是用 thrift 来实现。对于 C++ 来说,我真的是门外汉,但需求如此,皱着眉头也要把它实现。好歹在同事的帮助下,也是实现了 demo 示例,现在就把这两天的成果分享给大家。

版本

HDP:2.6.4.0

HBase:1.1.2

一、安装编译thrift

1. 准备工作

使用 yum 安装 Development Tools

1
yum -y groupinstall "Development Tools"

thrift 编译依赖于下面的工具,使用 yum 安装:

1
yum -y install automake libtool flex bison pkgconfig gcc-c++ boost-devel libevent-devel python-devel ruby-devel zlib-devel openssl-devel

2. 下载thrift安装包

为了生成依赖类库 /usr/local/include/thrift//usr/local/lib/ ,需要下载 thrift 源码包。本文使用 thrift 0.8.0 版本,通过以下地址下载后并解压。

1
2
cd /usr;wget http://archive.apache.org/dist/thrift/0.8.0/thrift-0.8.0.tar.gz
tar zxvf thrift-0.8.0.tar.gz;rm -rf thrift-0.8.0.tar.gz

3. 编译thrift

1
2
cd /usr/thrift-0.8.0
./configure --prefix=/usr/local/ --with-boost=/usr/local --with-libevent=/usr/local

命令执行完毕后,如下图所示:

编译 thrift ,执行如下命令:

1
make && make install

命令执行完毕后,如下图所示:

至此,thrift 0.8.0 就编译完成了。可执行 thrift -version 查看版本。

4. 检查相关文件是否存在

thrift编译成功后,会在 /usr/local/include/thrift//usr/local/lib/ 目录下生成相关文件,用于后面使用 g++ 工具编译 cpp 文件。如下图所示:

二、代码示例

1. 开启HBase thrift2

首先需要确保 HBase thrift2 服务正常运行。执行如下命令启动 HBase thrift2 服务:

1
/usr/hdp/2.6.4.0-91/hbase/bin/hbase-daemon.sh start thrift2

服务开启的默认端口号为 9090 ,可执行 netstat -ntlp | grep 9090 检测 thrift2 是否成功启动。

2. 生成c++相关文件

1
2
3
4
# 进入到hbase源码目录
cd /usr/hdp/2.6.4.0-91/hbase/include/thrift
# 在当前目录下生成gen-cpp目录,里面含有c++的相关文件
thrift --gen cpp hbase2.thrift

gen-cpp 目录下的文件列表如下图所示:

3. 编写客户端代码

创建 HbaseClient.cpp 文件(名称可自定义),向 hbase_test 表中插入一条数据,并打印指定 rowkey 的一行数据。代码内容如下所示:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
#include "THBaseService.h"
#include <config.h>
#include <vector>
#include <transport/TSocket.h>
#include <transport/TBufferTransports.h>
#include <protocol/TBinaryProtocol.h>

using namespace std;
using namespace apache::thrift;
using namespace apache::thrift::protocol;
using namespace apache::thrift::transport;
using namespace apache::hadoop::hbase::thrift2;

using boost::shared_ptr;
int readdb(int argc, char** argv) {
fprintf(stderr, "readdb start\n");
int port = atoi(argv[2]);
boost::shared_ptr<TSocket> socket(new TSocket(argv[1], port));
boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket));
boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
try {
transport->open();
printf("open\n");
THBaseServiceClient client(protocol);
TResult tresult;
TGet get;
std::vector<TColumnValue> cvs;
const std::string table("hbase_test");
const std::string thisrow="1";
//get data
get.__set_row(thisrow);
bool be = client.exists(table,get);
printf("exists result value = %d\n", be);
client.get(tresult,table,get);
vector<TColumnValue> list=tresult.columnValues;
std::vector<TColumnValue>::const_iterator iter;
for(iter=list.begin();iter!=list.end();iter++) {
printf("%s, %s, %s\n",(*iter).family.c_str(),(*iter).qualifier.c_str(),(*iter).value.c_str());
}
transport->close();
printf("close\n");
} catch (const TException &tx) {
std::cerr << "ERROR(exception): " << tx.what() << std::endl;
}
fprintf(stderr, "readdb stop\n");
return 0;
}

int writedb(int argc, char** argv){
fprintf(stderr, "writedb start\n");
int port = atoi(argv[2]);
boost::shared_ptr<TSocket> socket(new TSocket(argv[1], port));
boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket));
boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
try {
transport->open();
printf("open\n");
THBaseServiceClient client(protocol);
std::vector<TPut> puts;
const std::string table("hbase_test");

TPut put;
std::vector<TColumnValue> cvs;
//put data
put.__set_row("1");
TColumnValue tcv;
tcv.__set_family("info");
tcv.__set_qualifier("age");

tcv.__set_value("24");
cvs.insert(cvs.end(), tcv);
put.__set_columnValues(cvs);
puts.insert(puts.end(), put);

client.putMultiple(table, puts);
puts.clear();

transport->close();
printf("close\n");
} catch (const TException &tx) {
std::cerr << "ERROR(exception): " << tx.what() << std::endl;
}
fprintf(stderr, "writedb stop\n");
return 0;
}


int main(int argc, char **argv) {
if(argc != 3) {
fprintf(stderr, "param is :XX ip port\n");
return -1;
}
writedb(argc, argv);
readdb(argc, argv);
return 0;
}

4. 生成可执行的文件HbaseClient

使用 g++ 工具编译客户端代码,在 HbaseClient.cpp 所在的目录下执行以下命令:

1
g++ -DHAVE_NETINET_IN_H -o HbaseClient -I/usr/local/include/thrift -I./gen-cpp -L/usr/local/lib HbaseClient.cpp ./gen-cpp/hbase2_types.cpp ./gen-cpp/hbase2_constants.cpp ./gen-cpp/THBaseService.cpp -lthrift -g

命令参数说明:

  • -DHAVE_NETINET_IN_H:该参数解决编译时使用定义的文件内容。
  • -I/usr/local/include/thrift与-I./gen-cpp:g++会先在当前目录查找你所制定的头文件,如果没有找到,会回到缺省的头文件目录查找。使用-I参数指定目录,g++会先在你指定的目录中查找,然后再按常规的顺序查找。
  • -o HbaseClient:编译后输出HbaseClient文件。缺省状态下,编译后输出的文件为a.out。
  • -L/usr/local/lib:编译的时候,指定搜索库的路径。
  • -g:指示编译器,在编译时,产生调试信息。

5. 创建HBase表

在运行客户端之前,我们需要创建一个 hbase_test 表。创建表命令如下所示:

进入 HBase shell 命令行:

1
hbase shell

创建 hbase_test 表:

1
create 'hbase_test', {NAME => 'info'}

可执行 exit 命令退出命令行。

6. 运行客户端

可通过如下命令运行 HbaseClient 客户端:

1
2
# 在HbaseClient文件所在的当前目录下执行
./HbaseClient <thrift2_ip> <thrift2_port>

会出现错误:libthrift-0.8.0.so: cannot open shared object file。如下图所示:

解决方法:

需要配置环境变量。将export LD_LIBRARY_PATH=/usr/local/lib添加至/etc/profile文件中,如下图所示:

最后,执行 source /etc/profile 命令,使环境变量立即生效。

再执行 ./HbaseClient <thrift2_ip> <thrift2_port> 命令试试。

三、总结

1、在 /usr/hdp/2.6.4.0-91/hbase/include/thrift 目录下有两个文件,为 hbase1.thrifthbase2.thrift ,分别对应的thrift 1服务与thrift 2服务。本文采用 thrift 2 连接 HBase 数据库对表进行数据插入与读取操作。

2、使用 thrift --gen cpp hbase2.thrift 命令生成服务端相关代码。

3、在编写客户端文件时,通过 THBaseService.h 文件访问 HBase 服务端,使用 hbase2.thrift 文件内提供的方法对 HBase 数据库进行操作。

四、参考资料

我将这两天搜集的资料,觉得不错的列在下面,也方便继续深入的人查阅。