一個分散式服務框架--Dubbo實例

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

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

 

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

   com.groupId>dependency>
   com. alibaba
   dubbo
   2.5.3

2.5.3

2.5.3

2.5.3

2.5.3>/version>##<lt;version>/de#gt;

##

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{

    @Overridepublic 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                        ">

    <!-- 提供方应用信息，用于计算依赖关系 -->
    <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                        ">

    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <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的值改為：

接著，右鍵點選provider.xml後validate，經過漫長的等待，報錯訊息消失了。

以上是一個分散式服務框架--Dubbo實例的詳細內容。更多資訊請關注PHP中文網其他相關文章！