`
lobin
  • 浏览: 427418 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论
阅读更多
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/String;, [Ljava/lang/String;, Ljava/lang/String;[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/String;, [Ljava/lang/String;, Ljava/lang/String;[J, ... ...

消息长度
body长度




payload

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 1000 0000
TWOWAY 0x40 0100 0000
EVENT 0x20 0010 0000




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


Java序列化机制实现:参考https://lobin.iteye.com/blog/629414序列化章节。


0
0
分享到:
评论

相关推荐

    nodejs使用原生的dubbo协议打通了dubbo的rpc方法调用.

    标题中的“nodejs使用原生的dubbo协议打通了dubbo的rpc方法调用”意味着在Node.js环境中,开发者成功地实现了对Dubbo服务的RPC(远程过程调用)访问,利用了Dubbo协议的特性。Dubbo是阿里巴巴开源的一个高性能、轻量...

    dubbo协议、netty框架总结

    Dubbo协议和Netty框架是构建高性能分布式服务的关键技术,它们在现代企业级应用中扮演着重要角色。Dubbo协议是Dubbo服务框架的核心部分,主要用于实现服务提供者与消费者之间的高效通信。它采用请求-响应模式,支持...

    第六课:Dubbo协议模块源码解析1

    【Dubbo协议模块源码解析1】这节课主要讲解了RPC协议的基本组成和Dubbo框架中支持的多种RPC协议的实现细节。RPC(Remote Procedure Call)协议是分布式系统中实现远程方法调用的关键技术,它定义了服务提供者和服务...

    第五课:Dubbo协议模块源码剖析1

    【Dubbo协议模块源码剖析1】这节课主要讲解了RPC协议的基本组成和Dubbo框架中支持的多种RPC协议的实现细节。RPC(Remote Procedure Call)协议是分布式系统中实现远程方法调用的关键技术,它涉及到服务发现、负载...

    6.Dubbo协议模块源码剖析.zip.002

    6.Dubbo协议模块源码剖析.zip.002

    6.Dubbo协议模块源码剖析.zip.001

    6.Dubbo协议模块源码剖析.zip.001

    接口自动化测试框架——python版,支持HTTP,dubbo协议接口

    本项目是一个基于Python实现的接口自动化测试框架,它支持HTTP和Dubbo两种常见的接口协议,使得测试人员能够更加高效地进行接口验证工作。 首先,让我们详细了解一下HTTP接口测试。HTTP(超文本传输协议)是互联网...

    Dubbo 序列化协议 5 连问,你接得住不.PDF

    默认就是⾛ dubbo 协议,单⼀⻓连接,进⾏的是 NIO 异步通信,基于 hessian 作为序列化协议。使⽤的场景是:传输数据量⼩ (每次请求在 100kb 以内),但是并发量很⾼。 为了要⽀持⾼并发场景,⼀般是服务提供者就⼏...

    dubbo示例代码dubbo-sample

    在`dubbo.properties`配置文件中,可以设置服务使用的通信协议,例如默认的dubbo协议。不同的协议会影响服务调用的性能和特性。 5. **负载均衡(Load Balance)** Dubbo内置了几种负载均衡策略,如随机、轮询、...

    Dubbo Dubbo

    由于Dubbo将这些协议的实现进行了封装了,无论是服务端(开发服务)还是客户端(调用服务),都不需要关心协议的细节,只需要在配置中指定使用的协议即可,从而保证了服务提供方与服务消费方之间的透明。 另外,如果...

    incubator-dubbo-dubbo-2.6.1

    3. **协议支持**:Dubbo支持多种通信协议,如基于HTTP的RESTful协议、基于TCP的Dubbo协议、基于RMI的Hessian和 Burlap协议等,可以根据实际需求选择。 4. **负载均衡**:Dubbo内置了多种负载均衡策略,如随机、轮询...

    dubbodubbo.zip

    5. **协议(Protocol)**:Dubbo支持多种通信协议,如Dubbo协议、RMI、HTTP、Hessian等,用于传输服务调用的请求和响应。 6. **集群(Cluster)**:集群负责将多个服务提供者的实例聚合为一个逻辑服务,提供了负载...

    Jmeter-dubbo-2.7.7.jar

    软件描述:Dubbo的Jmeter平台插件,用来拓展Jmeter功能,使之支持Dubbo协议接口。使用前,需将下载的jar包放在Jmeter的lib/ext目录下,完成后打开Jmeter在取样器中看到Dubbo Sample,即为生效。

    springcloud同时整合dubbo与openfeign

    案例代码为springcloud-libaba整合dubbo同时也整合了openfeign,消费方可以通过两种方式调用服务提供方的接口,代码下载后简单修改下数据库链接可以直接运行起来,如果运行时有任何问题可以私信我;

    dubbox打包编译2.8.4版本jar及dubbo-admin2.8.4.war

    provider里只有dubbo协议就是dubbo,包含rest协议,同时service接口直接可以浏览器等rest访问就是dubbox,不再需要controller写requestmapping路径转发,详见事例:https://git.oschina.net/feiyangziyun/dubbox ...

    node-connect-dubbo-test:Node.js通过Dubbo协议连接到Java服务器

    node 采用 dubbo 协议连接 dubbo 服务端. 基本步骤 java 启动服务端, 在 zookeeper 注册 node 连接 zookeeper, 获取已经注册的服务, 获取需要的服务端的信息 node 发起 dubbo 协议的 tcp 连接, 获取调用结果, 完成 ...

    Apache Dubbo 3.0 教程.pdf

    Dubbo 3.0 是 Dubbo 框架的最新版本,相比之前的版本,Dubbo 3.0 提供了许多新的特性和改进,例如增强的服务治理能力、改进的性能、支持更多的协议等。Dubbo 3.0 也提供了更好的可扩展性和灵活性,使得开发者可以更...

    dubbo 对外提供和使用接口方法

    #### 四、Dubbo协议选择及配置 Dubbo支持多种通信协议,包括`dubbo`、`rest`、`hessian`、`http`等,每种协议都有其适用场景。 **1. dubbo协议** - **特点**:专为Dubbo设计,性能最优。 - **配置示例**: ```...

    dubbo-dubbo-2.7.2源码

    Dubbo协议是默认的高性能二进制协议,它实现了高效的序列化和反序列化,降低了网络传输开销。 五、服务接口与实现 服务接口定义了服务的契约,通常是一个Java接口,服务提供者实现这个接口并暴露服务,服务消费者...

    incubator-dubbo-dubbo-2.5.8

    3. **协议支持**:Dubbo支持多种通信协议,如Dubbo协议、HTTP/HTTPS、Hessian、RMI等,以适应不同的网络环境和性能需求。 4. **Zookeeper集成**:Dubbo常与Zookeeper结合使用,作为服务注册中心,实现服务的动态注册...

Global site tag (gtag.js) - Google Analytics