本文使用官方项目示例，基于dubbox发布restful服务。jdk，eclipse、maven神马环境的就不讲了，自行baidu之。

dubbox下载、编译

下载地址：https://github.com/dangdangdotcom/dubbox
下载方式可以用git下载，也可以打包下载。下载之后，用maven导入（eclipse->import->Maven)。

dubbo项目结构

使用maven打包，版本2.8.4。

zookeeper安装

本文使用的是单节点的注册中心，在实际项目中需要考虑高可用，需要搭建集群注册中心，集群环境搭建在以后的文章中会讲到。

下载

https://zookeeper.apache.org/
这里用的是zookeeper-3.5.1-alpha版本，下载之后，解压到本地。

配置

进入conf目录,修改dataDir（数据）和dataLogDir（日志）文件目录到你本地的目录：

dataDir=E:\\zookeeper-3.5.1-alpha\\data
dataLogDir=E:\\zookeeper-3.5.1-alpha\\logs

其它不用改动，需要注意的是clientPort=2181。这个就是dubbo连接注册中心需要使用的端口。

启动

进入zookeeper\bin目录，运行zkServer.cmd：

运行zookeeper

出现以下信息，启动成功：

2017-05-20 10:53:29,604 [myid:] - INFO  [main:NIOServerCnxnFactory@673] - Configuring NIO connection handler with 10s sessionless connection timeout, 2 selector thread(s), 16 worker threads, and 64 kB direct buffers.
2017-05-20 10:53:29,609 [myid:] - INFO  [main:NIOServerCnxnFactory@686] - binding to port 0.0.0.0/0.0.0.0:2181

dubbo示例

demo导入

dubbo官方自带的示例，包括三个工程，api\product（服务提供者）和consumer（服务消费者）。
导入后的项目结构：

dubbo示例项目结构

demo解剖

dubbo-demo-api：定义的服务接口
dubbo-demo-provider：服务发布
dubbo-demo-consumer:服务消费

配置文件

<!--连接本地注册中心-->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

服务接口

public interface UserService {
    User getUser(Long id);
    Long registerUser(User user);
}

定义了一个用户接口，两个方法。

服务发布

<!--对接口的实现-->
<bean id="userService" class="com.alibaba.dubbo.demo.user.UserServiceImpl" />
<!--dubbo服务-->
<dubbo:service interface="com.alibaba.dubbo.demo.user.UserService" ref="userService"  protocol="dubbo" group="xmlConfig"/>
<!--rest服务实现-->
<bean id="userRestService" class="com.alibaba.dubbo.demo.user.facade.UserRestServiceImpl">
    <property name="userService" ref="userService"/>
</bean>
<!--dubbo发布的rest服务-->
<dubbo:service interface="com.alibaba.dubbo.demo.user.facade.UserRestService" ref="userRestService"  protocol="rest" validation="true"/>

UserRestServiceImpl.java调用dubbo服务，实现rest服务的发布：

public class UserServiceImpl implements UserService {

    private final AtomicLong idGen = new AtomicLong();

    public User getUser(Long id) {
        return new User(id, "username" + id);
    }
    public Long registerUser(User user) {
//        System.out.println("Username is " + user.getName());
        return idGen.incrementAndGet();
    }

UserServiceImpl.java对接口的实现：

@Path("users")
@Consumes({MediaType.APPLICATION_JSON, MediaType.TEXT_XML})
@Produces({ContentType.APPLICATION_JSON_UTF_8, ContentType.TEXT_XML_UTF_8})
public class UserRestServiceImpl implements UserRestService {

    //使用dubbo服务
    private UserService userService;

    public void setUserService(UserService userService) {
        this.userService = userService;
    }

    @GET
    @Path("{id : \\d+}")
    public User getUser(@PathParam("id") Long id/*, @Context HttpServletRequest request*/) {
    //System.out.println("Client address from @Context injection: " + (request != null ? request.getRemoteAddr() : ""));
    //System.out.println("Client address from RpcContext: " + RpcContext.getContext().getRemoteAddressString());
        if (RpcContext.getContext().getRequest(HttpServletRequest.class) != null) {
            System.out.println("Client IP address from RpcContext: " + RpcContext.getContext().getRequest(HttpServletRequest.class).getRemoteAddr());
        }
        if (RpcContext.getContext().getResponse(HttpServletResponse.class) != null) {
            System.out.println("Response object from RpcContext: " + RpcContext.getContext().getResponse(HttpServletResponse.class));
        }
        return userService.getUser(id);
    }
}

服务消费

• 启动服务提供者
  使用测试用例DemoProvider.java启动，控制台出现以下信息，说明服务启动成功：

[20/05/17 11:32:02:002 CST] main  INFO container.Main:  [DUBBO] Dubbo SpringContainer started!, dubbo version: 2.0.0, current host: 127.0.0.1
[2017-05-20 11:32:02] Dubbo service server started!

查看服务管理界面（启动dobbo-admin工程）：

dubbo管理界面

可以看到发布的服务。

• 调用发布的restful
  调用地址：

http://localhost:8888/services/users/5.json  

返回数据：

{"id":5,"username":"username5"}