一、运行环境

本文运行环境：windows 7  + JDK1.8 + zookeeper-3.3.6 + dubbo-admin-2.5.4 （支持JDK 1.8）+ dubbo 2.5.3

所需工具可至资源页下载  –》点我下载

Demo下载

本文采用Dubbo与Zookeeper、Spring框架的整合。

主要是以下几个步骤：
1. 安装Zookeeper,启动；
2. 创建MAVEN项目，构建Dubbo+Zookeeper+Spring实现的简单Demo；
3. 安装Dubbo-admin，实现监控。

二、安装配置Zookeeper

1、tickTime：这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。
2、dataDir：是 Zookeeper 保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。
3、dataLogDir：是 Zookeeper 保存日志文件的目录
4、clientPort：这个端口就是客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。
在(D:\zookeeper-3.4.8\)目录下创建/tmp/zookeeper文件夹

启动

进入到bin文件夹下，在上面地址栏中输入cmd进入命令行，输入zkServer.cmd，若如图显示则代表启动成功。

三、创建MAVEN项目

（编译环境使用Intellij JDK版本为1.8）

项目结构：

dubbo-api : 存放公共接口；
dubbo-consumer :　调用远程服务；
dubbo-provider : 提供远程服务。

具体如图所示：

1、新建MAVEN项目 DubboDemo

导入所需要的jar包依赖。

