Dubbo是高性能, 基于java实现的开源RPC框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和 Spring框架无缝集成。
Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
主要核心部件
Remoting: 网络通信框架，实现了 sync-over-async 和request-response 消息机制
RPC: 一个远程过程调用的抽象，支持负载均衡、容灾和集群功能
Registry: 服务目录框架用于服务的注册和服务事件发布和订阅
工作原理
Provider
暴露服务方称之为“服务提供者”。
Consumer
调用
远程服务方称之为“服务消费者”。
Registry
服务注册与发现的中心目录服务称之为“服务注册中心”。
Monitor
统计服务的调用次数和调用时间的日志服务称之为“服务监控中心”。
(1) 连通性：
注册中心负责服务地址的注册与查找，相当于
目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小
监控中心负责统计各服务调用次数，调用时间等，统计先在内存汇总后每分钟一次发送到监控中心服务器，并以报表展示
服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销
服务消费者向注册中心获取服务提供者地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销
注册中心，服务提供者，服务消费者三者之间均为长连接，监控中心除外
注册中心通过
长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者
注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在
本地缓存了提供者列表
注册中心和监控中心都是可选的，服务消费者可以直连服务提供者
(2) 健壮性：
监控中心宕掉不影响使用，只是丢失部分
采样数据
数据库宕掉后，注册中心仍能通过
缓存提供服务列表查询，但不能注册新服务
注册中心对等
集群，任意一台宕掉后，将自动切换到另一台
注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯
服务提供者无状态，任意一台宕掉后，不影响使用
服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复
(3) 伸缩性：
注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心
服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者
特性
面向接口代理的高性能RPC调用
提供高性能的基于代理的远程调用能力，服务以接口为粒度，为开发者屏蔽远程调用底层细节。
智能负载均衡
内置多种负载均衡策略，智能感知下游节点健康状况，显著减少调用延迟，提高系统吞吐量。
服务自动注册与发现
支持多种注册中心服务，服务实例上下线实时感知。
高度可扩展能力
遵循微内核+插件的设计原则，所有核心能力如Protocol、Transport、Serialization被设计为扩展点，平等对待内置实现和第三方实现。
运行期流量调度
内置条件、脚本等路由策略，通过配置不同的路由规则，轻松实现灰度发布，同机房优先等功能。
可视化的服务治理与运维
提供丰富服务治理、运维工具：随时查询服务元数据、服务健康状态及调用统计，实时下发路由策略、调整配置参数。
例子
服务端
定义一个Service Interface：（HelloService.java）
1
2
3
4
5
6
7
8
package
com.alibaba.hello.api;
public
interface
HelloService
{
String sayHello(String name);
}
接口的实现类：（HelloServiceImpl.java）
1
2
3
4
5
6
7
package
com.alibaba.hello.impl;
import
com.alibaba.hello.api.HelloService;
public
class
HelloServiceImpl
implements
HelloService{
public
String sayHello(String name){
return
"Hello"
+ name;
}
}
Spring配置：（provider.xml）
1
2
3
4
5
6
7
8
9
10
11
12
13
<?
xmlversion
=
"1.0"
encoding
=
"UTF-8"
?>
<
beans......
>
<!--Applicationname-->
<
dubbo:applicationname
=
"hello-world-app"
/>
<!--registryaddress,usedforservicetoregisteritself-->
<
dubbo:registryaddress
=
"multicast://224.5.6.7:1234"
/>
<!--exposethisservicethroughdubboprotocol,throughport20880-->
<
dubbo:protocolname
=
"dubbo"
port
=
"20880"
/>
<!--whichserviceinterfacedoweexpose?-->
<
dubbo:serviceinterface
=
"com.alibaba.hello.api.HelloService"
ref
=
"helloService"
/>
<!--designateimplementation-->
<
beanid
=
"helloService"
class
=
"com.alibaba.hello.impl.HelloServiceImpl"
/>
</
beans
>
测试代码：（Provider.java）
1
2
3
4
5
6
7
importorg.springframework.context.support.ClassPathXmlApplicationContext;
public
class
Provider{
public
static
void
main(String[] args){
ClassPathXmlApplicationContext context =
new
ClassPathXmlApplicationContext(newString[]{
"provider.xml"
});
//启动成功，监听端口为20880System.in.read();//按任意键退出
}
}
客户端
Spring配置文件：(consumer.xml)
1
2
3
4
5
6
7
8
9
<?
xmlversion
=
"1.0"
encoding
=
"UTF-8"
?>
<
beans
xmlns=......>
<!--consumerapplicationname-->
<
dubbo:applicationname
=
"consumer-of-helloworld-app"
/>
<!--registryaddress,usedforconsumertodiscoverservices-->
<
dubbo:registryaddress
=
"multicast://224.5.6.7:1234"
/>
<!--whichservicetoconsume?-->
<
dubbo:referenceid
=
"helloService"
interface
=
"com.alibaba.hello.api.HelloService"
/>
</
beans
>
客户端测试代码：（Consumer.java）
1
2
3
4
5
6
7
8
9
10
11
import
org.springframework.context.support.ClassPathXmlApplicationContext;
import
com.alibaba.hello.api.HelloService;
public
class
Consumer{
public
static
void
main(String[] args){
ClassPathXmlApplicationContext context =
new
ClassPathXmlApplicationContext(newString[]{
"consumer.xml"
});
HelloService helloService = (HelloService)context.getBean(
"helloService"
);
//getserviceinvocationproxyStringhello=helloService.sayHello("world");
//doinvoke!System.out.println(hello);
//cool,howareyou~
}
}
转载于:https://www.cnblogs.com/jvStarBlog/p/11019504.html
相关资源：Dubbo是Alibaba开源的分布式服务框架
