2017酷站推荐网站软件开发过程五个步骤

2017酷站推荐网站,软件开发过程五个步骤,深圳正规seo,怎样做编辑发到网站深入 Remoting#xff1a;Dubbo 的“搬运工” —— 网络通信与线程模型 请关注公众号【碳硅化合物AI】 摘要 如果说 RPC 是 Dubbo 的大脑#xff0c;那么 Remoting 就是 Dubbo 的四肢。它负责把 RPC 层生成的调用请求#xff08;Invocation#xff09;变成二进制流…深入 RemotingDubbo 的“搬运工” —— 网络通信与线程模型请关注公众号【碳硅化合物AI】摘要如果说 RPC 是 Dubbo 的大脑那么 Remoting 就是 Dubbo 的四肢。它负责把 RPC 层生成的调用请求Invocation变成二进制流Byte Stream并通过网络搬运到地球的另一端。本篇将带你钻进下水道……啊不钻进底层看看 Netty、Mina 是如何被封装成统一的Transporter以及那些至关重要的 IO 线程和业务线程是如何协作的。1. 核心角色网络通信的基石Remoting 层位于dubbo-remoting模块它屏蔽了底层网络框架的差异向上层提供统一的接口。Transporter: 传输层接口。负责创建Server服务端和Client客户端。publicinterfaceTransporter{RemotingServerbind(URLurl,ChannelHandlerhandler);Clientconnect(URLurl,ChannelHandlerhandler);}这也是个 SPI 接口默认实现是NettyTransporter基于 Netty 4。Channel: 通道。代表一个网络连接可以发送和接收消息。ChannelHandler: 处理器。负责处理网络事件连接建立connected、断开disconnected、发送消息sent、接收消息received、异常caught。这和 Netty 的 Handler 概念是一致的。Exchanger: 信息交换层。它在 Transporter 之上包了一层把底层的单向消息Message变成了请求-响应模型Request-Response。底层只知道发了一个包收了一个包。Exchanger 知道发了一个 Request A收到了 Response A。核心类关系图 (PlantUML)2. 线程模型生死攸关的 DispatcherDubbo 的高性能很大程度上归功于其精细的线程模型。Netty 的 IO 线程NioEventLoop负责收发包但是千万不能在 IO 线程里执行耗时的业务逻辑否则会阻塞整个 IO 循环导致吞吐量暴跌。Dubbo 通过Dispatcher接口来决定消息派发到哪个线程池去处理publicinterfaceDispatcher{ChannelHandlerdispatch(ChannelHandlerhandler,URLurl);}五种派发策略 (Dispatcher)策略名关键词行为描述适用场景all(默认)全都派发连接、断开、请求、响应所有消息都扔给业务线程池ThreadPool。大多数场景避免 IO 线程阻塞。direct直接执行所有消息都在 IO 线程上直接执行。只有当业务逻辑极快如只在内存操作时使用否则会卡死 IO。message仅消息只有请求响应消息扔给业务线程池连接断开事件在 IO 线程执行。适合心跳检测频繁的场景。execution仅请求只有请求消息扔给业务线程池响应消息Consumer端在 IO 线程执行。适合 Consumer 端处理 Response 比较快。connection连接有序类似 message但连接断开事件排队串行执行。极少使用。配置方式:dubbo:protocol dispatcherall threadpoolfixed threads200 /3. 请求-响应模型如何把异步变同步底层的 TCP 是全双工的我发一个包不知道什么时候回包。Dubbo 如何让用户感觉像是同步调用方法答案DefaultFuture发送时: Consumer 生成一个唯一的Request ID创建一个DefaultFuture对象把它存到一个全局 Map 中 (MapID, Future)然后阻塞等待future.get()。传输: Request 包带着 ID 飞到了 ProviderProvider 处理完生成的 Response 包也带着这个 ID 飞回来。接收时: Consumer 收到 Response提取 ID去 Map 里找到对应的DefaultFuture把结果填进去future.complete(result)。唤醒:future.get()被唤醒拿到结果方法返回。消息接收处理时序图 (PlantUML)4. 编解码Netty 的魔法Dubbo 使用 Netty 的ByteToMessageDecoder和MessageToByteEncoder进行协议包的拆解和组装。一个典型的 Dubbo 协议头16字节Magic:0xdabb(魔数识别是不是 Dubbo 包)Flag: 请求/响应双向/单向心跳序列化类型Status: 响应状态OK, ERROR…ID: 8字节请求 IDLength: Body 长度这种设计解决了 TCP 的粘包/拆包问题。总结Remoting 层是 Dubbo 的基石它不仅封装了 Netty 的复杂性还通过精妙的线程模型Dispatcher平衡了 IO 吞吐量和业务处理能力并通过 Future 模式实现了异步转同步的魔法。下一篇我们将进入 Dubbo 的服务治理中心 ——Registry Configuration看看服务是如何注册、发现和被配置管理的。