HTTP 支持
tars 内置了对 http 的支持,对协议库做了 RPC 封装,使得对业务开发几乎透明,用起来非常方便。由于复用了 tars rpc,因此也拥有了同步和异步以及超时的特性,并能够利用 tars stat 上报调用质量。
本文简单介绍一下使用 http 的方法和步骤,包括同步调用和异步调用, 实例代码参见 examples/HttpDemo。
http server 实现
see demo: examples/HttpDemo/HttpServer
自定义协议, 采用 http, 具体可以[参考 http 服务端的文档()
void HttpServer::initialize()
{
addServant<HttpImp>(ServerConfig::Application + "." + ServerConfig::ServerName + ".HttpObj");
addServantProtocol(ServerConfig::Application + "." + ServerConfig::ServerName + ".HttpObj", &TC_NetWorkBuffer::parseHttp);
}
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 编解码函数
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 专门支持了串行模式.
例如:
prx->tars_connection_serial(10)
相当于启动了 10 个 http 连接, 在连接上完成 http 请求, 正常的 tars 的 rpc 不要启用这个参数!!!
这里使用一条函数启用了 prx 对 http 的支持, 其中第二个参数 10, 即串行连接个数
prx->tars_set_protocol(ServantProxy::PROTOCOL_HTTP1, 10);
实际上, 这条语句相当于:
ProxyProtocol proto;
proto.requestFunc = tars::http1Request;
proto.responseExFunc = tars::http1Response;
prx->tars_set_protocol(proto);
prx->tars_connection_serial(10);
发起同步调用
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”
发起异步调用
// 编写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”