大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
oneway的理解还是很模糊,于是看了下Thrift的代码,终于搞懂了 oneway 。
创新互联主要从事成都网站设计、成都网站建设、网页设计、企业做网站、公司建网站等业务。立足成都服务绿园,十载网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:18980820575代码位置: org.apache.thrift.ProcessFunction#isOneway
1 try {
2 result = this.getResult(iface, args);
3 } catch (TException var9) {
4 LOGGER.error("Internal error processing " + this.getMethodName(), var9);
5 TApplicationException x = new TApplicationException(6, "Internal error processing " + this.getMethodName());
6 oprot.writeMessageBegin(new TMessage(this.getMethodName(), (byte)3, seqid));
7 x.write(oprot);
8 oprot.writeMessageEnd();
9 oprot.getTransport().flush();
10 return;
11 }
12
13 if (!this.isOneway()) {
14 oprot.writeMessageBegin(new TMessage(this.getMethodName(), (byte)2, seqid));
15 result.write(oprot);
16 oprot.writeMessageEnd();
17 oprot.getTransport().flush();
18 }
原来开启了 oneway ,一次RPC调用服务端不会返回response 给客户端,也就相当于客户端是忽略结果的一次调用。
默认这个 oneway 是false 的,也就是默认都会返回结果,业务上不关心调用结果的接口可以设置为 oneway,可以稍微提升接口性能。