摘要：
1、 本文的目的是学习如何通过Dubbo的官方演示构建一个简单的Dubbo程序，包括服务器、客户端、界面等。
一、本文目的
通过Dubbo的官方Demo介绍，学会搭建一个简单的Dubbo程序，包括服务端、客户端、接口等。
二、Demo概况
1、Demo分为三个项目
a) dubbo-demo-api：服务接口，服务端和客户端都需要引用
b)dubbo-demo-provider：包含对服务接口的引用和实现
c)dubbo-demo-consumer：包含对服务接口的引用和使用
2、Demo三个项目的父项目是：dubbo-demo
三、Demo引用的Jar包说明
- JDK：1.6
- Dubbo版2号：2.5.4-SNAPSHOT
- Spring版本号：3.2.16.RELEASE<
- ZooKeeper版本号：3.3.3
- Jedis版本号：2.1.0
- Netty版本号：3.2.5.Final
- 其它：参考pom.xml https://github.com/alibaba/dubbo/blob/master/pom.xml
四、Demo代码说明
1、服务接口：dubbo-demo-api
本项目只包含一个接口及一个接口方法
1 2 3 4 5 6 7 | packagecom.alibaba.dubbo.demo;publicinterfaceDemoService { String sayHello(String name);} |
2、服务实现：dubbo-demo-provider
a) 服务端包含了对dubbo-demo-api的引用及实现
1 2 3 4 5 | <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo-demo-api</artifactId> <version>${project.parent.version}</version> </dependency> |
b) 配置文件（dubbo-demo-provider.xml）
其中<dubbo:servcie> 定义一个对外提供的接口，通过ref关联到具体的实现代码
1 2 3 4 5 6 7 8 9 10 11 | xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.5.xsd <beanid="demoService"class="com.alibaba.dubbo.demo.provider.DemoServiceImpl"/> <dubbo:serviceinterface="com.alibaba.dubbo.demo.DemoService"ref="demoService"/> </beans> |
c) 实现代码（DemoServiceImpl）
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | packagecom.alibaba.dubbo.demo.provider;importjava.text.SimpleDateFormat;importjava.util.Date;importcom.alibaba.dubbo.demo.DemoService;importcom.alibaba.dubbo.rpc.RpcContext;publicclassDemoServiceImpl implementsDemoService { publicString sayHello(String name) { System.out.println("["+ newSimpleDateFormat("HH:mm:ss").format(newDate()) + "] Hello "+ name + ", request from consumer: "+ RpcContext.getContext().getRemoteAddress()); return"Hello "+ name + ", response form provider: "+ RpcContext.getContext().getLocalAddress(); } } |
3、服务消费：dubbo-demo-consumer
a) 消费端也包含了对dubbo-demo-api的引用
1 2 3 4 5 | <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo-demo-api</artifactId> <version>${project.parent.version}</version> </dependency> |
b) 配置文件（dubbo-demo-consumer.xml）
通过<dubbo:reference>引用一个服务接口，客户端使用远程接口方法就和调用本地方法一致
1 2 3 4 5 6 7 8 9 | xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.5.xsd <dubbo:referenceid="demoService"interface="com.alibaba.dubbo.demo.DemoService"/></beans> |
c) 消费端调用代码：DemoAction.java
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 | packagecom.alibaba.dubbo.demo.consumer;importjava.text.SimpleDateFormat;importjava.util.Date;importcom.alibaba.dubbo.demo.DemoService;publicclassDemoAction { privateDemoService demoService; publicvoidsetDemoService(DemoService demoService) { this.demoService = demoService; } publicvoidstart() throwsException { for(inti = 0; i < Integer.MAX_VALUE; i ++) { try{ String hello = demoService.sayHello("world"+ i); System.out.println("["+ newSimpleDateFormat("HH:mm:ss").format(newDate()) + "] "+ hello); } catch(Exception e) { e.printStackTrace(); } Thread.sleep(2000); } }} |