Dubbo+Zookeeper+Spring整合入门Demo
2017-09-21 16:43
471 查看
接手一个新项目用到了dubbo,所以学习了一下,上网找了很多资料,踩了许多坑,在此把自己整合的过程记录一下。
感谢三位的文章给了我很多帮助:
http://blog.csdn.net/mg0324/article/details/49385233 http://blog.csdn.net/hejingyuan6/article/details/47403299 http://blog.csdn.net/noaman_wgs/article/details/70214612
关于Dubbo是什么这里就不多说了,Dubbo官网http://dubbo.io/,直接上干货。
(注:本文所用环境为jdk1.7.0_79、apache-tomcat-7.0.72、eclipse4.5.2)
![](https://img-blog.csdn.net/20170921180345569?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
![](https://img-blog.csdn.net/20170922093033373?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
需要把zoo_sample.cfg 改名为 zoo.cfg,因为 Zookeeper在启动时会找这个文件作为默认配置文件。
zookeeper最近的版本中有个内嵌的管理控制台是通过jetty启动,也会占用8080 端口。
想要修改端口可以在zoo.cfg文件中增加admin.serverPort=没有被占用的端口号,如:
admin.serverPort=9090
![](https://img-blog.csdn.net/20170922093130557?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
![](https://img-blog.csdn.net/20170922093157071?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
![](https://img-blog.csdn.net/20170922093234234?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
如图,使用我们设置的9090端口,默认监听在2181。
注意本文档使用dubbo-admin版本为2.5.3,与jdk1.8存在兼容性问题,会报错:Bean property 'URIType' is not writable orhas an invalid
可以自行下载jdk1.8版本的dubbo-admin或查阅相关解决方案。
本文所用dubbo-admin-2.5.3.war:http://download.csdn.net/download/guangyuj/9989155
如果使用jdk1.8的同学请用dubbo-admin-2.5.4.war:http://download.csdn.net/download/guangyuj/9988735
源码下载地址是:https://github.com/alibaba/dubbo
![](https://img-blog.csdn.net/20170922093359552?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
先把tomcat下的wtpwebapps\ROOT目录下内容清空,然后把下载的war包或自己编译的war包解压,放在该目录下
![](https://img-blog.csdn.net/20170922093434650?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
修改解压后的WEB-INF下的dubbo.properties文件,用来设置zookeeper注册中心的服务地址和端口号
![](https://img-blog.csdn.net/20170922093510927?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
控制台的登录密码也在这里设置
![](https://img-blog.csdn.net/20170922093544544?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
dubbo-api : 存放公共接口;
dubbo-consumer : 调用远程服务;
dubbo-provider: 提供远程服务。
![](https://img-blog.csdn.net/20170922093637741?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
下面详细介绍代码构建过程
![](https://img-blog.csdn.net/20170922093710929?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
pom.xml文件:
定义服务接口:
DemoService.java:
![](https://img-blog.csdn.net/20170922093817377?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
pom.xml文件:
在服务提供方实现接口:
DemoServiceImpl.java:
用Spring配置声明暴露服务:
dubboContext.xml:
加载Spring配置,启动服务(或者将项目建为web项目,然后在web.xml中配置好spring的启动,然后扔到tomcat中即可提供服务):
Provider.java:
![](https://img-blog.csdn.net/20170922093916891?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
pom.xml文件:
通过Spring配置引用远程服务:
dubboContext.xml:
调用服务测试:
Consumer.java:
运行项目,先确保provider已被运行后再启动consumer模块:
测试结果:
![](https://img-blog.csdn.net/20170922094006221?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
这时我们查看监控中心,
查看提供者:
![](https://img-blog.csdn.net/20170922094031349?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
查看消费者:
![](https://img-blog.csdn.net/20170922094108020?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3Vhbmd5dWo=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
至此,整合完毕!
附源码:http://download.csdn.net/download/guangyuj/9989243
感谢三位的文章给了我很多帮助:
http://blog.csdn.net/mg0324/article/details/49385233 http://blog.csdn.net/hejingyuan6/article/details/47403299 http://blog.csdn.net/noaman_wgs/article/details/70214612
关于Dubbo是什么这里就不多说了,Dubbo官网http://dubbo.io/,直接上干货。
(注:本文所用环境为jdk1.7.0_79、apache-tomcat-7.0.72、eclipse4.5.2)
一、安装Zookeeper
1. 下载zookeeper注册中心
地址:http://mirror.bit.edu.cn/apache/zookeeper,下载之后解压即可。2. 配置
Zookeeper的配置文件在 conf 目录下需要把zoo_sample.cfg 改名为 zoo.cfg,因为 Zookeeper在启动时会找这个文件作为默认配置文件。
zookeeper最近的版本中有个内嵌的管理控制台是通过jetty启动,也会占用8080 端口。
想要修改端口可以在zoo.cfg文件中增加admin.serverPort=没有被占用的端口号,如:
admin.serverPort=9090
3. 启动zookeeper
windows下运行bin\ zkServer.cmd即可如图,使用我们设置的9090端口,默认监听在2181。
二、 搭建dubbo监控环境
1. 下载dubbo-admin
dubbo官方提供了一款非常好用的dubbo监控web应用,叫做dubbo-admin。dubbo-admin.war可以在网上下载,也可以自己下载dubbo的源码编译。注意本文档使用dubbo-admin版本为2.5.3,与jdk1.8存在兼容性问题,会报错:Bean property 'URIType' is not writable orhas an invalid
可以自行下载jdk1.8版本的dubbo-admin或查阅相关解决方案。
本文所用dubbo-admin-2.5.3.war:http://download.csdn.net/download/guangyuj/9989155
如果使用jdk1.8的同学请用dubbo-admin-2.5.4.war:http://download.csdn.net/download/guangyuj/9988735
源码下载地址是:https://github.com/alibaba/dubbo
先把tomcat下的wtpwebapps\ROOT目录下内容清空,然后把下载的war包或自己编译的war包解压,放在该目录下
修改解压后的WEB-INF下的dubbo.properties文件,用来设置zookeeper注册中心的服务地址和端口号
控制台的登录密码也在这里设置
2. 启动tomcat
启动后,输入http://localhost:8080,用户名密码都是root,就可以进入dubbo-admin系统,来查看zookeeper中的服务了。三、 创建maven项目
项目结构主要分三大模块:dubbo-api : 存放公共接口;
dubbo-consumer : 调用远程服务;
dubbo-provider: 提供远程服务。
下面详细介绍代码构建过程
1. dubbo-api
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"> <modelVersion>4.0.0</modelVersion> <groupId>dubbo-api</groupId> <artifactId>dubbo-api</artifactId> <packaging>pom</packaging> <version>0.0.1-SNAPSHOT</version> <name>dubbo-api Maven Webapp</name> <url>http://maven.apache.org</url> <properties> <!-- spring版本号 --> <spring.version>4.2.2.RELEASE</spring.version> </properties> <dependencies> <!-- 添加spring核心依赖 --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-oxm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.9</version> </dependency> <!-- dubbo --> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> <exclusions> <exclusion> <groupId>org.springframework</groupId> <artifactId>spring</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> </dependencies> <build> <finalName>dubbo-api</finalName> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.3</version> <configuration> <!-- 指定source和target的版本 --> <source>1.7</source> <target>1.7</target> </configuration> </plugin> </plugins> </build> </project>
定义服务接口:
DemoService.java:
package com.leetu.dubbo.api; /** * 定义服务接口 * @author Jin Guangyu * */ public interface DemoService { String sayHello(String name); }
2. dubbo-provider
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"> <modelVersion>4.0.0</modelVersion> <groupId>dubbo-provider</groupId> <artifactId>dubbo-provider</artifactId> <packaging>war</packaging> <version>0.0.1-SNAPSHOT</version> <name>dubbo-provider Maven Webapp</name> <url>http://maven.apache.org</url> <dependencies> <dependency> <groupId>dubbo-api</groupId> <artifactId>dubbo-api</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> </dependencies> <build> <finalName>dubbo-provider</finalName> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.3</version> <configuration> <!-- 指定source和target的版本 --> <source>1.7</source> <target>1.7</target> </configuration> </plugin> </plugins> </build> </project>
在服务提供方实现接口:
DemoServiceImpl.java:
package com.leetu.dubbo.provider.impl; import com.leetu.dubbo.api.DemoService; /** * 服务提供方实现接口 * @author Jin Guangyu * */ public class DemoServiceImpl implements DemoService { @Override public String sayHello(String name) { return "Hello " + name; } }
用Spring配置声明暴露服务:
dubboContext.xml:
<?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-admin 或 dubbo-monitor 会显示这个名字,方便辨识 --> <dubbo:application name="leetu_provider" owner="programmer" organization="dubbox"/> <!-- 使用zookeeper注册中心暴露服务地址,即zookeeper的所在服务器ip地址和端口号,注意要先开启 zookeeper --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="com.leetu.dubbo.api.DemoService" ref="demoService" /> <!-- 具体的实现bean --> <bean id="demoService" class="com.leetu.dubbo.provider.impl.DemoServiceImpl" /> </beans>
加载Spring配置,启动服务(或者将项目建为web项目,然后在web.xml中配置好spring的启动,然后扔到tomcat中即可提供服务):
Provider.java:
package com.leetu.dubbo.provider.impl; import org.springframework.context.support.ClassPathXmlApplicationContext; public class Provider { public static void main(String[] args) throws Exception { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "dubboContext.xml" }); context.start(); System.in.read(); // 为保证服务一直开着,利用输入流的阻塞来模拟 } }
3. dubbo-consumer
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"> <modelVersion>4.0.0</modelVersion> <groupId>dubbo-consumer</groupId> <artifactId>dubbo-consumer</artifactId> <packaging>war</packaging> <version>0.0.1-SNAPSHOT</version> <name>dubbo-consumer Maven Webapp</name> <url>http://maven.apache.org</url> <dependencies> <dependency> <groupId>dubbo-api</groupId> <artifactId>dubbo-api</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> </dependencies> <build> <finalName>dubbo-consumer</finalName> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.3</version> <configuration> <!-- 指定source和target的版本 --> <source>1.7</source> <target>1.7</target> </configuration> </plugin> </plugins> </build> </project>
通过Spring配置引用远程服务:
dubboContext.xml:
<?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:application name="leetu_consumer" owner="programmer" organization="dubbox"/> <!-- 向 zookeeper 订阅 provider 的地址,由 zookeeper 定时推送 --> <dubbo:registry address="zookeeper://localhost:2181" /> <!-- 使用 dubbo 协议调用定义好的 api.PermissionService 接口 --> <dubbo:reference id="demoService" interface="com.leetu.dubbo.api.DemoService" /> </beans>
调用服务测试:
Consumer.java:
package com.leetu.dubbo.consumer; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.leetu.dubbo.api.DemoService; public class Consumer { public static void main(String[] args) throws Exception { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "dubboContext.xml" }); context.start(); DemoService demoService = (DemoService) context.getBean("demoService"); String hello = demoService.sayHello("xuanxuan"); System.out.println(hello); System.in.read(); } }
运行项目,先确保provider已被运行后再启动consumer模块:
测试结果:
这时我们查看监控中心,
查看提供者:
查看消费者:
至此,整合完毕!
附源码:http://download.csdn.net/download/guangyuj/9989243
相关文章推荐
- Springboot整合Dubbo/ZooKeeper demo
- spring整合zookeeper与dubbo的入门案例(一)
- dubbo 入门,与zookeeper maven spring整合
- 一个简单的Dubbo+Zookeeper+Spring整合Demo,附带源码
- dubbo+zookeeper+spring整合(注解式demo)
- dubbo+zookeeper+springmvc整合,小入门
- Maven+SpringMVC+Dubbo+zookeeper 简单的入门demo配置
- dubbo zookeeper spring mvc简单整合的工程例子demo
- Dubbo与Zookeeper、Spring整合使用.
- Springboot 整合 Dubbo/ZooKeeper 详解 SOA 案例
- 分布式系统设计原理与方案Dubbo+Zookeeper+Spring整合
- Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务
- Dubbo与Zookeeper、spring框架入门整合。
- 【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务
- Spring Boot整合Dubbo框架demo
- Dubbo与Zookeeper、Spring整合使用
- Springboot 整合 Dubbo/ZooKeeper 详解 SOA 案例
- Spring整合JMS发布/订阅入门小Demo
- (十)springmvc+mybatis+dubbo+zookeeper分布式架构 整合 - maven构建ant-utils工具项目
- 9、Spring技术栈-整合dubbo、zookeeper