dubbo的使用實例

一、項目結構

用 maven 多模塊的構建方式，在 spring-dubbo 下構建三個子模塊：

• dubbo-common：公共模塊，用於存放公共的接口和 bean，被 dubbo-provider 和 dubbo-provider 所引用；
• dubbo-provider ：服務的提供者，提供商品的查詢服務；
• dubbo-provider ：是服務的消費者，調用 provider 提供的查詢服務。

另外，本項目 Dubbo 的搭建采用 ZooKeeper 作為注冊中心。

二、項目依賴

 在父工程的項目中統一導入依賴 Dubbo 的依賴：

 <dependency>
            <!--dubbo 依賴-->
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.0.0</version>
           <exclusions>
               <exclusion>
                   <groupId>org.apache.zookeeper</groupId>
                   <artifactId>zookeeper</artifactId>
               </exclusion>
           </exclusions>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.13</version>
        </dependency>

三、公共模塊

api是接口，bean是實體類。

 

 四、 服務提供者

 

1. 開發服務

   productService 是服務的提供者，其實現的接口 IProductService 來源於公共模塊

   @Service //此處為dubbo的注解
   public class ProductService implements IProductService { private static List<Product> productList = new ArrayList<>(); static { for (int i = 0; i < 20; i++) { productList.add(new Product(i, "number" + i, i / 2 == 0, new Date(), 66.66f * i)); } } public Product queryProductById(int id) { for (Product product : productList) { if (product.getId() == id) { product.setDateInProduced(new Date()); return product; } } return null; } public List<Product> queryAllProducts() { return productList; } }

2. 暴露服務

在spring-dubbo-provider.xml中暴露服務，除了在xml中定義接口，還可以用掃描形式 <dubbo:annotation package="com.heibaiying.service" />，然后使用的dubbo框架所提供的@service注解。作用是聲明需要暴露的服務接口，如上面紅色的注解。

<?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://dubbo.apache.org/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 提供方應用信息，用於計算依賴關系 -->
    <dubbo:application name="dubbo-provider"/>

    <!-- 使用zookeeper注冊中心暴露服務地址 如果是集群配置 用, 分隔地址 -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>

    <!-- 用dubbo協議在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- 聲明需要暴露的服務接口，還可以用注解形式 -->
    <dubbo:service interface="com.heibaiying.api.IProductService" ref="productService"/>
    <!-- 和本地bean一樣實現服務 -->
    <bean id="productService" class="com.heibaiying.service.ProductService"/>

</beans>

五、服務消費者

1. 調用服務,在spring-dubbo-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://dubbo.apache.org/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans
          http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
          http://dubbo.apache.org/schema/dubbo
          http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
   
       <!-- 消費方應用名，用於計算依賴關系，不是匹配條件，不要與提供方一樣 -->
       <dubbo:application name="dubbo-consumer">
           <dubbo:parameter key="shutdown.timeout" value="60000"/> <!-- 單位毫秒 -->
       </dubbo:application>
   
       <!--Dubbo 缺省會在啟動時檢查依賴的服務是否可用，不可用時會拋出異常，阻止 Spring 初始化完成，以便上線時，能及早發現問題，默認 check="true"。-->
       <!--可以關閉所有服務的啟動時檢查 -->
       <dubbo:consumer check="false" />
   
       <!-- 使用zookeeper注冊中心暴露發現服務地址 -->
       <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
   
       <!-- 生成遠程服務代理，可以和本地bean一樣使用demoService -->
       <dubbo:reference id="sellService" interface="com.heibaiying.api.IProductService"/>
   
   
   </beans>

2. 消費服務

@Controller @RequestMapping("sell") public class SellController { 
　　//當成本地bean一樣使用 @Resource private IProductService productService; @RequestMapping public String productList(Model model) { List<Product> products = productService.queryAllProducts(); model.addAttribute("products", products); return "products"; } @RequestMapping("product/{id}") public String productDetail(@PathVariable int id, Model model) { Product product = productService.queryProductById(id); model.addAttribute("product", product); return "product"; } }

六、dubbo控制台

dubbo的新版控制台不太好用，我用的是dubbo-admin-2.5.10版本。直接將工程duboo-admin打成war包，放到tomcat中。

源碼地址：https://github.com/bruce-cao/spring-samples-for-all/tree/master/spring/spring-dubbo