Dubbo的使用简介

1.服务接口层（Service）：该层是与实际业务逻辑相关的，根据服务提供方和服务消费方的业务设计对应的接口和实现。
2.配置层（Config）：对外配置接口，以ServiceConfig和ReferenceConfig为中心，可以直接new配置类，也可以通过spring解析配置生成配置类。
3.服务代理层（Proxy）：服务接口透明代理，生成服务的客户端Stub和服务器端Skeleton，以ServiceProxy为中心，扩展接口为ProxyFactory。
4.服务注册层（Registry）：封装服务地址的注册与发现，以服务URL为中心，扩展接口为RegistryFactory、Registry和RegistryService。可能没有服务注册中心，此时服务提供方直接暴露服务。
5.集群层（Cluster）：封装多个提供者的路由及负载均衡，并桥接注册中心，以Invoker为中心，扩展接口为Cluster、Directory、Router和LoadBalance。将多个服务提供方组合为一个服务提供方，实现对服务消费方来透明，只需要与一个服务提供方进行交互。
6.监控层（Monitor）：RPC调用次数和调用时间监控，以Statistics为中心，扩展接口为MonitorFactory、Monitor和MonitorService。
7.远程调用层（Protocol）：封将RPC调用，以Invocation和Result为中心，扩展接口为Protocol、Invoker和Exporter。Protocol是服务域，它是Invoker暴露和引用的主功能入口，它负责Invoker的生命周期管理。Invoker是实体域，它是Dubbo的核心模型，其它模型都向它靠扰，或转换成它，它代表一个可执行体，可向它发起invoke调用，它有可能是一个本地的实现，也可能是一个远程的实现，也可能一个集群实现。
8.信息交换层（Exchange）：封装请求响应模式，同步转异步，以Request和Response为中心，扩展接口为Exchanger、ExchangeChannel、ExchangeClient和ExchangeServer。
9.网络传输层（Transport）：抽象mina和netty为统一接口，以Message为中心，扩展接口为Channel、Transporter、Client、Server和Codec。
10.数据序列化层（Serialize）：可复用的一些工具，扩展接口为Serialization、 ObjectInput、ObjectOutput和ThreadPool。

> 在RPC中，Protocol是核心层，也就是只要有Protocol + Invoker + Exporter就可以完成非透明的RPC调用，然后在Invoker的主过程上Filter拦截点。
> 图中的Consumer和Provider是抽象概念，只是想让看图者更直观的了解哪些类分属于客户端与服务器端，不用Client和Server的原因是Dubbo在很多场景下都使用Provider、Consumer、Registry、Monitor划分逻辑拓普节点，保持统一概念。
> 而Cluster是外围概念，所以Cluster的目的是将多个Invoker伪装成一个Invoker，这样其它人只要关注Protocol层Invoker即可，加上Cluster或者去掉Cluster对其它层都不会造成影响，因为只有一个提供者时，是不需要Cluster的。
> Proxy层封装了所有接口的透明化代理，而在其它层都以Invoker为中心，只有到了暴露给用户使用时，才用Proxy将Invoker转成接口，或将接口实现转成Invoker，也就是去掉Proxy层RPC是可以Run的，只是不那么透明，不那么看起来像调本地服务一样调远程服务。
> 而Remoting实现是Dubbo协议的实现，如果你选择RMI协议，整个Remoting都不会用上，Remoting内部再划为Transport传输层和Exchange信息交换层，Transport层只负责单向消息传输，是对Mina、Netty、Grizzly的抽象，它也可以扩展UDP传输，而Exchange层是在传输层之上封装了Request-Response语义。
> Registry和Monitor实际上不算一层，而是一个独立的节点，只是为了全局概览，用层的方式画在一起。

1 <bean id=“xxxService” class=“com.xxx.XxxServiceImpl” />
2  
3 <bean id=“xxxAction” class=“com.xxx.XxxAction”>
4     <property name=“xxxService” ref=“xxxService” />
5 </bean>

1 <bean id=“xxxService” class=“com.xxx.XxxServiceImpl” /> <!-- 和本地服务一样实现远程服务 -->
2  
3 <dubbo:service interface=“com.xxx.XxxService” ref=“xxxService” /> <!-- 增加暴露远程服务配置 -->

1 <dubbo:reference id=“xxxService” interface=“com.xxx.XxxService” /> <!-- 增加引用远程服务配置 -->
2  
3 <bean id=“xxxAction” class=“com.xxx.XxxAction”> <!-- 和本地服务一样使用远程服务 -->
4     <property name=“xxxService” ref=“xxxService” />
5 </bean>

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 5     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">
 6  
 7     <!-- 提供方应用信息，用于计算依赖关系 -->
 8     <dubbo:application name="hello-world-app"  />
 9  
