基于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\\datadataLogDir=E:\\zookeeper-3.5.1-alpha\\logs
其它不用改动,需要注意的是clientPort=2181。这个就是dubbo连接注册中心需要使用的端口。
启动进入zookeeper\bin目录,运行zkServer.cmd:
运行zookeeper
出现以下信息,启动成功:
2017-05-2010:53:29,604[myid:]-INFO[main:NIOServerCnxnFactory@673]-ConfiguringNIOconnectionhandlerwith10ssessionlessconnectiontimeout,2selectorthread(s),16workerthreads,and64kBdirectbuffers.2017-05-2010:53:29,609[myid:]-INFO[main:NIOServerCnxnFactory@686]-bindingtoport0.0.0.0/0.0.0.0:2181dubbo示例demo导入
dubbo官方自带的示例,包括三个工程,api\product(服务提供者)和consumer(服务消费者)。
导入后的项目结构:
dubbo示例项目结构
demo解剖dubbo-demo-api:定义的服务接口
dubbo-demo-provider:服务发布
dubbo-demo-consumer:服务消费
<!--连接本地注册中心--><dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>服务接口
publicinterfaceUserService{UsergetUser(Longid);LongregisterUser(Useruser);}
定义了一个用户接口,两个方法。
服务发布<!--对接口的实现--><beanid="userService"class="com.alibaba.dubbo.demo.user.UserServiceImpl"/><!--dubbo服务--><dubbo:serviceinterface="com.alibaba.dubbo.demo.user.UserService"ref="userService"protocol="dubbo"group="xmlConfig"/><!--rest服务实现--><beanid="userRestService"class="com.alibaba.dubbo.demo.user.facade.UserRestServiceImpl"><propertyname="userService"ref="userService"/></bean><!--dubbo发布的rest服务--><dubbo:serviceinterface="com.alibaba.dubbo.demo.user.facade.UserRestService"ref="userRestService"protocol="rest"validation="true"/>
UserRestServiceImpl.java调用dubbo服务,实现rest服务的发布:
publicclassUserServiceImplimplementsUserService{privatefinalAtomicLongidGen=newAtomicLong();publicUsergetUser(Longid){returnnewUser(id,"username"+id);}publicLongregisterUser(Useruser){//System.out.println("Usernameis"+user.getName());returnidGen.incrementAndGet();}
UserServiceImpl.java对接口的实现:
@Path("users")@Consumes({MediaType.APPLICATION_JSON,MediaType.TEXT_XML})@Produces({ContentType.APPLICATION_JSON_UTF_8,ContentType.TEXT_XML_UTF_8})publicclassUserRestServiceImplimplementsUserRestService{//使用dubbo服务privateUserServiceuserService;publicvoidsetUserService(UserServiceuserService){this.userService=userService;}@GET@Path("{id:\\d+}")publicUsergetUser(@PathParam("id")Longid/*,@ContextHttpServletRequestrequest*/){//System.out.println("Clientaddressfrom@Contextinjection:"+(request!=null?request.getRemoteAddr():""));//System.out.println("ClientaddressfromRpcContext:"+RpcContext.getContext().getRemoteAddressString());if(RpcContext.getContext().getRequest(HttpServletRequest.class)!=null){System.out.println("ClientIPaddressfromRpcContext:"+RpcContext.getContext().getRequest(HttpServletRequest.class).getRemoteAddr());}if(RpcContext.getContext().getResponse(HttpServletResponse.class)!=null){System.out.println("ResponseobjectfromRpcContext:"+RpcContext.getContext().getResponse(HttpServletResponse.class));}returnuserService.getUser(id);}}服务消费
启动服务提供者
使用测试用例DemoProvider.java启动,控制台出现以下信息,说明服务启动成功:
[20/05/1711:32:02:002CST]mainINFOcontainer.Main:[DUBBO]DubboSpringContainerstarted!,dubboversion:2.0.0,currenthost:127.0.0.1
[2017-05-2011:32:02]Dubboserviceserverstarted!
查看服务管理界面(启动dobbo-admin工程):
dubbo管理界面
可以看到发布的服务。
调用发布的restful
调用地址:
http://localhost:8888/services/users/5.json
返回数据:
{"id":5,"username":"username5"}
本文首发于http://www.jianshu.com/p/fcc567904290
声明:本站所有文章资源内容,如无特殊说明或标注,均为采集网络资源。如若本站内容侵犯了原著者的合法权益,可联系本站删除。