dubbo服務提供與消費

1、前言

　　項目中用到了Dubbo，臨時抱大腿，學習了dubbo的簡單實用方法。如今就來總結一下dubbo如何提供服務，如何消費服務，並作了一個簡單的demo做爲參考。

2、Dubbo是什麼

　　Dubbo是一個分佈式服務框架，致力於提供高性能和透明化的RPC遠程服務調用方案，以及SOA服務治理方案。簡單的說，dubbo就是個服務框架，若是沒有分佈式的需求，實際上是不須要用的，只有在分佈式的時候，纔有dubbo這樣的分佈式服務框架的需求，而且本質上是個服務調用的東東，說白了就是個遠程服務調用的分佈式框架（告別Web Service模式中的WSdl，以服務者與消費者的方式在dubbo上註冊）
其核心部分包含:
　　1. 遠程通信: 提供對多種基於長鏈接的NIO框架抽象封裝，包括多種線程模型，序列化，以及「請求-響應」模式的信息交換方式。
　　2. 集羣容錯: 提供基於接口方法的透明遠程過程調用，包括多協議支持，以及軟負載均衡，失敗容錯，地址路由，動態配置等集羣支持。
　　3. 自動發現: 基於註冊中心目錄服務，使服務消費方能動態的查找服務提供方，使地址透明，使服務提供方能夠平滑增長或減小機器。

　　摘自：http://www.cnblogs.com/Javame/p/3632473.html

3、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 {

    @Override
    public 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.xsd
    http://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);
    @Autowired
    private DubboServiceTest dubboServiceTest;
    
    @Test
    public 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.xsd
    http://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>

4、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

5、總結

　　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"/>

6、測試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