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请求进行访问，查看结果：