基於dubbo快速發布restful服務
本文使用官方項目示例，基於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:[email protected]] - 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:[email protected]
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"}
本文首發於http://www.jianshu.com/p/fcc567904290
本文出自 “開源框架、分布式架構研究” 博客，請務必保留此出處http://csblog.blog.51cto.com/154952/1927994
基於dubbo快速發布restful服務