本文使用官方項目示例,基于dubbox發(fā)布restful服務(wù)辕宏。jdk,eclipse砾莱、maven神馬環(huán)境的就不講了瑞筐,自行baidu之。
dubbox下載恤磷、編譯
下載地址:https://github.com/dangdangdotcom/dubbox
下載方式可以用git下載面哼,也可以打包下載野宜。下載之后,用maven導(dǎo)入(eclipse->import->Maven)魔策。
使用maven打包匈子,版本2.8.4。
zookeeper安裝
本文使用的是單節(jié)點的注冊中心闯袒,在實際項目中需要考慮高可用虎敦,需要搭建集群注冊中心,集群環(huán)境搭建在以后的文章中會講到政敢。
下載
https://zookeeper.apache.org/
這里用的是zookeeper-3.5.1-alpha版本其徙,下載之后,解壓到本地喷户。
配置
進入conf目錄,修改dataDir(數(shù)據(jù))和dataLogDir(日志)文件目錄到你本地的目錄:
dataDir=E:\\zookeeper-3.5.1-alpha\\data
dataLogDir=E:\\zookeeper-3.5.1-alpha\\logs
其它不用改動唾那,需要注意的是clientPort=2181。這個就是dubbo連接注冊中心需要使用的端口褪尝。
啟動
進入zookeeper\bin目錄闹获,運行zkServer.cmd:
出現(xiàn)以下信息,啟動成功:
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官方自帶的示例河哑,包括三個工程避诽,api\product(服務(wù)提供者)和consumer(服務(wù)消費者)。
導(dǎo)入后的項目結(jié)構(gòu):
demo解剖
dubbo-demo-api:定義的服務(wù)接口
dubbo-demo-provider:服務(wù)發(fā)布
dubbo-demo-consumer:服務(wù)消費
配置文件
<!--連接本地注冊中心-->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
服務(wù)接口
public interface UserService {
User getUser(Long id);
Long registerUser(User user);
}
定義了一個用戶接口璃谨,兩個方法沙庐。
服務(wù)發(fā)布
<!--對接口的實現(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ù)實現(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ù),實現(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對接口的實現(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ù)消費
- 啟動服務(wù)提供者
使用測試用例DemoProvider.java啟動佳吞,控制臺出現(xiàn)以下信息拱雏,說明服務(wù)啟動成功:
[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ù)管理界面(啟動dobbo-admin工程):
可以看到發(fā)布的服務(wù)。
- 調(diào)用發(fā)布的restful
調(diào)用地址:
http://localhost:8888/services/users/5.json
返回數(shù)據(jù):
{"id":5,"username":"username5"}