參數(shù)名

是否默認(rèn)

參數(shù)說明

-h,?--help

?

顯示幫助信息

-b,?--bind

?

綁定指定地址，但不支持TNonblockingServer和THsHaServer，兩者總是使用“0.0.0.0”

-p,?--port

9090

綁室指定端口，默認(rèn)為9090

-f,?--framed

?

使用TFramedTransport

-c,?--compact

?

使用TCompactProtocol，默認(rèn)是TBinaryProtocol

-threadpool

是

使用TThreadPoolServer，為默認(rèn)Server

-nonblocking

?

使用實(shí)現(xiàn)了FramedTransport的TNonblockingServer

-hsha

?

使用實(shí)現(xiàn)了FramedTransport的THsHaServer

//?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除默認(rèn)的TFramedTransport?(TBufferTransports.h)，還可選擇：

//?TBufferedTransport?(TBufferTransports.h)

//?THttpTransport

//?TZlibTransport

//?TFDTransport?(TSimpleFileTransport)

//

//?Protocol除默認(rèn)的apache::thrift::protocol::TBinaryProtocol，還可選擇：

//?TCompactProtocol

//?TJSONProtocol

//?TDebugProtocol

template? ?thriftclient,

??????????class?Protocol=apache::thrift::protocol::TBinaryProtocol,

??????????class?Transport=apache::thrift::transport::TFramedTransport>

class?CThriftClientHelper

//?HBase?thrift2?C++編程示例

#include?"THBaseService.h"

#include??//?PRIu64

#include?

#include?

#include?

?

//?請(qǐng)注意客戶端使用的thrift的Transport和Protocol要和hbase?thrift2服務(wù)端保持一致，

//?否則調(diào)用時(shí)，可能總是報(bào)超時(shí)，或其它錯(cuò)誤！！！

//

//?運(yùn)行之前，請(qǐng)通過HBase?shell創(chuàng)建好表：create?'test','cf1','cf2'

//?或指定版本數(shù)：create?'test',{NAME=>'cf1',VERSIONS=>2},{NAME=>'cf2',VERSIONS=>3}

//?刪除表，按順序執(zhí)行以下兩條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";?????//?表名，確保運(yùn)行之前已創(chuàng)建好

????????std::string?rowkey?=?"row1";????????//?行Key

????????std::string?family?=?"cf1";?????????//?例族名

????????std::string?columnname?=?"f1";??????//?例名

????????std::string?columnvalue?=?"value1";?//?例值

?

????????//?插入?yún)?shù)設(shè)置

????????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);?//?插入，出錯(cuò)拋異常hbase::thrift2::TIOError

?

????????//?查詢參數(shù)設(shè)置

????????hbase::thrift2::TGet?input;

????????input.__set_row(rowkey);

?

????????hbase::thrift2::TResult?result;?//?查詢結(jié)果存放在這里

????????hbase_client->get(result,?tablename,?input);?//?查詢，出錯(cuò)拋異常hbase::thrift2::TIOError

?

????????//?顯示查詢結(jié)果

????????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)

????{

????????//?如果和服務(wù)端的Transport和Protocol不同，這里的錯(cuò)誤是“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;

}