HTTP
srpc支持HTTP协议,只要把idl的内容作填到HTTP的body中,并且在header里填上idl的类型(json/protobuf),就可以与其他框架通过HTTP协议互通,由此可以实现跨语言。
启动SRPCHttpServer/TRPCHttpServer,可以接收由任何语言实现的HTTP client发过来的请求;
启动SRPCHttpClient/TRPCHttpClient,也可以向任何语言实现的Http Server发送请求;
HTTP header:
Content-Type
设置为application/json
表示json,application/x-protobuf
表示protobuf;HTTP body: 如果body中涉及bytes类型,json中需要使用base64进行encode;
在项目的README.md中,我们演示了如何使用curl向SRPCHttpServer发送请求,下面我们给出例子演示如何使用python作为客户端,向TRPCHttpServer发送请求。
示例
proto文件:
syntax="proto3"; // proto2 or proto3 are both supported
package trpc.test.helloworld;
message AddRequest {
string message = 1;
string name = 2;
bytes info = 3;
};
message AddResponse {
string message = 1;
};
service Batch {
rpc Add(AddRequest) returns (AddResponse);
};
python客户端:
import json
import requests
from base64 import b64encode
class Base64Encoder(json.JSONEncoder):
def default(self, o):
if isinstance(o, bytes):
return b64encode(o).decode()
return json.JSONEncoder.default(self, o)
headers = {'Content-Type': 'application/json'}
req = {
'message': 'hello',
'name': 'k',
'info': b'i am binary'
}
print(json.dumps(req, cls=Base64Encoder))
ret = requests.post(url = "http://localhost:8800/trpc.test.helloworld.Batch/Add",
headers = headers, data = json.dumps(req, cls=Base64Encoder))
print(ret.json())
请求路径拼接
README.md中,我们可以看到,路径是由service名和rpc名拼接而成的。而对于以上带package名 package trpc.test.helloworld;
的例子, package名也需要拼接到路径中,SRPCHttp 和 TRPCHttpClient 的拼接路径方式并不一样。我们以curl为例子:
与SRPCHttpServer互通:
curl 127.0.0.1:8811/trpc/test/helloworld/Batch/Add -H 'Content-Type: application/json' -d '{...}'
与TRPCHttpServer互通:
curl 127.0.0.1:8811/trpc.test.helloworld.Batch/Add -H 'Content-Type: application/json' -d '{...}'