Dubbo快速入門

Dubbo是一個分散式服務框架，既然是服務，必然存在服務提供者與服務調用者。

接下來，我們先編寫一個服務提供者。工程仍然使用上篇文章spring4入門中的工程。

我們在pom.xml中加入dubbo的依賴

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
</dependency>

編寫如下類：

package com.mm.service;

public interface WeatherService {
    public String getMessage(String city);
}

package com.mm.service.impl;

import com.mm.service.WeatherService;

public class WeatherServiceImpl implements WeatherService{

    @Override
    public String getMessage(String city) {
        return city+"天氣晴朗，局部有陣雨";
    }

}

新建一個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="mm-weather"  />
 
    <!-- 使用multicast廣播註冊中心暴露服務地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />
 
    <!-- 用dubbo協議在20880埠暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />
 
    <!-- 聲明需要暴露的服務介面 -->
    <dubbo:service interface="com.mm.service.WeatherService" ref="weatherService" />
 
    <!-- 和本地bean一樣實現服務 -->
    <bean id="weatherService" class="com.mm.service.impl.WeatherServiceImpl" />
 
</beans>

新建一個控制台程式，用於服務啟動

package com.mm.main.dubbo;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class DubboProvider {
    public static void main(String[] args) throws IOException{
         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"config/provider.xml"});
         context.start();
         System.in.read(); // 按任意鍵退出
    }
}

 然後，我們啟動服務提供者，沒有發現報錯信息，服務應該是成功啟動了。

接下來，我們來編寫服務調用者，官方稱為消費者。這裡為了方便，我直接複製一份代碼到新的工作空間，簡單配置了一下maven和tomcat。並刪除相應的實現類。代碼結構如下：

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="mm-weather-consumer"  />
 
    <!-- 使用multicast廣播註冊中心暴露發現服務地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />
 
    <!-- 生成遠程服務代理，可以和本地bean一樣使用demoService -->
    <dubbo:reference id="weatherService" interface="com.mm.service.WeatherService" />
 
</beans>

新建一個控制台程式，用於服務的調用

package com.mm.main.dubbo;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.mm.service.WeatherService;

public class DubboConsumer {
    public static void main(String[] args) throws IOException{
         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"config/consumer.xml"});
         WeatherService  demoService = (WeatherService )context.getBean("weatherService"); // 獲取遠程服務代理
         String hello = demoService.getMessage("北京"); // 執行遠程方法
         System.out.println( hello ); // 顯示調用結果
    }
}

控制台輸出如下：

同時我們在提供者的控制台也會發現如下信息：

額外補充：

在spring配置文件中使用dubbo標簽時，會報錯。實際應該不影響，估計是eclipse文件驗證的問題。但是看得有點不爽，於是....

首先，在maven的本地倉庫中找到dubbo-2.5.3.jar，解壓發現xsd文件，如下：

打開eclipse的配置

將key的值改為：http://code.alibabatech.com/schema/dubbo/dubbo.xsd

接著，右擊provider.xml後validate，經過漫長的等待，報錯信息消失了。