tars 内置了对 http 的支持,对协议库做了 RPC 封装,使得对业务开发几乎透明,用起来非常方便。由于复用了 tars rpc,因此也拥有了同步和异步以及超时的特性,并能够利用 tars stat 上报调用质量。
本文简单介绍一下使用 http 的方法和步骤,包括同步调用和异步调用, 实例代码参见 examples/HttpDemo。
http server 实现
see demo: examples/HttpDemo/HttpServer
自定义协议, 采用 http, 具体可以[参考 http 服务端的文档()
Copy void HttpServer::initialize()
{
addServant<HttpImp>(ServerConfig::Application + "." + ServerConfig::ServerName + ".HttpObj");
addServantProtocol(ServerConfig::Application + "." + ServerConfig::ServerName + ".HttpObj", &TC_NetWorkBuffer::parseHttp);
}
Copy int HttpImp::doRequest(JceCurrentPtr current, vector<char> &buffer)
{
TC_HttpRequest request;
vector<char> v = current->getRequestBuffer();
string sBuf;
sBuf.assign(&v[0],v.size());
request.decode(sBuf);
TC_HttpResponse rsp;
string s="hello";
rsp.setResponse(s.c_str(),s.size());
rsp.encode(buffer);
return 0;
}
http rpc 的使用
获取客户端代理,设置 http 编解码函数
Copy CommunicatorPtr & comm = Application :: getCommunicator ();
ServantPrx prx = comm -> stringToProxy < ServantPrx > ( "test.server.yourobj" );
// set protocol
prx -> tars_set_protocol (ServantProxy :: PROTOCOL_HTTP1 , 10 );
关于连接复用
虽然 http 支持长短连接, 但是 http 无法连接复用, 即一条连接上只能并行跑一个包(请求和响应), 因此 tars rpc 专门支持了串行模式.
例如:
Copy prx -> tars_connection_serial ( 10 )
相当于启动了 10 个 http 连接, 在连接上完成 http 请求, 正常的 tars 的 rpc 不要启用这个参数!!!
这里使用一条函数启用了 prx 对 http 的支持, 其中第二个参数 10, 即串行连接个数
Copy prx -> tars_set_protocol (ServantProxy :: PROTOCOL_HTTP1 , 10 );
实际上, 这条语句相当于:
Copy ProxyProtocol proto;
proto . requestFunc = tars :: http1Request;
proto . responseExFunc = tars :: http1Response;
prx -> tars_set_protocol (proto);
prx -> tars_connection_serial ( 10 );
发起同步调用
Copy shared_ptr < TC_HttpResponse > rsp;
shared_ptr < TC_HttpRequest > req = std :: make_shared < TC_HttpRequest >();
req -> setPostRequest ( "http://domain.com/hello" , string ( "helloworld-" ) + TC_Common :: tostr (i) , true );
//你可以设置http头支持, keep-alive
req -> setHeader ( "Connection" , "keep-alive" );
prx -> http_call ( "hello" , req , rsp);
注意: 这里 http_call 第一个参数没有实际函数, 只是用来监控用, 即在 web 管理平台接口统计看到函数名是"hello"
发起异步调用
Copy // 编写callback
class MyHttpCb : public HttpCallback
{
public :
virtual int onHttpResponse ( const shared_ptr < TC_HttpResponse > & rsp)
{
return 0 ;
}
virtual int onHttpResponseException ( int expCode)
{
return 0 ;
}
};
// 发起调用
shared_ptr < TC_HttpRequest > req = std :: make_shared < TC_HttpRequest >();
string buff = string ( "helloworld-" ) + TC_Common :: tostr (i);
req -> setPostRequest ( "http://domain.com/hello" , buff , true );
prx -> http_call_async ( "hello" , req , p);
注意: 这里 http_call_async 第一个参数没有实际函数, 只是用来监控用, 即在 web 管理平台接口统计看到函数名是"hello"