參數名

是否默認

參數說明

-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

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

?

//?請注意客戶端使用的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;

}