HBase & thrift & C++炂栫▼

HBase & thrift & C++炂栫▼.pdf婩鍜屽Thrift2 1

2.1.thrift2 1

2.2.Thrift2 1

2.3.マラリア hbase.thrift 2

4.thrift_helper.h3

5. ++ 私は HBase HBase 0.94 HBase HBase 0.94 thrift HBase HBase HBase HBase HBase HBase HBase HBase HBase HBase HBase HBase >hbase-1.1.2 hbase-1.1.2 hbase- を使用しています。 1.1.2 thrift-0.9.0 thrift-0.9.0 2.1.Thrift2thrift2?/span>hbase-daemon.shstartthrift2thrift2樿鄄卭洃钖鍙ｆ槸9090锛屽彲浠ラ€氲tension鍙卛暟「？」 SPAN> -p ´´寚瀹瀹氩叾叾瀹幂€€卞粯卞粯Jiao鐢ㄧJiao

娉ㄦ暇瀹㈡埛绔小鐢ㄧ殑プロトコル鍜?/span>トランスポート鍜屾湇AGAIN(タイムアウト) AGAIN(タイムアウト)阌澾銆?

2.2.base-daemon.shstopthrift2

hbase- daemon.shstopthrift2

2.3.base-daemon.shstartthrift2 Ning︿ 相互妾弬鏁help

卙四暟钖?/span>

鏄惁樿

四暟科

-h、--助けて

min鎸囧畾鍦禁止潃潃甛屼絶嶆敮鎸?span>TNonblockingServer鍜?/span>THsHaServer锛屼袱袱Key呮€絵画槸汮综合椤'?/span>0.0.0.0'?/span>

❤️涶浠モ€?/span>-f濥惎锷?/span>hbasethrift2銆?/span>

