Dubbo 是阿里开源的分布式 RPC 通信框架, 目前在国内使用范围比较广, 本文详细描述 Dubbo 的入门级使用过程, 希望能够给想了解 dubbo 的人提供一点帮助
前期准备 (括号内为我使用的版本)
- JDK 1.5+(1.8.0_u161)
- eclipse(4.7.2)
- zookeeper(3.4.11)
- maven(3.5.2)
我们在 eclipse 中创建 maven 项目, 命名为 dubbo-demo
创建三个子模块, 分别为 dubbo-provider,dubbo-consumer,dubbo-api, 从命名可以看出这三个模块分别为服务提供者, 服务消费者和 API 接口项目
项目初始化结构
在 dubbo-demo 的 pom.xml 中添加公共依赖, 主要是添加 dubbo 和 zookeeper 客户端依赖代码如下:
- <dependencies>
- <!-- dubbo 当前最新版 -->
- <dependency>
- <groupId>com.alibaba</groupId>
- <artifactId>dubbo</artifactId>
- <version>2.6.0</version>
- </dependency>
- <!-- zookeeper 客户端 -->
- <dependency>
- <groupId>com.101tec</groupId>
- <artifactId>zkclient</artifactId>
- <version>0.10</version>
- </dependency>
- </dependencies>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-compiler-plugin</artifactId>
- <version>3.7.0</version>
- <configuration>
- <source>1.8</source>
- <target>1.8</target>
- <encoding>utf-8</encoding>
- </configuration>
- </plugin>
- </plugins>
- </build>
首先我们先处理 api, 此项目为其他两个项目提供接口, 保证生产者和消费者所使用的接口统一我们在 dubbo-api 项目中创建包 com.aotian.demo.dubbo.api, 并添加 DemoService 接口
API 项目结构及代码
接口类定义后我们需要在服务端和客户端项目中引用, 保证两端接口一致, 分别在两个项目的 pom.xml 中添加如下代码:
- <dependencies>
- <!-- API 接口引用 -->
- <dependency>
- <groupId>com.aotian</groupId>
- <artifactId>dubbo-api</artifactId>
- <version>0.0.1-SNAPSHOT</version>
- </dependency>
- </dependencies>
引用接口之后, 我们需要在服务端添加接口实现类, 在 dubbo-provider 项目中创建包 com.aotian.demo.dubbo.provider, 并添加 DemoService 接口的实现类
服务端项目结构及代码实现. png
接口实现类添加后, 我们需要将其注册到注册中心, 只有这样, 其他应用才有可能请求到, 接下来我们在 src / main / resources 下创建 dubbo-provider.xml 文件, 用于配置 dubbo 服务端注册, 代码如下:
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans.xsd
- http://code.alibabatech.com/schema/dubbo
- http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
- <!--dubbo 应用程序命名 -->
- <dubbo:application name="dubbo-demo-provider"/>
- <!--dubbo 注册地址 -->
- <dubbo:registry address="zookeeper://localhost:2181"/>
- <!--dubbo 协议地址 -->
- <dubbo:protocol name="dubbo" port="20880"/>
- <!-- 接口声明 -->
- <dubbo:service interface="com.aotian.demo.dubbo.api.DemoService" ref="demoService"/>
- <bean id="demoService" class="com.aotian.demo.dubbo.provider.DemoServiceImpl"/>
- </beans>
接下来我们准备对服务端进行注册, 所以需要准备注册中心, 这里用的是 zookeeper, 官网下载 zookeeper 后解压, 将 conf 文件夹下的 zoo_sample.cfg 重命名为 zoo.cfg, 之后在命令提示符下切换至 bin 目录下, 执行 .\zkServer.cmd, 看到如下提示后表示启动成功
2018-03-13 23:12:59,007 [myid:] - INFO [main:NIOServerCnxnFactory@89] - binding to port 0.0.0.0/0.0.0.0:2181
启动服务端本 Demo 用于测试, 所以使用 main 方法加载的形式加载服务端, 实际使用过程中可能会在 web 环境中使用在服务端下添加 Provider.java 并执行 main 方法即可, 其他 main 方法实现如下:
- public static void main(String[] args) throws IOException {
- ClassPathXmlApplicationContext context
- = new ClassPathXmlApplicationContext("classpath:dubbo-provider.xml");
- context.start();
- // 阻塞当前进程, 否则程序会直接停止
- System.in.read();
- }
处理好服务端之后, 我们再进行客户端的处理, 首先添加客户端配置文件 dubbo-consumer.xml 放于 src / main / resources 下, 内容与服务端相似, 只不过不需要暴露接口, 而是引用接口, 代码如下:
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans.xsd
- http://code.alibabatech.com/schema/dubbo
- http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
- <!--dubbo 应用程序命名 -->
- <dubbo:application name="dubbo-demo-provider"/>
- <!--dubbo 注册地址 -->
- <dubbo:registry address="zookeeper://localhost:2181"/>
- <!-- 接口引用 -->
- <dubbo:reference interface="com.aotian.demo.dubbo.api.DemoService" id="demoService"/>
- </beans>
处理完配置文件, 我们可以在客户端进行测试了, 在 src / main / java 下创建包 com.aotian.demo.dubbo.api, 并创建文件 consumer.java,main 方法代码如下:
- public static void main(String[] args) {
- ClassPathXmlApplicationContext context
- = new ClassPathXmlApplicationContext("classpath:dubbo-consumer.xml");
- context.start();
- String username = "aotian";
- DemoService demoService = (DemoService) context.getBean("demoService");
- System.out.println(demoService.changeUsername(username));
- }
执行后便可在控制台查看结果, 如下图所示, 表示客户端和服务端已经成功调用
执行结果
示例代码: https://github.com/Aotian-GitHub/dubbo-basic-demo.git
来源: http://www.jianshu.com/p/b492ef5d4b98