1. <project xmlns=“http://maven.apache.org/POM/4.0.0” xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”
2. xsi:schemaLocation=“http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd”>
3. <modelVersion>4.0.0</modelVersion>
4. <groupId>DubboDemo</groupId>
5. <artifactId>DubboDemo</artifactId>
6. <packaging>pom</packaging>
7. <version>1.0-SNAPSHOT</version>
8. <modules>
9. <module>dubbo-api</module>
10. <module>dubbo-consumer</module>
11. <module>dubbo-provider</module>
12. </modules>
14. <name>DubboDemo Maven Webapp</name>
15. <url>http://maven.apache.org</url>
16. <properties>
17. <maven.compiler.source>1.8</maven.compiler.source>
18. <maven.compiler.target>1.8</maven.compiler.target>
19. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
20. <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
22. <!– spring版本号 –>
23. <spring.version>4.2.5.RELEASE</spring.version>
25. <!– mybatis版本号 –>
26. <mybatis.version>3.2.8</mybatis.version>
28. <!– mysql驱动版本号 –>
29. <mysql-driver.version>5.1.29</mysql-driver.version>
31. <!– log4j日志包版本号 –>
32. <slf4j.version>1.7.18</slf4j.version>
33. <log4j.version>1.2.17</log4j.version>
35. </properties>
36. <dependencies>
37. <dependency>
38. <groupId>junit</groupId>
39. <artifactId>junit</artifactId>
40. <version>3.8.1</version>
41. <scope>test</scope>
42. </dependency>
43. <!– 添加jstl依赖 –>
44. <dependency>
45. <groupId>jstl</groupId>
46. <artifactId>jstl</artifactId>
47. <version>1.2</version>
48. </dependency>
50. <dependency>
51. <groupId>javax</groupId>
52. <artifactId>javaee-api</artifactId>
53. <version>7.0</version>
54. </dependency>
56. <!– 添加junit4依赖 –>
57. <dependency>
58. <groupId>junit</groupId>
59. <artifactId>junit</artifactId>
60. <version>4.11</version>
61. <!– 指定范围，在测试时才会加载 –>
62. <scope>test</scope>
63. </dependency>
65. <!– 添加spring核心依赖 –>
66. <dependency>
67. <groupId>org.springframework</groupId>
68. <artifactId>spring-core</artifactId>
69. <version>${spring.version}</version>
70. </dependency>
71. <dependency>
72. <groupId>org.springframework</groupId>
73. <artifactId>spring-web</artifactId>
74. <version>${spring.version}</version>
75. </dependency>
76. <dependency>
77. <groupId>org.springframework</groupId>
78. <artifactId>spring-oxm</artifactId>
79. <version>${spring.version}</version>
80. </dependency>
81. <dependency>
82. <groupId>org.springframework</groupId>
83. <artifactId>spring-tx</artifactId>
84. <version>${spring.version}</version>
85. </dependency>
86. <dependency>
87. <groupId>org.springframework</groupId>
88. <artifactId>spring-jdbc</artifactId>
89. <version>${spring.version}</version>
90. </dependency>
91. <dependency>
92. <groupId>org.springframework</groupId>
93. <artifactId>spring-webmvc</artifactId>
94. <version>${spring.version}</version>
95. </dependency>
96. <dependency>
97. <groupId>org.springframework</groupId>
98. <artifactId>spring-context</artifactId>
99. <version>${spring.version}</version>
100. </dependency>
101. <dependency>
102. <groupId>org.springframework</groupId>
103. <artifactId>spring-context-support</artifactId>
104. <version>${spring.version}</version>
105. </dependency>
106. <dependency>
107. <groupId>org.springframework</groupId>
108. <artifactId>spring-aop</artifactId>
109. <version>${spring.version}</version>
110. </dependency>
112. <dependency>
113. <groupId>org.springframework</groupId>
114. <artifactId>spring-test</artifactId>
115. <version>${spring.version}</version>
116. </dependency>
118. <!– 添加mybatis依赖 –>
119. <dependency>
120. <groupId>org.mybatis</groupId>
121. <artifactId>mybatis</artifactId>
122. <version>${mybatis.version}</version>
123. </dependency>
125. <!– 添加mybatis/spring整合包依赖 –>
126. <dependency>
127. <groupId>org.mybatis</groupId>
128. <artifactId>mybatis-spring</artifactId>
129. <version>1.2.2</version>
130. </dependency>
132. <!– 添加mysql驱动依赖 –>
133. <dependency>
134. <groupId>mysql</groupId>
135. <artifactId>mysql-connector-java</artifactId>
136. <version>${mysql-driver.version}</version>
137. </dependency>
138. <!– 添加数据库连接池依赖 –>
139. <dependency>
140. <groupId>commons-dbcp</groupId>
141. <artifactId>commons-dbcp</artifactId>
142. <version>1.2.2</version>
143. </dependency>
145. <!– 添加fastjson –>
146. <dependency>
147. <groupId>com.alibaba</groupId>
148. <artifactId>fastjson</artifactId>
149. <version>1.2.22</version>
150. </dependency>
152. <!– 添加日志相关jar包 –>
153. <dependency>
154. <groupId>log4j</groupId>
155. <artifactId>log4j</artifactId>
156. <version>${log4j.version}</version>
157. </dependency>
158. <dependency>
159. <groupId>org.slf4j</groupId>
160. <artifactId>slf4j-api</artifactId>
161. <version>${slf4j.version}</version>
162. </dependency>
163. <dependency>
164. <groupId>org.slf4j</groupId>
165. <artifactId>slf4j-log4j12</artifactId>
166. <version>${slf4j.version}</version>
167. </dependency>
169. <!– log end –>
170. <!– 映入JSON –>
171. <dependency>
172. <groupId>org.codehaus.jackson</groupId>
173. <artifactId>jackson-mapper-asl</artifactId>
174. <version>1.9.13</version>
175. </dependency>
176. <!– https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core –>
177. <dependency>
178. <groupId>com.fasterxml.jackson.core</groupId>
179. <artifactId>jackson-core</artifactId>
180. <version>2.8.0</version>
181. </dependency>
182. <!– https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-databind –>
183. <dependency>
184. <groupId>com.fasterxml.jackson.core</groupId>
185. <artifactId>jackson-databind</artifactId>
186. <version>2.8.0</version>
187. </dependency>
189. <dependency>
190. <groupId>commons-fileupload</groupId>
191. <artifactId>commons-fileupload</artifactId>
192. <version>1.3.1</version>
193. </dependency>
195. <dependency>
196. <groupId>commons-io</groupId>
197. <artifactId>commons-io</artifactId>
198. <version>2.4</version>
199. </dependency>
201. <dependency>
202. <groupId>commons-codec</groupId>
203. <artifactId>commons-codec</artifactId>
204. <version>1.9</version>
205. </dependency>
207. <dependency>
208. <groupId>org.quartz-scheduler</groupId>
209. <artifactId>quartz</artifactId>
210. <version>2.2.1</version>
211. </dependency>
213. <dependency>
214. <groupId>org.apache.shiro</groupId>
215. <artifactId>shiro-core</artifactId>
216. <version>1.3.2</version>
217. </dependency>
218. <dependency>
219. <groupId>org.apache.shiro</groupId>
220. <artifactId>shiro-web</artifactId>
221. <version>1.3.2</version>
222. </dependency>
223. <dependency>
224. <groupId>org.apache.shiro</groupId>
225. <artifactId>shiro-spring</artifactId>
226. <version>1.3.2</version>
227. </dependency>
228. <dependency>
229. <groupId>org.apache.shiro</groupId>
230. <artifactId>shiro-ehcache</artifactId>
231. <version>1.3.2</version>
232. </dependency>
233. <dependency>
234. <groupId>org.apache.zookeeper</groupId>
235. <artifactId>zookeeper</artifactId>
236. <version>3.4.9</version>
237. </dependency>
238. <!– dubbo –>
239. <dependency>
240. <groupId>com.alibaba</groupId>
241. <artifactId>dubbo</artifactId>
242. <version>2.5.3</version>
243. <exclusions>
244. <exclusion>
245. <groupId>org.springframework</groupId>
246. <artifactId>spring</artifactId>
247. </exclusion>
248. </exclusions>
249. </dependency>
250. <dependency>
251. <groupId>com.101tec</groupId>
252. <artifactId>zkclient</artifactId>
253. <version>0.10</version>
254. </dependency>
255. <dependency>
256. <groupId>DubboDemo</groupId>
257. <artifactId>dubbo-api</artifactId>
258. <version>1.0-SNAPSHOT</version>
259. </dependency>
261. </dependencies>
262. <build>
263. <finalName>DubboDemo</finalName>
264. </build>
265. </project>

