一、前言
項目中用到了Dubbo，臨時抱大腿，學習了dubbo的簡單實用方法。現在就來總結一下dubbo如何提供服務，如何消費服務，并做了一個簡單的demo作為參考。
二、Dubbo是什么
Dubbo是一個分布式服務框架，致力于提供高性能和透明化的RPC遠程服務調用方案，以及SOA服務治理方案。簡單的說，dubbo就是個服務框架，如果沒有分布式的需求，其實是不需要用的，只有在分布式的時候，才有dubbo這樣的分布式服務框架的需求，并且本質上是個服務調用的東東，說白了就是個遠程服務調用的分布式框架（告別Web Service模式中的WSdl，以服務者與消費者的方式在dubbo上注冊）
其核心部分包含:
1. 遠程通訊: 提供對多種基于長連接的NIO框架抽象封裝，包括多種線程模型，序列化，以及“請求-響應”模式的信息交換方式。
2. 集群容錯: 提供基于接口方法的透明遠程過程調用，包括多協議支持，以及軟負載均衡，失敗容錯，地址路由，動態配置等集群支持。
3. 自動發現: 基于注冊中心目錄服務，使服務消費方能動態的查找服務提供方，使地址透明，使服務提供方可以平滑增加或減少機器。
摘自：http://www.cnblogs.com/Javame/p/3632473.html
三、dubbo配置
1.dubbo需要依賴的jar
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.hjz</groupId><artifactId>dubbo</artifactId><version>0.0.1-SNAPSHOT</version><packaging>pom</packaging><modules><module>hjz-dubbo-api</module><module>hjz-dubbo-consumer</module><module>hjz-dubbo-provider</module></modules><dependencies><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.8.4</version></dependency><dependency><groupId>javassist</groupId><artifactId>javassist</artifactId><version>3.12.1.GA</version></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version></dependency><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version></dependency></dependencies> </project>
2.dubbo服務接口
package com.hjz.dubbo.api;public interface DubboServiceTest {public int calculate(int a, int b); }
3.dubbo服務生產者配置
實現dubbo服務的接口
package com.hjz.service;import org.springframework.stereotype.Service;import com.hjz.dubbo.api.DubboServiceTest;@Service("dubboServiceTest") public class DubboServiceProvider implements DubboServiceTest {@Overridepublic int calculate(int a, int b) {return a+b;}}
dubbo服務提供者配置：classpath:dubbo-provider-example.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:context="http://www.springframework.org/schema/context"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://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><description>dubbo公共配置</description><!-- 掃描需要注入到spring容器中的bean --><context:component-scan base-package="com.hjz.service" /><!-- 引入dubbo需要的配置文件 --><context:property-placeholder location="classpath:dubbo-example.properties" /> <!-- 同一個工程只配置一份即可 --><dubbo:application name="hjz-dubbo" owner="hjzgg"/><!-- 發布dubbo需要對外的協議（dubbo）和端口（20880），20880是dubbo默認提供的端口，若一臺機器發布多個dubbo服務，則此端口需要顯示配置，多個dubbo服務端口需要不一樣，否則會端口沖突 --><dubbo:protocol name="dubbo" port="${dubbo.protocol.port}" serialization="java"/><!-- 配置dubbo服務失敗后的重試次數和接口超時時間 --><dubbo:provider retries="0" timeout="${dubbo.provider.timeout}"/><!-- dubbo注冊到zookeeper，用于預發布或生產環境 --><!-- <dubbo:registry protocol="zookeeper" address="${zookeeper.addr}" /> --><!-- dubbo不注冊到任何registry，用于開發或測試環境--><dubbo:registry protocol="zookeeper" address="N/A" /><dubbo:service ref="dubboServiceTest" interface="com.hjz.dubbo.api.DubboServiceTest"/> </beans>
由于是提供者作為一個web項目，所以web.xml文件如下。
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_2_5.xsd"version="2.5" xmlns="http://xmlns.jcp.org/xml/ns/javaee"><display-name>hjz-dubbo-provider</display-name><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:dubbo-provider-example.xml</param-value></context-param><context-param><param-name>log4jConfigLocation</param-name><param-value>classpath:log4j.properties</param-value></context-param><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener><welcome-file-list></welcome-file-list> </web-app>
4.dubbo服務消費者配置
dubbo服務消費者測試類
package com.hjz.dubbo.consumer;import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import com.alibaba.dubbo.common.logger.Logger; import com.alibaba.dubbo.common.logger.LoggerFactory; import com.hjz.dubbo.api.DubboServiceTest;@RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(locations={"classpath:dubbo-consumer-example.xml"}) public class DubboServiceConsumer {private static final Logger logger = LoggerFactory.getLogger(DubboServiceConsumer.class);@Autowiredprivate DubboServiceTest dubboServiceTest;@Testpublic void consumer(){int a = 4, b = 5;logger.info("消費dubbo服務....................");logger.info(String.format("a = %d, b = %d, a+b = %d", a, b, dubboServiceTest.calculate(a, b)));} }
dubbo服務消費者配置：dubbo-consumer-example.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:context="http://www.springframework.org/schema/context"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://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><description>dubbo公共配置</description><context:property-placeholder location="classpath:dubbo-example.properties" /><!-- 同一個工程只配置一份即可 --><dubbo:application name="hjz-dubbo" owner="hjzgg"/><!-- 服務應用方調用的超時時間。默認不配置，則以服務提供方的超時時間為準。check為false表示延遲加載dubbo依賴的服務--><dubbo:consumer retries="0" timeout="${dubbo.consumer.timeout}" check="false"/><!-- dubbo注冊到zookeeper，用于預發布或生產環境 --><!-- <dubbo:registry protocol="zookeeper" address="${zookeeper.addr}" /> --><!-- 像引用spring的bean服務一樣引用dubbo提供的接口，用于預發布和生產環境--><!-- <dubbo:reference id="dubboServiceTest" interface="com.hjz.dubbo.api.DubboServiceTest" /> --><!-- dubbo直連方式，只用于開發或測試階段 --><dubbo:reference id="dubboServiceTest" interface="com.hjz.dubbo.api.DubboServiceTest" url="dubbo://127.0.0.1:20880" /> </beans>
四、dubbo測試
首先啟動dubbo生產者，然后運行消費者的測試類，可以看到控制臺中有如下信息輸出：
2016-09-25 19:36:08,502 INFO [com.hjz.dubbo.consumer.DubboServiceConsumer] - [DUBBO] 消費dubbo服務...................., dubbo version: 2.8.4, current host: 192.168.80.4
2016-09-25 19:36:08,761 INFO [com.hjz.dubbo.consumer.DubboServiceConsumer] - [DUBBO] a = 4, b = 5, a+b = 9, dubbo version: 2.8.4, current host: 192.168.80.4 五、總結
1.如果一個工程中有dubbo消費者，也有dubbo生產者，則<dubbo:application name="hjz-dubbo" owner="hjzgg"/>配置只有一個就可以了。
2.測試環境一般采用dubbo直聯方式，生產環境一般將dubbo服務注冊到zookeeper。
3.配置文件中?dubbo:reference id="dubboServiceTest" ?和 dubbo:service ref="dubboServiceTest"， id和ref的對應的value要一致。
4.配置文件中?dubbo:service ref="dubboServiceTest"，ref對應的value是服務的名稱，例如@Service("dubboServiceTest")。
5.如果拋出下面異常，
com.caucho.hessian.client.HessianRuntimeException: com.caucho.hessian.io.HessianFieldException: com.shine.ermp.dto.UserAccountDTO.invalidDate:
java.sql.Timestamp cannot be assigned from null dubbo服務提供者的配置文件中加上下面紅色的代碼。
<dubbo:protocol name="dubbo" port="20880" serialization="java"/>
六、測試demo
https://github.com/hjzgg/dubbo_demo
注：測試demo工程是個maven工程，eclipse可以通過?Check out as Maven Project from SCM 來導入即可，URL:https://github.com/hjzgg/dubbo_demo.git
