Dubbo[]是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。html
其核心部分包含:前端
随着互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已没法应对,分布式服务架构以及流动计算架构势在必行,亟需一个治理系统确保架构有条不紊的演进。
java
在大规模服务化以前,应用可能只是经过RMI或Hessian等工具,简单的暴露和引用远程服务,经过配置服务的URL地址进行调用,经过F5等硬件进行负载均衡。git
(1) 当服务愈来愈多时,服务URL配置管理变得很是困难,F5硬件负载均衡器的单点压力也愈来愈大。github
此时须要一个服务注册中心,动态的注册和发现服务,使服务的位置透明。算法
并经过在消费方获取服务提供方地址列表,实现软负载均衡和Failover,下降对F5硬件负载均衡器的依赖,也能减小部分红本。spring
(2) 当进一步发展,服务间依赖关系变得错踪复杂,甚至分不清哪一个应用要在哪一个应用以前启动,架构师都不能完整的描述应用的架构关系。api
这时,须要自动画出应用间的依赖关系图,以帮助架构师理清理关系。服务器
(3) 接着,服务的调用量愈来愈大,服务的容量问题就暴露出来,这个服务须要多少机器支撑?何时该加机器?网络
为了解决这些问题,第一步,要将服务如今天天的调用量,响应时间,都统计出来,做为容量规划的参考指标。
其次,要能够动态调整权重,在线上,将某台机器的权重一直加大,并在加大的过程当中记录响应时间的变化,直到响应时间到达阀值,记录此时的访问量,再以此访问量乘以机器数反推总容量。
以上是Dubbo最基本的几个需求,更多服务治理问题参见:
http://code.alibabatech.com/blog/experience_1402/service-governance-process.html
架构
节点角色说明:
调用关系说明:
整体架构
图例说明:
Dubbo框架设计一共划分了10个层,官方文档对各层说明:
Dubbo采用全spring配置方式,透明化接入应用,对应用没有任何API侵入,只需用Spring加载Dubbo的配置便可。下面以官网给出的DemoService做为示例,教你们一步步使用Dubbo实现本身的分布式服务。
官网文档介绍:http://dubbo.io/User+Guide-zh.htm#UserGuide-zh-%E5%BF%AB%E9%80%9F%E5%90%AF%E5%8A%A8
开发环境
1.定义服务接口
package com.ricky.dubbo.api; import com.ricky.dubbo.api.model.User; public interface DemoService { public String sayHello(String name); public User findUserById(long id); }
User.Java
package com.ricky.dubbo.api.model; import java.io.Serializable; public class User implements Serializable { private static final long serialVersionUID = 1L; private long id; private String name; private int age; public long getId() { return id; } public void setId(long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } @Override public String toString() { return "User [id=" + id + ", name=" + name + ", age=" + age + "]"; } }
服务接口须要在服务提供方和消费方共享,因此,将它单独放置在一个工程中,方便后面咱们在服务提供方和消费方进行引用。
2.服务提供者
2.1 在服务提供方实现DemoService接口,并实现相应的方法。
package com.ricky.dubbo.provider.impl; import com.ricky.dubbo.api.DemoService; import com.ricky.dubbo.api.model.User; public class DemoServiceImpl implements DemoService { @Override public String sayHello(String name) { return "Hello " + name; } @Override public User findUserById(long id) { User user = new User(); user.setId(id); user.setName("Ricky"); user.setAge(26); return user; } }
2.2 用Spring配置声明暴露服务
provider.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-app" /> <!-- 使用zookeeper注册中心暴露服务地址 --> <!-- 使用multicast广播注册中心暴露服务地址 --> <dubbo:registry address="multicast://224.5.6.7:1234" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 声明须要暴露的服务接口 --> <dubbo:service interface="com.ricky.dubbo.api.DemoService" ref="demoService" /> <!-- 和本地bean同样实现服务 --> <bean id="demoService" class="com.ricky.dubbo.provider.impl.DemoServiceImpl" /> </beans>
2.3 加载Spring配置
package com.ricky.dubbo.provider; import java.io.IOException; import org.springframework.context.support.ClassPathXmlApplicationContext; /** * Dubbo provider * */ public class App { public static void main(String[] args) { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "provider.xml" }); context.start(); System.out.println("Dubbo provider start..."); try { System.in.read(); // 按任意键退出 } catch (IOException e) { e.printStackTrace(); } } }
3.服务消费者
3.1 经过Spring配置引用远程服务
consumer.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="consumer-of-helloworld-app" /> <!-- 使用zookeeper注册中心暴露服务地址 --> <!-- 使用multicast广播注册中心暴露发现服务地址 --> <dubbo:registry address="multicast://224.5.6.7:1234" /> <!-- 生成远程服务代理,能够和本地bean同样使用demoService --> <dubbo:reference id="demoService" interface="com.ricky.dubbo.api.DemoService" /> </beans>
3.2 加载Spring配置,并调用远程服务
package com.ricky.dubbo.consumer; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.ricky.dubbo.api.DemoService; import com.ricky.dubbo.api.model.User; /** * Dubbo Consumer client * */ public class App { public static void main(String[] args) { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "consumer.xml" }); context.start(); DemoService demoService = (DemoService) context.getBean("demoService"); // 获取远程服务代理 String hello = demoService.sayHello("ricky"); // 执行远程方法 System.out.println(hello); // 显示调用结果 User user = demoService.findUserById(15); System.out.println(user); // 显示调用结果 } }
OK,到这里一个简单的分布式服务已经开发完毕了,赶忙动手试试吧!
完整Sample代码下载连接:https://github.com/FBing/dubbo-samples