Dubbo與Zookeeper、SpringMVC整合和使用（個人入門demo）

時間 2019-11-12

標籤 dubbo zookeeper springmvc 整合使用個人入門 demo 欄目 Dubbo 简体版

原文原文鏈接

開發工具html	MyEclipse 10.7git
JDKgithub	1.7web
容器spring	Tomcat 8(運行dubbo)apache
zookeeper版本windows	zookeeper-3.4.6tomcat
dubboapp	dubbo-admin-2.5.3webapp

dubbo-admin-2.5.3下載地址：http://pan.baidu.com/s/1bozCMzP

zookeeper下載地址：http://www-eu.apache.org/dist/zookeeper/zookeeper-3.4.6/

Dubbo+Zookeeper 的下載安裝配置啓動

1.dubbo-admin-2.5.3下載完成後。放在webapps文件夾下面。先把默認的tomcat的ROOT項目備份後移除。將dubbo-admin-2.5.3.war改爲ROOT.war 備用

2.zookeeper下載後解壓安裝便可。windows安裝完成後以下圖

進入到conf裏面，會看到zoo_sample.cfg文件。複製一個修改成zoo.cfg，修改相關配置內容

# The number of milliseconds of each tick

tickTime=2000

# The number of ticks that the initial

# synchronization phase can take

initLimit=10

# The number of ticks that can pass between

# sending a request and getting an acknowledgement

syncLimit=5

# the directory where the snapshot is stored.

# do not use /tmp for storage, /tmp here is just

# example sakes.

dataDir=/tmp/zookeeper

# the port at which the clients will connect

#這塊是設置zookeeper的端口。默認2181

clientPort=2181

# the maximum number of client connections.

# increase this if you need to handle more clients

#maxClientCnxns=60

# Be sure to read the maintenance section of the

# administrator guide before turning on autopurge.

# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance

# The number of snapshots to retain in dataDir

#autopurge.snapRetainCount=3

# Purge task interval in hours

# Set to "0" to disable auto purge feature

#autopurge.purgeInterval=1

到bin文件夾下面。啓動zookeeper，windows 點擊zkServer.cmd便可

3.能夠啓動tomcat了。這樣直接訪問就能看到dubbo的頁面。要否則dubbo啓動會報錯。第一次入門的話建議就用默認的端口配置便可。默認用戶 root 密碼 root

登陸成功之後看到以下頁面

以上就是dubbo+zookeeper的配置和啓動。下面開始Java代碼的編寫

整合Dubbo+Zookeeper+SpringMVC

1.建立myDubbo項目爲主項目，結構圖以下 myC P S後續才建立，剛開始是沒有的。

POM.XML配置以下

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

<artifactId>mydubbo</artifactId>

注意這裏。打包爲POM，分佈式系統的第一步

<version>0.0.1-SNAPSHOT</version>

<name>mydubbo</name>

<url>http://maven.apache.org</url>

<spring.version>3.2.4.RELEASE</spring.version>

</properties>

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<groupId>org.springframework</groupId>

<artifactId>spring</artifactId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-core</artifactId>

<version>${spring.version}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-context</artifactId>

<version>${spring.version}</version>

</dependency>

</dependencies>

<build>

<finalName>mydubbo</finalName>

</build>

建立子項目後自動會加載。剛開始是沒有的

<module>myService</module>

<module>myProvider</module>

<module>myConsumer</module>

</modules>

</project>

2.建立服務提供商子項目，MyEclipse操做以下圖示意對mydubbo項目鼠標右鍵new或者maven插件直接建立maven module項目，填寫子項目名稱。有的若是不選種Create a simple project 自定義建立會報錯。選擇則不會。根據實際狀況來肯定是否選擇

3.建立3個子項目分別爲 myService(服務商(接口)，模塊提供方) myProvider(供應者，給dubbo zookeeper註冊暴露接口) myConsumer

