Dubbox实践笔记
sunnyzuo
8年前
<h2><strong>简介</strong></h2> <h3><strong>SOA（面向服务体系结构）PRC(远程过程调用)</strong></h3> <p>面向服务的体系结构，将应用程序的不同功能单元（称为服务）通过这些服务之间定义良好的接口和契约联系起来。</p> <p>服务消费者（service consumer）可以通过发送消息来调用服务，这些消息由一个服务总线（service bus）转换后发送给适当的服务实现。</p> <p style="text-align: center;"><img src="https://simg.open-open.com/show/862ebec7d3ff90824e5dab65eb739547.png"></p> <p>Dubbo框架设计一共划分了10个层，最上面的Service层是留给实际想要使用Dubbo开发分布式服务的开发者实现业务逻辑的接口层，图中左边淡蓝背景的为服务消费方使用的接口，右边淡绿色背景为服务提供方使用的接口，位于中轴线上的为双方都用到的接口</p> <ol> <li>服务接口层（Service）：该层是与实际业务逻辑相关的，根据服务提供方和服务消费方的业务设计对应的接口和实现。</li> <li>配置层（Config）：对外配置接口，以ServiceConfig和ReferenceConfig为中心，可以直接new配置类，也可以通过spring解析配置生成配置类</li> <li>服务代理层（Proxy）：服务接口透明代理，生成服务的客户端Stub和服务器端Skeleton，以ServiceProxy为中心，扩展接口为ProxyFactory</li> <li>服务注册层（Registry)：封装服务地址的注册与发现，以服务URL为中心，扩展接口为RegistryFactory,Registry和RegistryService，可能没有服务注册中心，此时服务提供方直接暴露服务</li> <li>集群层（Cluster)：封装多个提供者的路由及负载均衡，并桥接注册中心，以Invoker为中心，扩展接口为Cluster,Directory,Router和LoadBalance。将多个服务提供方组合为一个服务提供方，实现对服务消费方来透明，只需要与一个服务提供方进行交互。</li> <li>监控层（Monitor）：RPC调用次数和调用时间监控，以Statistics为中心，扩展接口为MonitorFactory，Monitor和MonitorService。</li> <li>远程调用层（Protocol)：封装RPC调用，封将RPC调用，以Invocation和Result为中心，扩展接口为Protocol、Invoker和Exporter。Protocol是服务域，它是Invoker暴露和引用的主功能入口，它负责Invoker的生命周期管理。Invoker是实体域，它是Dubbo的核心模型，其它模型都向它靠扰，或转换成它，它代表一个可执行体，可向它发起invoke调用，它有可能是一个本地的实现，也可能是一个远程的实现，也可能一个集群实现。</li> <li>信息交换层（Exchange)：封装请求响应模式，同步转异步，以Request和Response为中心，扩展接口为Exchanger，xchangeChannel，ExchangeClient和ExchangeServer。</li> <li>网络传输层（Transport)：抽象mina和netty为统一接口，以Message为中心，扩展接口为 Channel,Transproter,Client,Server和Codec。</li> <li>数据序列化层（Serialize)：可复用的一些工具，扩展接口为 Serialization,ObjectInput,ObjectOutput和ThreadPool。</li> </ol> <p><strong>服务调用</strong></p> <p style="text-align: center;"><img src="https://simg.open-open.com/show/9290ae5ed8edfda730f797dd450afa94.png"></p> <p>上图中，蓝色的表示与业务有交互，绿色的表示只对Dubbo内部交互。上述图所描述的调用流程如下：</p> <ol> <li> <p>服务提供方发布服务到服务注册中心；</p> </li> <li> <p>服务消费方从服务注册中心订阅服务；</p> </li> <li> <p>服务消费方调用已经注册的可用服务；</p> </li> </ol> <p style="text-align: center;"><img src="https://simg.open-open.com/show/268c872f303beee1fe81ac89bb0aa927.png"></p> <p>注册/注销服务</p> <p>服务的注册与注销，是对服务提供方角色而言，那么注册服务与注销服务的时序图，如图所示：</p> <p style="text-align: center;"><img src="https://simg.open-open.com/show/f1d8bf605dab2af59e7326749de8131a.png"></p> <p>服务订阅/取消</p> <p>为了满足应用系统的需求，服务消费方的可能需要从服务注册中心订阅指定的有服务提供方发布的服务，在得到通知可以使用服务时，就可以直接调用服务。反过来，如果不需要某一个服务了，可以取消该服务。下面看一下对应的时序图，如图所示：</p> <p style="text-align: center;"><img src="https://simg.open-open.com/show/2334e08f3d48eaeb82a05a6a597575c4.png"></p> <p>Dubbo以包结构来组织各个模块，各个模块及其关系，如图所示：</p> <p style="text-align: center;"><img src="https://simg.open-open.com/show/c9c7881111c6228d45a0567038bce246.png"></p> <p>可以通过Dubbo的代码（使用Maven管理）组织，与上面的模块进行比较。简单说明各个包的情况：</p> <ul> <li> <p><strong>dubbo-common 公共逻辑模块，包括Util类和通用模型。</strong></p> </li> <li> <p>dubbo-remoting 远程通讯模块，相当于Dubbo协议的实现，如果RPC用RMI协议则不需要使用此包。</p> </li> <li> <p>dubbo-rpc 远程调用模块，抽象各种协议，以及动态代理，只包含一对一的调用，不关心集群的管理。</p> </li> <li> <p>dubbo-cluster 集群模块，将多个服务提供方伪装为一个提供方，包括：负载均衡、容错、路由等，集群的地址列表可以是静态配置的，也可以是由注册中心下发。</p> </li> <li> <p>dubbo-registry 注册中心模块，基于注册中心下发地址的集群方式，以及对各种注册中心的抽象。</p> </li> <li> <p>dubbo-monitor 监控模块，统计服务调用次数，调用时间的，调用链跟踪的服务。</p> </li> <li> <p>dubbo-config 配置模块，是Dubbo对外的API，用户通过Config使用Dubbo，隐藏Dubbo所有细节。</p> </li> <li> <p>dubbo-container 容器模块，是一个Standalone的容器，以简单的Main加载Spring启动，因为服务通常不需要Tomcat/JBoss等Web容器的特性，没必要用Web容器去加载服务。</p> </li> </ul> <h2><strong>dubbox</strong></h2> <ul> <li> <p>支持REST风格远程调用（HTTP + JSON/XML)：基于非常成熟的JBoss RestEasy框架，在dubbo中实现了REST风格（HTTP + JSON/XML）的远程调用，以显著简化企业内部的跨语言交互，同时显著简化企业对外的Open API、无线API甚至AJAX服务端等等的开发。事实上，这个REST调用也使得Dubbo可以对当今特别流行的“微服务”架构提供基础性支持。 另外，REST调用也达到了比较高的性能，在基准测试下，HTTP + JSON与Dubbo 2.x默认的RPC协议（即TCP + Hessian2二进制序列化）之间只有1.5倍左右的差距，详见文档中的基准测试报告。</p> </li> <li> <p>支持基于Kryo和FST的Java高效序列化实现：基于当今比较知名的Kryo和FST高性能序列化库，为Dubbo默认的RPC协议添加新的序列化实现，并优化调整了其序列化体系，比较显著的提高了Dubbo RPC的性能，详见文档中的基准测试报告。</p> </li> <li> <p>支持基于Jackson的JSON序列化：基于业界应用最广泛的Jackson序列化库，为Dubbo默认的RPC协议添加新的JSON序列化实现。</p> </li> <li> <p>支持基于嵌入式Tomcat的HTTP remoting体系：基于嵌入式tomcat实现dubbo的HTTP remoting体系（即dubbo-remoting-http），用以逐步取代Dubbo中旧版本的嵌入式Jetty，可以显著的提高REST等的远程调用性能，并将Servlet API的支持从2.5升级到3.1。（注：除了REST，dubbo中的WebServices、Hessian、HTTP Invoker等协议都基于这个HTTP remoting体系）。</p> </li> <li> <p>升级Spring：将dubbo中Spring由2.x升级到目前最常用的3.x版本，减少版本冲突带来的麻烦。</p> </li> <li> <p>升级ZooKeeper客户端：将dubbo中的zookeeper客户端升级到最新的版本，以修正老版本中包含的bug。</p> </li> <li> <p>支持完全基于Java代码的Dubbo配置：基于Spring的Java Config，实现完全无XML的纯Java代码方式来配置dubbo</p> </li> <li> <p>调整Demo应用：暂时将dubbo的demo应用调整并改写以主要演示REST功能、Dubbo协议的新序列化方式、基于Java代码的Spring配置等等。</p> </li> <li> <p>修正了dubbo的bug 包括配置、序列化、管理界面等等的bug。</p> </li> </ul> <h2><strong>dubbo</strong></h2> <p>api项目</p> <p>pom.xml</p> <p>SerializationOptimizerImpl.java</p> <p>User.java</p> <p>UserRestService.java</p> <p>UserService.java</p> <p>provider项目</p> <p>pom.xml</p> <p>UserRestServiceImpl.java</p> <p>UserServiceImpl.java</p> <p>dubbo-demo-provider.xml</p> <p>consumer项目</p> <p>pom.xml</p> <p>DemoConsumer.java</p> <p>dubbo-hello-consumer.xml</p> <h3><strong>框架整合</strong></h3> <p>Springmvc + Mybatis + Shiro（权限） + REST(服务) + WebService(服务) + JMS(消息) + Lucene(搜搜引擎) + Quartz(定时调度) + Bootstrap Html5（支持PC、IOS、Android）</p> <h2><strong>安装</strong></h2> <ul> <li> <p>git clone https://github.com/dangdangdotcom/dubbox</p> </li> <li> <p>在checkout出来的dubbox目录执行 mvn install -Dmaven.test.skip=true 编译一下dubbo</p> </li> <li> <p>在dubbox/dubbo/target/下 分别运行 mvn install:install-file -DgroupId=com.alibaba -DartifactId=dubbo-remoting-grizzly -Dversion=2.8.4 -Dpackaging=jar -Dfile=./dubbo-2.8.4.jar mvn install:install-file -DgroupId=com.alibaba -DartifactId=dubbo-remoting-grizzly -Dversion=2.8.4 -Dpackaging=jar -Dfile=./dubbo-2.8.4-sources.jar mvn install:install-file -DgroupId=com.alibaba -DartifactId=dubbo-remoting-grizzly -Dversion=2.8.4 -Dpackaging=jar -Dfile=./original-dubbo-2.8.4.jar</p> </li> <li> <p>在checkout出来的dubbox根目录执行 mvn idea:idea 或者 mvn eclipse:eclipse 创建IDE工程文件</p> </li> <li> <p>将项目导入IDE</p> </li> <li> <p>下载解压zookeeper,编辑其conf/zoo.cfg 后启动zookeeper用作dubbo注册中心：启动/停止/重启命令 bin/zkServer.sh start/stop/restart 启动客户端，创建，查询节点 bin/zkCli.sh -server localhost:2128</p> </li> <li> <p>用IDE运行/dubbo-demo/dubbo-demo-provider/.../test目录下的DemoProvider启动dubbo服务端，目前他会分别启动dubbo协议（包括用kryo和FST序列化）和REST协议的服务</p> </li> <li> <p>用IDE运行/dubbo-demo/dubbo-demo-consumer/.../test目录下的DemoConsumer来启动dubbo客户端调用上面的服务端，直接看console的输出即可</p> </li> <li> <p>用IDE运行/dubbo-demo/dubbo-demo-consumer/.../test目录下的RestClient来启动rest客户端（模拟非dubbo的rest客户端）调用上面的服务端，直接看console的输出即可</p> </li> </ul> <h3><strong>dubbo-admin部署</strong></h3> <p>用户名root 密码 root</p> <h3><strong>dubbo-monitor-simple部署</strong></h3> <p>打包后，目录dubbo-simple/dubbo-monitor-simple/target中会生成dubbo-monitor-simple-xxx-assembly.tar.gz 用tar -zxvf *.gz解压，解压后有三个子目录bin, conf , lib ,</p> <p>配置文件</p> <pre> dubbo.container=log4j,spring,registry,jetty dubbo.application.name=simple-monitor dubbo.application.owner= #dubbo.registry.address=multicast://224.5.6.7:1234 dubbo.registry.address=zookeeper://127.0.0.1:2181 #dubbo.registry.address=redis://127.0.0.1:6379 #dubbo.registry.address=dubbo://127.0.0.1:9090 dubbo.protocol.port=7070 dubbo.jetty.port=8180 dubbo.jetty.directory=${user.home}/monitor dubbo.charts.directory=${dubbo.jetty.directory}/charts dubbo.statistics.directory=${user.home}/monitor/statistics dubbo.log4j.file=logs/dubbo-monitor-simple.log dubbo.log4j.level=WARN</pre> <p>启动： bin/start.sh</p> <h2><strong>项目介绍</strong></h2> <ul> <li>aubbo-demo-api(服务接口传输对象)</li> <li>dubbo-demo-provider(服务生产者)</li> <li>duboo-demo-consumer(服务消费方)</li> <li>dubbo-admin(dubbo的后台管理，其配置文件在webapp\WEB-INF\底下，名为dubbo.properties)</li> <li>dubbo-monitor(性能监控)</li> </ul> <h2><strong>参考资料</strong></h2> <p><a href="/misc/goto?guid=4959724576923455559" rel="nofollow,noindex">dubbox入门</a></p> <p><a href="/misc/goto?guid=4959724577015322591" rel="nofollow,noindex">ZooKeeper高可用集群安装和配置</a></p> <p><a href="/misc/goto?guid=4959724577086829879" rel="nofollow,noindex">dubbox入门实例</a></p> <p><a href="/misc/goto?guid=4959724577171417918" rel="nofollow,noindex">dubbox监管</a></p> <p><a href="/misc/goto?guid=4959724577256385692" rel="nofollow,noindex">dubbo架构设计详解</a></p> <p><a href="/misc/goto?guid=4959724577339040573" rel="nofollow,noindex">dubbox实现</a></p> <p> </p> <p> </p> <p>来自：http://www.jianshu.com/p/39dbdacf3747</p> <p> </p>