基于dubbo快速發(fā)布restful服務(wù)

     本文使用官方項(xiàng)目示例，基于dubbox發(fā)布restful服務(wù)。jdk，eclipse、maven神馬環(huán)境的就不講了，自行baidu之。

dubbox下載、編譯

下載地址：https://github.com/dangdangdotcom/dubbox
下載方式可以用git下載，也可以打包下載。下載之后，用maven導(dǎo)入（eclipse->import->Maven)。dubbo項(xiàng)目結(jié)構(gòu):

使用maven打包，版本2.8.4。

zookeeper安裝

本文使用的是單節(jié)點(diǎn)的注冊(cè)中心，在實(shí)際項(xiàng)目中需要考慮高可用，需要搭建集群注冊(cè)中心，集群環(huán)境搭建在以后的文章中會(huì)講到。

下載

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

配置

進(jìn)入conf目錄,修改dataDir（數(shù)據(jù)）和dataLogDir（日志）文件目錄到你本地的目錄：

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

其它不用改動(dòng)，需要注意的是clientPort=2181。這個(gè)就是dubbo連接注冊(cè)中心需要使用的端口。

啟動(dòng)

進(jìn)入zookeeper\bin目錄，運(yùn)行zkServer.cmd：

運(yùn)行zookeeper

出現(xiàn)以下信息，啟動(dòng)成功：

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導(dǎo)入

dubbo官方自帶的示例，包括三個(gè)工程，api\product（服務(wù)提供者）和consumer（服務(wù)消費(fèi)者）。
導(dǎo)入后的項(xiàng)目結(jié)構(gòu)：

dubbo示例項(xiàng)目結(jié)構(gòu)

demo解剖

dubbo-demo-api：定義的服務(wù)接口
dubbo-demo-provider：服務(wù)發(fā)布
dubbo-demo-consumer:服務(wù)消費(fèi)

配置文件

<!--連接本地注冊(cè)中心--><dubbo:registry address="zookeeper://127.0.0.1:2181"/>

服務(wù)接口

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

定義了一個(gè)用戶接口，兩個(gè)方法。

服務(wù)發(fā)布

<!--對(duì)接口的實(shí)現(xiàn)-->
<bean id="userService" class="com.alibaba.dubbo.demo.user.UserServiceImpl" />
<!--dubbo服務(wù)-->
<dubbo:service interface="com.alibaba.dubbo.demo.user.UserService" ref="userService"  protocol="dubbo" group="xmlConfig"/>
<!--rest服務(wù)實(shí)現(xiàn)-->
<bean id="userRestService" class="com.alibaba.dubbo.demo.user.facade.UserRestServiceImpl">
    <property name="userService" ref="userService"/></bean>
<!--dubbo發(fā)布的rest服務(wù)-->
<dubbo:service interface="com.alibaba.dubbo.demo.user.facade.UserRestService" ref="userRestService"  protocol="rest" validation="true"/>

UserRestServiceImpl.java調(diào)用dubbo服務(wù)，實(shí)現(xiàn)rest服務(wù)的發(fā)布：

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對(duì)接口的實(shí)現(xiàn)：

@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服務(wù)
    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);
    }
}

服務(wù)消費(fèi)

• 啟動(dòng)服務(wù)提供者
  使用測(cè)試用例DemoProvider.java啟動(dòng)，控制臺(tái)出現(xiàn)以下信息，說(shuō)明服務(wù)啟動(dòng)成功：

  [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!

查看服務(wù)管理界面（啟動(dòng)dobbo-admin工程）：

dubbo管理界面

可以看到發(fā)布的服務(wù)。

• 調(diào)用發(fā)布的restful
  調(diào)用地址：

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

  返回?cái)?shù)據(jù)：

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

本文首發(fā)于http://www.jianshu.com/p/fcc567904290