myService 項目相關配置

pom配置
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>mydubbo</artifactId>
<groupId>com</groupId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<name>myService</name>
10. <artifactId>myService</artifactId>
11. <packaging>jar</packaging>

</project>

新建一個接口類

13. package com.xiaoshuai;

15. public interface HelloService {

16. public String speakHello(String name);

}

以上工做完成後，進行maven install

myProvider項目相關配置

pom配置
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>mydubbo</artifactId>
<groupId>com</groupId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>myProvider</artifactId>

10. 引用接口服務項目子項目maven install 爲jar

11. <dependencies>
12. <dependency>
13. <groupId> myService </groupId>
14. <artifactId>myService</artifactId>
15. <version>0.0.1-SNAPSHOT</version>
16. </dependency>
17. </dependencies>

</project>

18. 實現接口服務者

19. package com.xiaoshuai.impl;

22. import com.xiaoshuai.HelloService;

23. public class HelloServiceImpl implements HelloService{

24.
25. public String speakHello(String name) {
26. return "你好:"+name+"歡迎查閱小帥丶博客";
27. }
28.

29. }

將實現類接口類暴露給dubbo+zookeeper 在myProvider建立provider.xml 內容以下

31. <?xml version="1.0" encoding="UTF-8"?>

32. <beans xmlns="http://www.springframework.org/schema/beans"

33. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
34. xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
35. xsi:schemaLocation="http://www.springframework.org/schema/beans
36. http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
37.
38.
39. <dubbo:application name="hello-provider" />
40.
41.
42. <dubbo:registry address="zookeeper://127.0.0.1:2181" />
43.
44.
45. <dubbo:protocol name="dubbo" port="20880" />
46.
47.
48. <dubbo:service interface="com.xiaoshuai.HelloService" ref="helloService" />
49.
50.
51. <bean id="helloService" class="com.xiaoshuai.impl.HelloServiceImpl" />
52.

53. </beans>

須要建立一個Java類寫個方法去加載provider.xml 註冊到dubbo + zookeeper

55. package com.xiaoshuai.impl;

56. import org.springframework.context.support.ClassPathXmlApplicationContext;

58. public class ProviderServer {

59. public static void main(String[] args){
60. try {
61. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");
62. context.start();
63. System.in.read();
64. } catch (Exception e) {
65. e.printStackTrace();
66. }
67. }

68. }

能夠運行。啓動該提供者服務，編寫消費者。
能夠看到dubbo 提供者服務已經註冊

myConsumer 項目相關配置

pom配置
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>mydubbo</artifactId>
<groupId>com</groupId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>myConsumer</artifactId>
10. <dependencies>
11. <dependency>
12. <groupId>com</groupId>
13. <artifactId>myService</artifactId>
14. <version>0.0.1-SNAPSHOT</version>
15. </dependency>
16. </dependencies>

</project>

消費者進行訂閱provider的服務，也就是須要去zookeeper讀取加載服務，那就須要建立一個consumer.xml去加載zookeeper

18. <?xml version="1.0" encoding="UTF-8"?>

19. <beans xmlns="http://www.springframework.org/schema/beans"

20. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
21. xsi:schemaLocation="http://www.springframework.org/schema/beans
22. http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
23.
24. <dubbo:application name="hello-consumer" />
25.
26. <dubbo:registry address="zookeeper://127.0.0.1:2181" />
27.
28. <dubbo:reference id="helloService" interface="com.xiaoshuai.HelloService" />

29. </beans>

建立一個消費者方法，進行調用ConsumerClient

31. package com.xiaoshuai;

33. import org.springframework.context.support.ClassPathXmlApplicationContext;

35. public class ConsumerClient {

36. public static void main(String[] args) {
37. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");
38. HelloService helloService = (HelloService) context.getBean("helloService");
39. String result = helloService.speakHello("xiaoshuai");
40. System.out.println(result);
41. }

42. }