dubbo+rest 之 helloworld（一）

　　之前的博客中已經介紹過dubbo服務的provider-consumer的實現，這里實現一個內部服務由dubbo提供，而外部服務則用rest提供。實現的原理還需要進一步研究源代碼，但首先，我們要知道how。本篇將展示第一種簡單配置，即將dubbo-provider作為依賴，使用rest-provider啟動並提供服務。工程結構如圖：

其中，dubbo-provider的結構在之前的博客中已有說明，它的重要配置文件依次如下：

dubbo.properties:

dubbo.spring.config=classpath*:Spring/*.xml

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

    <!-- 使用multicast廣播注冊中心暴露服務地址 <dubbo:registry address="multicast://224.5.6.7:1234" 
        /> -->

    <!-- 使用zookeeper注冊中心暴露服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

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

    <!-- 具體的實現bean -->
    <bean id="ProviderServiceImpl" class="com.changjiang.test.dubboProvider.ProviderServiceImpl" />
    <!-- 聲明需要暴露的服務接口 -->
    <dubbo:service interface="com.changjiang.test.dubboProvider.ProviderService"
        ref="ProviderServiceImpl"  protocol="dubbo" version="dubboTest1.0"/>

</beans> 

接口以及實現：

package com.changjiang.test.dubboProvider;

public class ProviderServiceImpl implements ProviderService {

    @Override
    public String provide() {
        System.out.println("== provide service ==");
        return "success";
    }

}

而后，我們將其作為一個依賴，放入dubboRest中：

        <dependency>
            <groupId>com.changjiang.test</groupId>
            <artifactId>dubboProvider</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

這樣，我們在rest服務的具體實現中就可以調用該服務了。

 dubboRest結構：

其中的dubbo.properties與上相同，Provider.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns="http://www.springframework.org/schema/beans"
    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">

    <!-- 提供方應用信息，用於計算依賴關系 -->
    <!-- 使用multicast廣播注冊中心暴露服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    <dubbo:annotation package="com.changjiang.test.dubboRest" />
    <dubbo:protocol path="DubboRest" name="rest" port="20660"
        server="tomcat" accepts="5000" threads="1000" keepalive="false" />

</beans>

這里要注意的是，既然將dubboProvider作為依賴引入，那么就不能再指定一些重復的信息，比如dubbo-application,或者是發布服務的端口號等。此處沒有設置dubboApplicationName,端口號改用20660，服務發布的根路徑為DubboRest。另外，引入applicationContext.xml是為了加載文件，以及引用bean比較方便：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns="http://www.springframework.org/schema/beans"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:mongo="http://www.springframework.org/schema/data/mongo"  
       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.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/data/mongo  
        http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd"
       default-lazy-init="true">

    <description>Spring公共配置</description>

    <!-- 該 BeanPostProcessor 將自動對標注 @Autowired 的 Bean 進行注入 -->
    <context:annotation-config/>

    <!-- 使用annotation 自動注冊bean, 並保證@Required、@Autowired的屬性被注入 -->
    <context:component-scan base-package="com.changjiang.test.dubboRest"/>

</beans>

無論是dubbo協議還是rest協議服務，在dubbo架構中都必須使用接口實現，所以我們看看接口以及它的實現：

package com.changjiang.test.dubboRest;

import javax.ws.rs.Consumes;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.springframework.beans.factory.annotation.Autowired;

import com.alibaba.dubbo.config.annotation.Service;
import com.changjiang.test.dubboProvider.ProviderService;
@Service(protocol="rest")
@Path("/restService")
@Consumes({ MediaType.APPLICATION_JSON })
@Produces({ MediaType.APPLICATION_JSON })
public class RestServiceImpl implements RestService{

    @Autowired
    private ProviderService providerService;

    @Path("/getMsg")
    @GET
    public String rest() {
        String str = providerService.provide();
        System.out.println(str);
        return str;
    }
}

這里@Service(protocol="rest")表示使用rest協議，而后我們可以根據下面的路徑和請求方式獲取到發布出來的rest服務。

可能你已經注意到這里用到了dubboFilter。對於Java Web應用，Spring的攔截器可以攔截Web接口的調用；而對於dubbo接口，Spring的攔截器就不管用了。所以，需要使用相關的攔截和處理，需要用到dubboFilter:

/dubboRest/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Filter:

restValidateFilter=com.changjiang.test.dubboRest.interceptor.RestValidateFilter

實現：

package com.changjiang.test.dubboRest.interceptor;

import javax.ws.rs.core.Response;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;
import com.alibaba.dubbo.rpc.RpcException;
import com.alibaba.dubbo.rpc.RpcResult;
import com.alibaba.fastjson.JSONObject;


public class RestValidateFilter implements Filter {
    Logger logger= LoggerFactory.getLogger(RestValidateFilter.class);

    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
   
        return getRpcResult(invoker,invocation,null);
    }

    public Result getRpcResult(Invoker<?> invoker,Invocation invocation,JSONObject result){
        if(invoker==null){
            return  new RpcResult(Response.status(401).build());
        }else{
            return invoker.invoke(invocation);
        }
    }
}

配置都齊全了，我們可以在主類中使用dubbo自帶的Main啟動：

package com.changjiang.test.dubboRest;

/**
 * Hello world!
 *
 */

public class App {
    public static void main(String[] args) {
        String[] ars = {};
        com.alibaba.dubbo.container.Main.main(ars);
    }
}

可以在dubbo-admin中觀察到，此時我們發布了2個服務，一個是dubbo風格的，另一個是rest風格的，而在此工程的內部，我們已經調用到了該dubbo服務：

根據服務的路徑，我們可以用HttpGet請求進行訪問，查看結果：