本章是整理知识内容,为强化知识长期更新。
Dubbo概述
- 服务治理(SOA)治理框架
- Duboo是一个分布式服务框架
- 远程通讯:提供多种基于长链接的NIO框架抽象封装,包括多种线程模型、序列化“请求-响应”的信息交换方案。
- 集群容错:提供基于接口方法的透明远程调用过程,包括多协议支持、软负载均衡、失败容错、地址路由、动态配置等集群支持。
- 自动发现:基于注册中心目录服务,使服务消费方能动态地查找提供方,使地址透明,使服务提供方可以平滑增或减少机器。
- 介绍:
- 致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。
- Dubbo的命名:澳大利亚达博市
- 同类型框架:
- Apache Thrift、Hessian、RMI、WebService(原生)、HSF(淘宝,不开源)、JSF(京东,不开源)。
- Dubbo涉及的基础知识
- 远程调用方面:RMI、Hassion、WebService、Thrift进行底层调用。
- 通讯交互:HTTP、Mian、netty。
- 序列化:Hession2、Java、Json。
- 容器:Jetty、Spring。
- 负载均衡:zookeeper、Redis。(大部分都是zookeeper)
- 简单的使用场景
- 作为对内提供服务应用的容器。
- 拆分负载Web应用到服务容器。
- 应用负载均和协调。
- 引用服务处理。
架构节点(抽象概念)
- Provider:暴露服务的服务提供方。
- Consumer:调用远程服务的服务消费方。
- Registry:服务注册于发现服务
- Monitor:统计服务的调用次调用时间监控中心
- Container:服务运行容器
- 节点调用关系
- 服务提供-服务提供者在启动的时候,向注册中心提供自己提供的服务。
- 服务消费-服务消费者在启动的时候,向注册中心订阅自己所需要的服务。
- 注册中心异步返回服务提供者地址列表给消费者,如果有变动,注册中心将给予长连接推送变更数据给消费者。
- 服务统计-服务者和消费者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
- 异步方式
- 服务调用关系
- 服务消费者,从提供者地址列表中,基于[软负载均衡算法],选一台提供者进行调用,如果调用失败,在选另一台调用。
Dubbo源码相关
源码地址
git clone https://github.com/alibaba/dubbo
初次编码不执行Test
mvn clean install -Dmaven.test.skip=true
JS错误不修改,请自行忽视。
修复mavan的警告
* 地址:dubbo-parent pom.xml
* maven-jar-plugin version:2.4
* maven-surefire-plugin Version 2.19.1
* maven-deploy-plugin Version 3.3.9项目导入后修复Dubbo XML校验错误提示
需要导入dubbo.xsd文件
下载dubbo-2.5.3.jar 版本尽量保持源码同步,解压dt后导入eclipse中。
Preferences-XML-XML Catalog 添加一个自定义的:
- Location: D:\xsd\dubbo.xsd
- Key: http://code.alibabatech.com/schema/dubbo/dubbo.xsd (默认生成的不行自行修改)。
- 在校验错误的XML头部添加:
1
关于maven-dependency-plugin错误 可能是IDE错误提示,空白处添加空格保存自动消失。
错误信息如下:Artifact has not been packaged yet. When used on reactor artifact, unpack should be executed after packaging: see MDEP-98. (org.apache.maven.plugins:maven-dependency-plugin:2.8:unpack:unpack:package)
- 修复方案更改插件配置:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
<version>2.10</version>
<executions>
<execution>
<id>unpack</id>
<phase>packaged</phase>
<goals>
<goal>unpack</goal>
</goals>
</execution>
</executions>
</plugin>
Dubbo源码模块
- Config配置层(Dubbo-config)
- Proxy服务代理层(Dubbo-rpc)
- Registry注册中心层(Dubbo-registry)
- Cluster路由层(Dubbo-cluster)
- Monitor监控层(Dubbo-monitor)
- Protocol远程调用层(Dubbo-rpc)
- Exchange信息交换层(Dubbo-remoting)
- Transport网络传输层(Dubbo-remoting)
- Serialize数据序列化层(Dubbo-common)
Zookeeper
(测试方案采用zookeeper做均衡负载,简单介绍下配置信息)
- 下载地址 http://apache.fayea.com/zookeeper/zookeeper-3.4.8/zookeeper-3.4.8.tar.gz
- 基本配置:
- 单机模式:修改zookeeper-3.4.8/conf zoo.cfg(原始文件名zoo_sanple.cfg复制一份重命名)
- 编辑内容(仅供参考,具体环境自行修改)
- tickTime = 2000
- tickTime:基本事件单元,以毫秒为单位。这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔,也就是每个 tickTime 时间就会发送一个心跳。
- initLimit= 5
- initLimit:这个配置项用来配置Zookeeper接受客户端初始化连接时最长能忍受多少个心跳时间间隔数,当已超过5个心跳的时间(也就是tickTime)长度后Zookeeper服务器还没有收到客户端的返回信息,那么表明这个客户端连接失败。总的时间长度是5 * 2000=4s。
- dataDir = D:\zookeeper\data
- 顾名思义就是 Zookeeper 保存数据快照的目录,默认情况下,Zookeeper 将写数据的日志文件也保存在这个目录里)。
- dataLogDir= D:\zookeeper\log
- 顾名思义就是 Zookeeper 保存日志的目录。
- synclimit = 5
- 这个配置项表示Leader与Follower之间发送消息,请求和应答时间长长度,最长不能超过多少个tickTime的时间长度,总的时间长度是2 * 2000 = 4s。
- clientPort = 2181
- 这个端口就是客户端连接 Zookeeper 服务器的端口,Zookeeper 会监听这个端口,接受客户端的访问请求。
- Server(待续)
- 格式:server.id=host:port:port(两个port保证可以正常使用就行)
- id:通常为整数,建议使用整数。
- host:服务器的IP地址。
- port: Follower端口
- port: Leader选举投票。
- ZooKeeper建议使用hostname,而非ip。这需要对主机的/etc/hostname和/etc/hosts做host绑定(不用的OS不同修改方式)。
- 格式:server.id=host:port:port(两个port保证可以正常使用就行)
- 创建一个myid文件(放在 dataDir文件下面)
- 写入一行数据(请查阅zoo.cfg文件)
- 写入当前Zookeeper id位置的数据即可。表示当前系统环境Zookeeper是哪一个Server(通讯用的)。
- 写入一行数据(请查阅zoo.cfg文件)
- 单机模式:修改zookeeper-3.4.8/conf zoo.cfg(原始文件名zoo_sanple.cfg复制一份重命名)
Dubbo程序运行
- 测试运行,默认配置即可。注意与zookeeper一台机器。
- 运行Dubbo-admin本机tomcat启动启动成功后127.0.0.1:8080/dubbo-admin(注意默认请设置跟目录,否则部分功能不发正常显示)
- 默认用户名密码(root/root,guest/guest)