10     <!-- 使用multicast广播注册中心暴露服务地址 -->
11     <dubbo:registry address="multicast://224.5.6.7:1234" />
12  
13     <!-- 用dubbo协议在20880端口暴露服务 -->
14     <dubbo:protocol name="dubbo" port="20880" />
15  
16     <!-- 声明需要暴露的服务接口 -->
17     <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />
18  
19     <!-- 和本地bean一样实现服务 -->
20     <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />
21  
22 </beans>

 1 import org.springframework.context.support.ClassPathXmlApplicationContext;
 2  
 3 public class Provider {
 4  
 5     public static void main(String[] args) throws Exception {
 6         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/provider.xml"});
 7         context.start();
 8  
 9         System.in.read(); // 按任意键退出
10     }
11  
12 }

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 5     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">
 6  
 7     <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
 8     <dubbo:application name="consumer-of-helloworld-app"  />
 9  
10     <!-- 使用multicast广播注册中心暴露发现服务地址 -->
11     <dubbo:registry address="multicast://224.5.6.7:1234" />
12  
13     <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
14     <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />
15  
16 </beans>

 1 import org.springframework.context.support.ClassPathXmlApplicationContext;
 2 import com.alibaba.dubbo.demo.DemoService;
 3  
 4 public class Consumer {
 5  
 6     public static void main(String[] args) throws Exception {
 7         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/consumer.xml"});
 8         context.start();
 9  
10         DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
11         String hello = demoService.sayHello("world"); // 执行远程方法
12  
13         System.out.println( hello ); // 显示调用结果
14     }
15  
16 }

1 <dubbo:registry  address="multicast://224.5.6.7:1234" />
2 替换为
3 <dubbo:registry protocol="zookeeper" address="192.168.17.129:2181,192.168.17.129:2182,192.168.17.129:2183" /> 或者
4 <dubbo:registry address="zookeeper://192.168.17.129:2181?backup=192.168.17.129:2182,192.168.17.129:2183" /> 

 1 import com.alibaba.dubbo.rpc.config.ApplicationConfig;
 2 import com.alibaba.dubbo.rpc.config.RegistryConfig;
 3 import com.alibaba.dubbo.rpc.config.ProviderConfig;
 4 import com.alibaba.dubbo.rpc.config.ServiceConfig;
 5 import com.xxx.XxxService;
 6 import com.xxx.XxxServiceImpl;
 7  
 8 // 服务实现
 9 XxxService xxxService = new XxxServiceImpl();
10  
11 // 当前应用配置
12 ApplicationConfig application = new ApplicationConfig();
13 application.setName("xxx");
14  
15 // 连接注册中心配置
16 RegistryConfig registry = new RegistryConfig();
17 registry.setAddress("10.20.130.230:9090");
18 registry.setUsername("aaa");
19 registry.setPassword("bbb");
20  
21 // 服务提供者协议配置
22 ProtocolConfig protocol = new ProtocolConfig();
23 protocol.setName("dubbo");
24 protocol.setPort(12345);
25 protocol.setThreads(200);
26  
27 // 注意：ServiceConfig为重对象，内部封装了与注册中心的连接，以及开启服务端口
28  
29 // 服务提供者暴露服务配置
30 ServiceConfig<XxxService> service = new ServiceConfig<XxxService>(); // 此实例很重，封装了与注册中心的连接，请自行缓存，否则可能造成内存和连接泄漏
31 service.setApplication(application);
32 service.setRegistry(registry); // 多个注册中心可以用setRegistries()
33 service.setProtocol(protocol); // 多个协议可以用setProtocols()
34 service.setInterface(XxxService.class);
35 service.setRef(xxxService);
36 service.setVersion("1.0.0");
37  
38 // 暴露及注册服务
39 service.export();

 1 import com.alibaba.dubbo.rpc.config.ApplicationConfig;
 2 import com.alibaba.dubbo.rpc.config.RegistryConfig;
 3 import com.alibaba.dubbo.rpc.config.ConsumerConfig;
 4 import com.alibaba.dubbo.rpc.config.ReferenceConfig;
 5 import com.xxx.XxxService;
 6  
 7 // 当前应用配置
 8 ApplicationConfig application = new ApplicationConfig();
 9 application.setName("yyy");
10  
11 // 连接注册中心配置
12 RegistryConfig registry = new RegistryConfig();
13 registry.setAddress("10.20.130.230:9090");
14 registry.setUsername("aaa");
15 registry.setPassword("bbb");
16  
17 // 注意：ReferenceConfig为重对象，内部封装了与注册中心的连接，以及与服务提供方的连接
18  
19 // 引用远程服务
20 ReferenceConfig<XxxService> reference = new ReferenceConfig<XxxService>(); // 此实例很重，封装了与注册中心的连接以及与提供者的连接，请自行缓存，否则可能造成内存和连接泄漏
21 reference.setApplication(application);
22 reference.setRegistry(registry); // 多个注册中心可以用setRegistries()
23 reference.setInterface(XxxService.class);
24 reference.setVersion("1.0.0");
25  
26 // 和本地bean一样使用xxxService
27 XxxService xxxService = reference.get(); // 注意：此代理对象内部封装了所有通讯细节，对象较重，请缓存复用