Dubbo通过注解实现RPC调用

启动Dubbo服务有2个方式，1是通过xml配置，2是通过注解来实现，这点和Spring相似。

采用XML配置如下：

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        
6    http://www.springframework.org/schema/beans/spring-beans.xsd        
7    http://code.alibabatech.com/schema/dubbo        
8    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
9 
10    <!-- 提供方应用信息，用于计算依赖关系 -->
11    <dubbo:application name="find_all_goods"  />
12 
13    <!-- 使用multicast广播注册中心暴露服务地址 -->
14   <!--  <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
15 
16     <!-- 使用zookeeper注册中心暴露服务地址 -->
17    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
18 
19    <!-- 用dubbo协议在20880端口暴露服务 -->
20    <dubbo:protocol name="dubbo" port="20880" />
21 
22    <!-- 声明需要暴露的服务接口（注意是接口,不是实现类） -->
23    <dubbo:service interface="com.zdd.dubbo.provider.GoodsService" ref="goodsService" />
24    
25    <!-- 这里是具体实现类,id和上面的暴露的服务接口ref要一致,dubbo就是通过这个来注册对应的服务 -->
26    <bean id="goodsService" class="com.zdd.dubbo.provider.GoodsServiceImpl"></bean>
27    
28</beans>

上面代码是通过dubbo:service interface标签把接口暴露出去,在程序启动的时候会自动注册到zookeeper。

消费端调用方式配置如下：

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        
6    http://www.springframework.org/schema/beans/spring-beans.xsd        
7    http://code.alibabatech.com/schema/dubbo        
8    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
9    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
10    <dubbo:application name="dubbo-consumer"/>
11    <!-- 使用multicast广播注册中心暴露发现服务地址 -->
12    <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
13    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
14    <!-- 生成远程服务代理，可以和本地bean一样调用 -->
15    <dubbo:reference id="goodsService" interface="com.zdd.dubbo.provider.GoodsService" />
16</beans>

然后我们可以像spring一样调用本地服务,代码如下：

1ApplicationContext  dubbo_cusumer = new ClassPathXmlApplicationContext("file:D:/workspace/GZDTL_TRUNK/zdd-web-consumer/spring/dubbo-consumer.xml");
2
3       dubbo_cusumer.getBean("goodsService");

上面的是采用xml方式配置dubbo，下面是通过注解配置dubbo，可以对比一下区别。

通过注解方式配置的dubbo.xml如下：

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    xmlns:context="http://www.springframework.org/schema/context"
6    xsi:schemaLocation="http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
7        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
8        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd">
9       
10
11   
12    <!-- 提供方应用信息，用于计算依赖关系 -->  
13    <dubbo:application name="dubbo_provider" />  
14  
15    <!-- 使用multicast广播注册中心暴露服务地址 <dubbo:registry address="multicast://224.5.6.7:1234"   
16        /> -->  
17  
18    <!-- 使用zookeeper注册中心暴露服务地址 -->  
19    <dubbo:registry address="zookeeper://127.0.0.1:2181" />  
20  
21    <!-- 用dubbo协议在20880端口暴露服务 -->  
22    <dubbo:protocol name="dubbo" port="20880" />  
23  
24    <!-- 具体的实现bean  
25    <bean id="demoService" class="com.unj.dubbotest.provider.impl.DemoServiceImpl" />  
26    -->  
27    <!-- 声明需要暴露的服务接口   
28    <dubbo:service interface="com.unj.dubbotest.provider.DemoService" ref="demoService" />  
29    -->  
30      
31    <!-- 使用注解方式暴露接口 -->     
32    <dubbo:annotation package="com.dubbo.provide" />  
33      
34    <!-- 加入spring注解扫描 -->  
35    <!-- <context:component-scan base-package="com.dubbo.provide"/>   -->
36</beans>

上面是通过 dubbo:annotation package 扫描com.dubbo.provide下的所有包,类似于spring 的 context:component-scan base-package，它会把dubbo相关注解进行扫描，这样我们就不需要在xml里面针对每个服务接口配置dubbo:service interface。

通过注解方式的服务实现类如下

1package com.dubbo.provide;
2
3import com.alibaba.dubbo.config.annotation.Service;
4
5@Service
6public class DubboPro implements DubboProInterface {
7
8    public void print() {
9
10        System.out.println("is ok");
11        
12    }
13
14}

需要注意的是Service注解是dubbo的注解，而不是spring的,它位于dubbo.jar的annotaion目录下：

消费端注解方式调用类如下：

1package com.dubbo.consumer;
2
3import org.springframework.stereotype.Component;
4
5import com.alibaba.dubbo.config.annotation.Reference;
6import com.dubbo.provide.DubboProInterface;
7
8
9@Component
10public class DubboConsumer{
11
12    @Reference 
13    DubboProInterface dubboProInterface;
14    
15    public void print(){
16        System.out.println(dubboProInterface);
17        dubboProInterface.print();
18    }
19}

通过@Reference注解,dubbo会在扫描的时候会自动帮我们代理接口（见下图）,然后通过rpc调用远程服务

注意：这边接口的名称以及包路径，必须和提供者暴露的接口一致，可以直接将服务端的接口导出成jar，然后在客户端引入使用。