1 Dubbo出现的背景
随着互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已无法应对,分布式服务架构以及流动计算架构势在必行,亟需一个治理系统确保架构有条不紊的演进。
-
我们传统的网站结构为单一应用架构,也就是把所有的功能都放在一个项目工程里,部署在一台服务器上。
-
当访问量越来越大,我们需要通过不断添加服务器的方式来应对越来越大的访问量,或是将应用拆分成几个不相干的应用部署在不同的服务器上。
-
随着用户数的增加及业务的发展,拆分的应用越来越多,应用之间的交互及数据传输不可避免,则将核心业务抽取出来,作为独立的服务,逐渐形成稳定的服务中心,使前端应用能更快速的响应多变的市场需求。
-
当服务越来越多,容量的评估,小服务资源的浪费等问题逐渐显现,此时需增加一个调度中心基于访问压力实时管理集群容量,提高集群利用率。
2 系统发展进化理论
系统发展经历过两个阶段:
- 集中式系统
就是把所有的程序、功能、模块集中到一个项目中,部署在一台服务器上,从而对外提供服务。 - 分布式系统
分布:在一定范围内分散开
分布式系统就是把所有的程序、功能拆分成不同的子系统,部署在多台不同的服务器上,这些子系统相互协作共同对外提供服务,对于用户而言并不知道后台是如何交互的,使用上和集中式系统一样。
3 认识集群及分布式
-
什么是集群?
就是将相同的程序、功能部署在两台或是多台服务器上,这些服务器对外提供的功能是完全一样的,集群就是通过不同横向扩展增加服务器的方式,以提高服务的能力。 -
什么是分布式?
就是将两个或多个程序、功能分别运行在两台或多台主机服务器上,这些服务对外提供的功能并不一样,它们通过相互协作最终完成某一服务或是功能。
简单来讲:如果两台服务器部署的程序完全一样则是集群,不一样就是分布式;分布式中的每一个节点都可以做成集群,而集群并不一定就是分布式。
4 Dubbo简介
Dubbo是一个分布式、高性能、透明化的RPC服务架构,提供服务自动注册、自动发现等高效服务治理方案。
Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架。
Dubbo官方网站:http://dubbo.io/
5 认识RPC
如果有两台服务器A和B,一个应用部署在A服务器上,一个应用部署在B服务器上,如果A想要调用B应用提供的方法,由于它们不在同一台机器上,也就是它们不在一个JVM内存空间,无法直接调用,需要通过网络进行调用,那么这个调用过程就叫做RPC。
![](https://upload-images.jianshu.io/upload_images/12377037-0c8e09a403664614.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/733/format/webp)
6 Dubbo架构
![](https://upload-images.jianshu.io/upload_images/12377037-1b68e756478505f3.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/827/format/webp)
Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务消费方。
Registry: 服务注册与发现的注册中心。(常见Zookeeper作为注册中心)
Monitor: 统计服务的调用次数和调用时间的监控中心。
- 调用流程
- 服务容器负责启动,加载,运行服务提供者。
- 服务提供者在启动时,向注册中心注册自己提供的服务。
- 服务消费者在启动时,向注册中心订阅自己所需的服务。
- 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
- 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
- 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
7 Dubbo程序开发
项目结构
主要分三大模块:
dubbo-api : 存放公共接口和model;
dubbo-consumer : 调用远程服务;
dubbo-provider : 提供远程服务。(用来具体实现dubbo-api提供的接口)
![](https://upload-images.jianshu.io/upload_images/12377037-0885ba8ef3cf24a3.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/466/format/webp)
-
DubboDemo中pom.xml文件
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>DubboDemo</groupId> <artifactId>DubboDemo</artifactId> <packaging>pom</packaging> <version>1.0-SNAPSHOT</version> <modules> <module>dubbo-api</module> <module>dubbo-consumer</module> <module>dubbo-provider</module> </modules> <dependencies> <dependency> <groupId>DubboDemo</groupId> <artifactId>dubbo-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.10</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> <exclusions> <exclusion> <groupId>org.springframework</groupId> <artifactId>spring</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.10</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>4.2.5.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>4.2.5.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>4.2.5.RELEASE</version> </dependency> </dependencies> </project>
dubbo-api开发
- API层开发Person接口
package com.hanyue.dubbo.api;
public interface Person { public String sayHello(String name); public String working(String work); }
dubbo-provider开发
- 服务提供者需要使用到接口层代码,所以父级pom文件中已经将相关依赖jar包添加进去;
- 开发接口层代码所定义的接口具体实现;
- 配置接口为dubbo服务,将能提供的接口(服务)对外暴露出去,以便让别人能调用;
- Person接口实现类PersonImpl开发
package com.hanyue.dubbo.provider;
import com.hanyue.dubbo.api.Person;
public class PersonImpl implements Person { public String sayHello(String name){ return "hello,"+name; } public String working(String work) { return "我的工作是:"+work; } }
- resources下applicationContext.xml配置文件
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!-- 配置服务应用名称 --> <dubbo:application name="dubbo-provider"/> <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/> <!--spring配置具体实现类--> <bean id="personimpl" class="com.hanyue.dubbo.provider.PersonImpl"/> <!--配置一个dubbo服务,将服务暴露出去--> <dubbo:service interface="com.hanyue.dubbo.api.Person" ref="personimpl"/> </beans>
- provider 简单测试
provider工程目录下新建Main类
package com.hanyue.dubbo.main;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
public class Main { public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml"); System.in.read(); } }
dubbo-consumer开发
- 配置dubbo服务引用,引用远程服务者提供的服务
- applicationContext.xml配置文件
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!-- 配置服务应用名称 --> <dubbo:application name="dubbo-consumer"/> <!--配置服务引用,引用远程服务,通过接口去引用--> <dubbo:reference id="person" interface="com.hanyue.dubbo.api.Person"/> <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/> </beans>
- consumer简单测试
请求Zookeeper进行服务端资源访问
package com.hanyue.dubbo.main;
import com.hanyue.dubbo.api.Person;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainConsumer { public static void main(String[] args) { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml"); Person person = (Person)context.getBean("person"); String hi = person.sayHello("旺旺"); System.out.println(hi); String work = person.working("测试"); System.out.println(work); } }
8 Dubbo-admin管理工具
![](https://upload-images.jianshu.io/upload_images/12377037-c9a88b2e16dcfb20.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1000/format/webp)
![](https://upload-images.jianshu.io/upload_images/12377037-1bd2f963041c5b65.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1000/format/webp)
9 Dubbo集群实现负载均衡
![](https://upload-images.jianshu.io/upload_images/12377037-16ba080b16b17062.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1000/format/webp)