2、在此项目下新建MAVEN项目：dubbo-api
创建接口DemoService

1. package com.zh.dubbo.demo;
3. import java.util.List;
5. public interface DemoService {
6. List<String> getPermissions(Long id);
7. }

（若不能创建java文件，则在java文件夹点击右键，选择Mark Directory As —–Source Root即可）
3、创建dubbo-provider的MAVEN项目实现公共接口

1. package com.zh.dubbo.demo.impl;
3. import com.zh.dubbo.demo.DemoService;
5. import java.util.ArrayList;
6. import java.util.List;
8. public class DemoServiceImpl implements DemoService {
9. public List<String> getPermissions(Long id) {
10. List<String> demo = new ArrayList<String>();
11. demo.add(String.format(“Permission_%d”, id – 1));
12. demo.add(String.format(“Permission_%d”, id));
13. demo.add(String.format(“Permission_%d”, id + 1));
14. return demo;
15. }
16. }

添加Spring配置声明文件 Provider.xml  此文件放在target/classes文件夹下

1. <?xml version=“1.0” encoding=“UTF-8”?>
2. <beans xmlns=“http://www.springframework.org/schema/beans”
3. xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”
4. xmlns:dubbo=“http://code.alibabatech.com/schema/dubbo”
5. xsi:schemaLocation=“http://www.springframework.org/schema/beans
6. http://www.springframework.org/schema/beans/spring-beans.xsd
7. http://code.alibabatech.com/schema/dubbo
8. http://code.alibabatech.com/schema/dubbo/dubbo.xsd”>
9. <!–定义了提供方应用信息，用于计算依赖关系；在 dubbo-admin 或 dubbo-monitor 会显示这个名字，方便辨识–>
10. <dubbo:application name=“demotest-provider” owner=“programmer” organization=“dubbox”/>
11. <!–使用 zookeeper 注册中心暴露服务，注意要先开启 zookeeper–>
12. <dubbo:registry address=“zookeeper://localhost:2181”/>
13. <!– 用dubbo协议在20880端口暴露服务 –>
14. <dubbo:protocol name=“dubbo” port=“20880” />
15. <!–使用 dubbo 协议实现定义好的 api.PermissionService 接口–>
16. <dubbo:service interface=“com.zh.dubbo.demo.DemoService” ref=“demoService” protocol=“dubbo” />
17. <!–具体实现该接口的 bean–>
18. <bean id=“demoService” class=“com.zh.dubbo.demo.impl.DemoServiceImpl”/>
19. </beans>

添加启动远程服务类Provider.class：

1. package com.zh.dubbo.demo.impl;
3. import org.springframework.context.support.ClassPathXmlApplicationContext;
4. import java.io.IOException;
6. public class Provider {
7. public static void main(String[] args) throws IOException {
8. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(“provider.xml”);
9. System.out.println(context.getDisplayName() + “: here”);
10. context.start();
11. System.out.println(“服务已经启动…”);
12. System.in.read();
13. }
14. }

4、创建dubbo-consumer的MAVEN项目添加Spring配置声明文件 consumer.xml  此文件放在target/classes文件夹下

1. <?xml version=“1.0” encoding=“UTF-8”?>
2. <beans xmlns=“http://www.springframework.org/schema/beans”
3. xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”
4. xmlns:dubbo=“http://code.alibabatech.com/schema/dubbo”
5. xsi:schemaLocation=“http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
6. http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd”>
7. <dubbo:application name=“demotest-consumer” owner=“programmer” organization=“dubbox”/>
8. <!–向 zookeeper 订阅 provider 的地址，由 zookeeper 定时推送–>
9. <dubbo:registry address=“zookeeper://localhost:2181”/>
10. <!–使用 dubbo 协议调用定义好的 api.PermissionService 接口–>
11. <dubbo:reference id=“permissionService” interface=“com.zh.dubbo.demo.DemoService”/>
12. </beans>

创建Consumer类， 启动Consumer,调用远程服务

1. package com.zh.dubbo.consumer;
3. import com.zh.dubbo.demo.DemoService;
4. import org.springframework.context.support.ClassPathXmlApplicationContext;
6. public class Consumer {
7. public static void main(String[] args) {
8. //测试常规服务
9. ClassPathXmlApplicationContext context =
10. new ClassPathXmlApplicationContext(“consumer.xml”);
11. context.start();
12. System.out.println(“consumer start”);
13. DemoService demoService = context.getBean(DemoService.class);
14. System.out.println(“consumer”);
15. System.out.println(demoService.getPermissions(1L));
16. }
17. }

5、运行项目，先确保provider已被运行后再启动consumer模块
四、Dubbo管理控制台配置

1、把dubbo-admin.war放到tomcat的webapps目录下

2、启动tomcat

3、在webapps文件夹下找到dubbo-admin文件夹，进入WEB-INF文件夹，打开dubbo.properties，可以看到账户密码分别为root guest

4、在启动zookeeper后，然后再启动tomcat，访问地址：http://localhost:8080/dubbo-admin/

输入帐号密码后即可登录到后台

–结束–