Dubbo源码学习--thrift协议
Dubbo学习--thrift协议。
当前 dubbo 支持的 thrift 协议是对 thrift 原生协议的扩展，在原生协议的基础上添加了一些额外的头信息，比如 service name，magic number 等。
使用 dubbo thrift 协议同样需要使用 thrift 的 idl compiler 编译生成相应的 java 代码，后续版本中会在这方面做一些增强。
org.apache.thrift
所有服务共用一个端口3：
可以参考dubbo 项目中的示例代码
Thrift 不支持 null 值，即：不能在协议中传递 null 值
1.2.3.0以上版本支持
2.Thrift是 Facebook 捐给 Apache 的一个 RPC 框架
3. 与原生Thrift不兼容
ThriftProtocol也是提供了export和refer对外暴露服务和引用服务两个功能
（1）export：暴露服务，通过netty、mina或者grizaly对外暴露tcp服务
//通过dubboExport中提供的netty、mina或grizaly对外暴露tcp协议
Exporter export(Invoker invoker) throws RpcException {
// can use thrift codec only
URL url = invoker.getUrl().addParameter(Constants.CODEC_KEY, ThriftCodec.NAME);
// find server.
String key = url.getAddress();
// client can expose a service for server to invoke only.
boolean isServer = url.getParameter(Constants.IS_SERVER_KEY, true);
if (isServer && !serverMap.containsKey(key)) {
serverMap.put(key, getServer(url));
// export service.
key = serviceKey(url);
DubboExporter exporter = new DubboExporter(invoker, key, exporterMap);
exporterMap.put(key, exporter);
（2）refer：引用服务，与服务提供者建立长连接进行服务引用
//通过ThriftInvoker中提供的netty、mina或grizaly通过tcp协议与服务提供者建立连接
Invoker refer(Class type, URL url) throws RpcException {
ThriftInvoker invoker = new ThriftInvoker(type, url, getClients(url), invokers);
invokers.add(invoker);thrift与dubbo哪个性能更好_百度知道
thrift与dubbo哪个性能更好
我有更好的答案
wilfulness and selfishness of Prince Eigenwillig.
为您推荐：
其他类似问题
换一换
回答问题，赢新手礼包
个人、企业类
违法有害信息,请在下方选择后提交
色情、暴力
我们会通过消息、邮箱等方式尽快将举报结果通知您。扫一扫体验手机阅读
基于dubbo框架下的RPC通讯协议性能测试
<span type="1" blog_id="2086319" userid='
106篇文章，8W+人气，0粉丝
大数据时代的微服务之路
￥51.00486人订阅
前百度高级工程师的架构高可用实战
￥51.00236人订阅
<span type="1" blog_id="2086319" userid='dubbo thrift和原生态thrift的怎么实现信息互通 _ 湖州宠物网
dubbo thrift和原生态thrift的怎么实现信息互通
在DefaultFuture里就找不到自己的future，HeaderExchanger，凡是涉及到发request的地方，在发请求的时候，把long型的RequestId和强转后的int值关联，Request的id就一直是int型，发Request2，其他的都没改，而且不及时删除这个缓存有可能引起内存泄露重写exchange，也可以直接替换TMessage里的seqId，都要重写，如果强转为int，到客户端处理时。所以自己就重写了Request2，当Request的id大于int型的最大值，Request，拿到的Response的id是long型强转后的int值，这样的话，假设重写后的请求叫Request2，或小于int型的最小值时，把里面的INVOKER_ID改为AtomicInteger，但是觉得这样不太优雅，但是Request的id是long型的。主要原因是想用requestId代替TMessage里seqId，可以在客户端这边做缓存，HeaderExchangeServer，那么当id增长到大于int的最大值时，主要涉及到HeaderExchangeChannel，HeartBeatTask，HeaderExchangeClient。涉及到发送Request的地方全都改成Request2
关于java分布式应用开发除了dubbo还有下面几个框架可推荐： spring-cloud，其他的如twitter的finagle，facebook的thrift。
//Student.thrift namespace php Student service Student{ string getStuName() } 执行thrift --gen php ./Student.thrift 在gen-php下有两个文件。 其中Student.php
//Student.thrift namespace php Student service Student{ string getStuName() } 执行thrift --gen php ./Student.thrift 在gen-php下有两个文件。 其中Student.php
重写exchange，主要涉及到HeaderExchangeChannel，HeaderExchangeClient，HeaderExchangeServer，HeaderExchanger，HeartBeatTask，Request，凡是涉及到发request的地方，都要重写，假设重写后的请求叫Request2，在发请求的时候，发Request2。主...
//Student.thrift namespace php Student service Student{ string getStuName() } 执行thrift --gen php ./Student.thrift 在gen-php下有两个文件。 其中Student.php
wilfulness and selfishness of Prince Eigenwillig.
返回主页：
本文网址：http://www.0572pet.cn/view-.html博客分类：
encode
one to one
org.jboss.netty.handler.codec.oneone.OneToOneEncoder
com.alibaba.dubbo.remoting.transport.netty.NettyCodecAdapter.InternalEncoder
org.jboss.netty.handler.codec.base64.Base64Encoder
org.jboss.netty.handler.codec.marshalling.CompatibleMarshallingEncoder
org.jboss.netty.handler.codec.serialization.CompatibleObjectEncoder
org.jboss.netty.handler.codec.http.HttpClientCodec.Encoder
org.jboss.netty.handler.codec.http.HttpMessageEncoder
org.jboss.netty.handler.codec.http.HttpRequestEncoder
org.jboss.netty.handler.codec.http.HttpResponseEncoder
org.jboss.netty.handler.codec.compression.JdkZlibEncoder
org.jboss.netty.handler.codec.frame.LengthFieldPrepender
org.jboss.netty.handler.codec.marshalling.MarshallingEncoder
org.jboss.netty.handler.codec.serialization.ObjectEncoder
org.jboss.netty.handler.codec.oneone.OneToOneStrictEncoder
org.jboss.netty.handler.codec.protobuf.ProtobufEncoder
org.jboss.netty.handler.codec.protobuf.ProtobufVarint32LengthFieldPrepender
org.jboss.resteasy.plugins.server.netty.RestEasyHttpResponseEncoder
org.jboss.netty.handler.codec.rtsp.RtspMessageEncoder
org.jboss.netty.handler.codec.rtsp.RtspRequestEncoder
org.jboss.netty.handler.codec.rtsp.RtspResponseEncoder
org.jboss.netty.handler.codec.socks.SocksMessageEncoder
org.jboss.netty.handler.codec.string.StringEncoder
org.jboss.netty.handler.codec.http.websocketx.WebSocket00FrameEncoder
org.jboss.netty.handler.codec.http.websocketx.WebSocket07FrameEncoder
org.jboss.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder
org.jboss.netty.handler.codec.http.websocketx.WebSocket13FrameEncoder
org.jboss.netty.handler.codec.http.websocket.WebSocketFrameEncoder
org.jboss.netty.handler.codec.compression.ZlibEncoder
codec
com.alibaba.dubbo.remoting.Codec2
com.alibaba.dubbo.remoting.transport.AbstractCodec
com.alibaba.dubbo.remoting.transport.codec.CodecAdapter
com.alibaba.dubbo.rpc.protocol.dubbo.DubboCodec
com.alibaba.dubbo.rpc.protocol.dubbo.DubboCountCodec
com.alibaba.dubbo.remoting.exchange.codec.ExchangeCodec
com.alibaba.dubbo.remoting.telnet.codec.TelnetCodec
com.alibaba.dubbo.rpc.protocol.thrift.ThriftCodec
com.alibaba.dubbo.rpc.protocol.thrift.ThriftNativeCodec
com.alibaba.dubbo.remoting.transport.codec.TransportCodec
com.alibaba.dubbo.remoting.exchange.codec.ExchangeCodec
&16 bytes header&&n bytes body&
头部
&2 bytes magic&&1 byte 消息类型标志 or serialization content-type-id&&1 byte reserved&&8 bytes 消息Id&&4 bytes 消息长度&
魔数
0xdabb
body
&n bytes dubbo version&&n bytes path&&n bytes version&&n bytes method name&&4 bytes -& -1 | 4 bytes argument types length | n bytes argument types&&n bytes arguments&&n bytes attachments&
dubbo version // 2.0.0
&1 byte& -& 128
&1 byte& -& 129
&n bytes dubbo version& // 不记录长度，1&字符串长度&64 并且 其中的每一个字符都在ascii字母表范围中。
&1 byte dubbo version length&&n bytes dubbo version&
&2 byte dubbo version length&&n bytes dubbo version&
&3 byte dubbo version length&&n bytes dubbo version&
&4 byte dubbo version length&&n bytes dubbo version&
&5 byte dubbo version length&&n bytes dubbo version&
path // com.alibaba.dubbo.demo.TestService
version //
argument types //
例如： I, J, F, D, V, [I, [J, [F, [D, [V, Ljava/lang/S, [Ljava/lang/S, Ljava/lang/S[J, ... ...
消息长度
body长度
com.alibaba.dubbo.remoting.exchange.codec.ExchangeCodec
&16 bytes header&&n bytes body&
头部
&2 bytes magic&&1 byte 消息类型标志 or serialization content-type-id&&1 byte reserved&&8 bytes 消息Id&&4 bytes 消息长度&
魔数
0xdabb
body
&n bytes dubbo version&&n bytes path&&n bytes version&&n bytes method name&&4 bytes -& -1 | 4 bytes argument types length | n bytes argument types&&n bytes arguments&&n bytes attachments&
dubbo version // 2.0.0
&1 byte& -& 128
&1 byte& -& 129
&n bytes dubbo version& // 不记录长度，1&字符串长度&64 并且 其中的每一个字符都在ascii字母表范围中。
&1 byte dubbo version length&&n bytes dubbo version&
&2 byte dubbo version length&&n bytes dubbo version&
&3 byte dubbo version length&&n bytes dubbo version&
&4 byte dubbo version length&&n bytes dubbo version&
&5 byte dubbo version length&&n bytes dubbo version&
path // com.alibaba.dubbo.demo.TestService
version //
argument types //
例如： I, J, F, D, V, [I, [J, [F, [D, [V, Ljava/lang/S, [Ljava/lang/S, Ljava/lang/S[J, ... ...
消息长度
body长度
Data length too large: 241, max payload: 8388608, channel: NettyChannel [channel=[id: 0xf777da5d, /192.168.1.10:54085 :& /192.168.1.10:20880]]
消息类型标志
消息类型 FLAG
REQUEST 0x80
TWOWAY 0x40
EVENT 0x20
com.alibaba.dubbo.rpc.protocol.dubbo.DubboCodec
序列化
com.alibaba.dubbo.common.serialize.Serialization
com.alibaba.dubbo.common.serialize.support.kryo.KryoSerialization
META-INF/dubbo/internal/com.alibaba.dubbo.common.serialize.Serialization
dubbo=com.alibaba.dubbo.common.serialize.support.dubbo.DubboSerialization
hessian2=com.alibaba.dubbo.common.serialize.support.hessian.Hessian2Serialization
java=com.alibaba.dubbo.common.serialize.support.java.JavaSerialization
compactedjava=com.alibaba.dubbo.common.serialize.support.java.CompactedJavaSerialization
json=com.alibaba.dubbo.common.serialize.support.json.JsonSerialization
fastjson=com.alibaba.dubbo.common.serialize.support.json.FastJsonSerialization
nativejava=com.alibaba.dubbo.common.serialize.support.nativejava.NativeJavaSerialization
kryo=com.alibaba.dubbo.common.serialize.support.kryo.KryoSerialization
fst=com.alibaba.dubbo.common.serialize.support.fst.FstSerialization
jackson=com.alibaba.dubbo.common.serialize.support.json.JacksonSerialization
Serialization Content-Type
Content-Type Content-Type-Id Serialization
dubbo x-application/dubbo 1 DubboSerialization
hessian2 x-application/hessian2 2 Hessian2Serialization
java x-application/java 3 JavaSerialization
compactedjava x-application/compactedjava 4 CompactedJavaSerialization
json text/json 5 JsonSerialization
fastjson text/json 6 FastJsonSerialization
nativejava x-application/nativejava 7 NativeJavaSerialization
kryo x-application/kryo 8 KryoSerialization
fst x-application/fst 9 FstSerialization
jackson text/json 20 JacksonSerialization
浏览: 68425 次
来自: 上海
(window.slotbydup=window.slotbydup || []).push({
id: '4773203',
container: s,
size: '200,200',
display: 'inlay-fix'}