钖﹀垯瀹㈡埛绔湪璋卂椤镞讹纴鍙兘浼氶亣鍒 Pull€淓AGAIN( Timedout ocs /org/apache/hadoop/hbase/thrift2/package-summary.html銆?

浠ヤ笂鍙曛暟涓嶆槸缁?span>hbase-daemon.sh雳椤曃囃€屾槸琚? /span>hbasethrift2Huancuan椛屽彲浠ユ祻诺堢浉鍏昆虫簮浠ｇ爜朜 WuВ缁woo妭锛?/span>

hbase-thriftsrcmainjavaorgapachehadoophbasethrift2ThriftServer .java

hbase-thrifts rcmainjavaorgapachehadoophbasethrift2ThriftHBaseServiceHandler.java

?Hbase-daemon.shstartthrift2--framed-nonblocking

3.hbase.thrift

hbaser.thriftHbase-daemon.shstartthrift2--framed-nonblocking hbase-1.1.2 hbase.thrift hbase.thrift hbase.thrift涓婂fan瀹夎 /span>thrift span>thrift--gencpp-out.hbase.thrift涓枃浠讹精品

THBaseService.h

THBaseService.cpp

hbase_types.h

hbase_types.cpp

hbase_con立っています。 h

hbase_constants.cpp

鍏多腑渚鍏多腑渚涘鎴风huanthrift_helper.h /github.com/eyjian/mooon/blob/master/common_library/include/mooon/net/thrift_helper.h唛屽畠鍙相互平和姪绠€鍖栧HBasethrift2鄄勮皟鐢元気です

//thrift瀹㈡埛绔緟锷╃被

//

//フアンクロス敤绀淥甛?/span>

//mooon::net::CThriftClientHelperclient(rpc_server_ip) ,rpc_server_port );

//try

//{

//client.connect();

//client->foo();

-p,--port	9090	缁戝鎸囧畾绔彛岄粯璁やnegative9090
-f,--framed		TframedTransport
-c,--compact		Huancuan敤TCompactProtocol锛岄粯璁ゆ槸TBinaryProtocol
-threadpool	鏄?/span>	framedTransport TNonblockingServer
-hsha		寓敤瀹絵幇浜?span> framedTransport鄄?/span>THsHaServer

//}//catch(apache::thrift: :transport::TTransportException&ex)

//{ //MYLOG_ERROR("thriftException:(% d)%sn",ex.getType(),ex.what()); //} // catch(apache::thrift::transport::TApplicationException&ex) //{ // MYLOG_ERROR("thriftException:%sn",ex.what()); //} //catch(apache ::thrift::TException&ex) //{ //MYLOG_ERROR("thriftException:% sn",ex.what()); //} //Transport鄄ら粯璁ょTframedTransport(TBufferTransports) .h)雃它缮鍙€夋嫨锛?/span> //TBufferedTransport (TBufferTransports.h) //THttpTransport //TZlibTransport //TFDTransport(TSimpleFileTransport) // //プロトコル旄ら粯璁ょ殑apache::thrift::protocol::TBinaryProtocol锛它缮鍙€夋嫨锛?/span> //TCompactProtocol //TJSONProtocol //TDebugProtocol template classProtocol=apache::thrift::protocol::TBin aryProtocol, classTransport =apache::thrift::transport::TframedTransport> classCThriftClientHelper 5.绀轰緥浠g爜 //HBasethrift2C++缂栫▼绀轰緥 #include"&&BaseService.h" #include 64 #include #include #include //鐨凾ransport鍜孭rotocol缺陷佸拰hbasethrift2链嶅姟楽しい缭鎸佷竴鑷达紝 //鍚﹀垯璋幂敤鏃孭紝鍴鍙兘砧叾瀹冮敊璇紒锛侊紒 // //杩愯涔嫔墠锛岃閫氳岃閫氳绷HBaseshell鍒涘缓濂借〃锛涘歝'cate'f2'歝'cate' //鎴栨寚瀹氱增链暟锛歝reate'test',{NAME=>'cf1',VERSIONS= >2},{NAME=>'cf2',VERSIONS=>3} //鍒犻櫎琛紝鎸夐『搴忔墽琛屼互涓嬩袱鏉Baseshell 鍛造リング保護锛? /span> //「テスト」を無効にする STRING_ARG_DEFINE(hbase_ip,"192.168.0.1","hbasethriftip"); INTEGER_ARG_DEFINE(uint16_t,hbase_port,9090, 1000," );0倹約 intmain(intargc,char*argv[] ) { std::stringerrmsg; if(!mooon::utils::parse_arguments(argc,argv,&errmsg)) { fprintf(stderr, "%s str ()); 退出(1); } usingnamespaceapache; uint16_thbase_port=mooon::argument::hbase_port->value(); mooon::net:: CThriftClientHelperhbase_ip🜎🜎 ); { hbase_client.connect();//杩炴帴hbasethrift2server fprintf(stdout,"connect%s:%dokn",h)ベースIP。 c_str(),hbase_port); st=":stringtablest=" ";//辰ㄥ悕锛檄'淇濊刺琛屼箣鍓嶅凡鍒涘缓濂?/span> std::stringrowkey ="row1";//琛孠ey std::stringfamily= "cf1";//渚嬫棌鍚?/span> std::stringcolumnname="f1";//渚嫔悕 std ::stringcolumnvalue="value1";//渚嫔€?/span> //鎻掑叆鍙傛暟璁ストーリー疆 std::vectorcolumns_value(1) ); 叆鍙傛暟璁ストーリー疆 std::vectorcolumns_value(1); 叆鍙傛暟璁_value [0].__set_qualifier(columnname); columns_value [0].__set_value(columnvalue); hbase::thrift2::TPutput; ; hbase_client->put(tablename,put);//鎻掑叆锛屽嚭閿欐姏Liao傚父hbase ::thrift2::TIOError //釗暃ヨ hbase::thrift2::TGetinput; input.__set_row(rowkey); hbase_client->get(result,tablename,input);/ /鏌ヨ锛屽嚭閿欐姏寮傚父hbase::thrift2::TIOError ボ損傷灉 for(inti=0;i(result.columnValues.size()) ;++i) { consthbase::thrift2::TColumnValue&column_column_value_ref=result.i fprintf(stdout,"family[%s]/qualifier[%s]/timestamp[%"PRIu64"]:%sn" 、column_value_ref.family.c_str（）、 column_value_ref.qualifier.c_str（）、column_ref.timestamp、 column_value_ref.value.c_str（）; }} ::TIOError&ex) { n .what()); } catch(apache::thrift::transport::TTransportException&ex) { //濡傛灉鍜屾湇鍔$ 魶sport鐨凾凾凾屾湇鍔$魅sport鐨凾凾岃繖阅殑閿殑閿殑閿殑閿分鏄€淓AGAIN(タイムアウト)'?/span> fprintf (標準エラー、 "(%d)%sn",ex.getType(),ex.what()); } catch(apache::thrift::TApplicationException&ex) { fprintf(stderr,"%sn") ,ex.what()); fprintf(stderr,"%sn",ex.what()); } return0; } http://www.bkjia.com/PHPjc/1096388.html www.bkjia.com tru​​e http://www.bkjia.com/PHPjc/1096388.html🜎技術記事 HBase C++缂栫▼hbase thrift c ++ ..