Spring Boot 整合dubbo与zookeeper实现不同项目之间数据通过服务的传递

一、安装zookeeper
1、下载路径：http://mirrors.hust.edu.cn/apache/zookeeper/
可以自己选择版本进行下载(同时支持windows和linux)
2、目录结构

3、修改conf下的配置文件zoo.cfg

4、启动zookeeper
windows环境下，在zookeeper的bin目录下双击zkServer.cmd即可启动zookeeper服务器端
启动之后是这样的状态
5、启动客户端(双击zkCli.cmd)

二、创建服务提供者项目
1、创建一个maven project

勾选create a simple project 创建一个简单的示例项目(默认是javaWeb项目)

点击next，输入相关信息，这里a-parent项目是已经存在的，所以提示一个相应的错误，再点击finish 就创建好了

2、创建a项目下的module

这里直接点击finish即可

目前测试看效果，就创建一下三个module

3、在a-parent父级项目中的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/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.system.a</groupId><artifactId>a-parent</artifactId><version>0.0.1-SNAPSHOT</version><packaging>pom</packaging><!-- 声明父级的依赖，声明在这里，所有的module都会继承这个依赖，这里不解释继承的概念 --><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.13.RELEASE</version></parent><!-- 声明当前pom文件的属性配置 --><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><dubbo-spring-boot>1.0.0</dubbo-spring-boot></properties><dependencies><!-- 引入Spring Boot Web --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- 引入Spring Boot Dubbo --><dependency><groupId>io.dubbo.springboot</groupId><artifactId>spring-boot-starter-dubbo</artifactId><version>${dubbo-spring-boot}</version></dependency><!-- 引入zookeeper的客户端 --><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version></dependency> <!-- 引入 zookeeper的服务器端 --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.5</version><!-- 该标签内的依赖会不再引入进来，这里是为了不和spring boot starter web 中的日志出现冲突 --><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion></exclusions></dependency></dependencies><!-- 三个module项目 --><modules><module>a-service</module><module>a-boot</module><module>a-domain</module></modules>
</project>

4、创建application.properties

spring.datasource.driverClassName=com.mysql.jdbc.Driverspring.datasource.url=jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
server.port=8888
# 下面为连接池的补充设置，应用到上面所有数据源中
# 初始化大小，最小，最大
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
# 配置获取连接等待超时的时间
spring.datasource.maxWait=60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
# 打开PSCache，并且指定每个连接上PSCache的大小
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
spring.datasource.filters=stat,wall,log4j
# 通过connectProperties属性来打开mergeSql功能；慢SQL记录
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 合并多个DruidDataSource的监控数据
#spring.datasource.useGlobalDataSourceStat=true
spring.http.multipart.maxFileSize=10Mb
spring.http.multipart.maxRequestSize=100Mb
spring.mvc.view.prefix=/
spring.mvc.view.suffix=.jsp
mybatis.type-aliases-package=com.distributed
mybatis.mapper-locations:classpath:com/distributed/mapper/*.xml
#当查询数据为空时字段返回为null，不加这个查询数据为空时，字段将被隐藏
mybatis.configuration.call-setters-on-nulls=true
#spring.cache.ehcache.config=classpath:ehcache.xml
logging.level.com.muck.controller=error
logging.level.com.muck.mapper=debug
logging.level.com.muck.service.impl=error
logging.path=D:/usr/local/application/muck/log/mucklog# Dubbo 服务提供者配置
#服务器端app名称
spring.dubbo.application.name=distributed-provider
#需要将当前项目的服务注册在的目标服务注册中心
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
#服务器端节点名称
spring.dubbo.protocol.name=dubbo
#服务器端节点的端口
spring.dubbo.protocol.port=20880
#扫描以下包目录，并将其中的服务注册到服务注册中心
spring.dubbo.scan=com.a.service

5、编写启动类，并测试项目是否可以正常启动(右键run as java application)

6、写一个简单的服务提供者所提供的服务
首先建一个用户的实体类，这里一定要序列化，由于数据通过二进制在项目之间进行传递，需要实现序列化

写一个获取所有用户的Service

以下是最重要的部分，这里要使用引入的dubbo下的Service注解version是服务的版本，这是要注册到服务注册中心的服务版本

然后启动项目，看配置的该服务是否注册到了服务注册中心zookeeper

三、创建服务消费者项目（创建方式和一般的spring boot 项目创建方式一样，和提供者的项目创建方式也一样，主要就是相关的application.properties和pom依赖)
1、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/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.b</groupId><artifactId>b-parent</artifactId><version>0.0.1-SNAPSHOT</version><packaging>pom</packaging><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.13.RELEASE</version></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>io.dubbo.springboot</groupId><artifactId>spring-boot-starter-dubbo</artifactId><version>1.0.0</version></dependency><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version></dependency> </dependencies><modules><module>b-controller</module><module>b-boot</module><module>b-domain</module></modules>
</project>

2、application.properties

spring.datasource.driverClassName=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
server.port=8889
# 下面为连接池的补充设置，应用到上面所有数据源中
# 初始化大小，最小，最大
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
# 配置获取连接等待超时的时间
spring.datasource.maxWait=60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
# 打开PSCache，并且指定每个连接上PSCache的大小
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
spring.datasource.filters=stat,wall,log4j
# 通过connectProperties属性来打开mergeSql功能；慢SQL记录
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 合并多个DruidDataSource的监控数据
#spring.datasource.useGlobalDataSourceStat=true
spring.http.multipart.maxFileSize=10Mb
spring.http.multipart.maxRequestSize=100Mb
spring.mvc.view.prefix=/
spring.mvc.view.suffix=.jsp
mybatis.type-aliases-package=com.distributed
mybatis.mapper-locations:classpath:com/distributed/mapper/*.xml
#当查询数据为空时字段返回为null，不加这个查询数据为空时，字段将被隐藏
mybatis.configuration.call-setters-on-nulls=true
spring.cache.ehcache.config=classpath:ehcache.xml
logging.level.com.muck.controller=error
logging.level.com.muck.mapper=debug
logging.level.com.muck.service.impl=error
logging.path=D:/usr/local/application/muck/log/mucklog# Dubbo 服务消费者配置
spring.dubbo.application.name=distributed-consumer-1
# 注册中心 0
spring.dubbo.application.registries[0].address=zookeeper://127.0.0.1:2181
# 注册中心 1
#spring.dubbo.application.registries[1].address=zookeeper://127.0.0.1:2182
#服务消费者启动时dubbo的端口
spring.dubbo.protocol.port=65482
#扫描需要服务所在的包目录，这个要和服务提供者保持一致
spring.dubbo.scan=com.a.service

3、相关目录结构

4、controller调用注册好的服务

5、启动b项目

6、调用b项目提供给前台页面的接口

7、项目已上传到GitHup
https://github.com/GeekCracker/MindMap.git

Spring Boot 整合dubbo与zookeeper实现不同项目之间数据通过服务的传递相关推荐

spring boot 整合Dubbo/Zookeeper
spring boot 整合Dubbo/Zookeeper 只是一个简单的整合demo,只做思路分析叙述,具体功能不做描述. 一.技术介绍 •ZooKeeper ZooKeeper 是一个分布式的,开 ...
VUE+Spring Boot整合MyBatis实现前后端分离项目壁纸网站
目录前言一.项目运行二.环境需要三.技术栈四.项目说明五.后端代码前言每次换桌面,壁纸总是不好找,搜索图片得不到好的索引与反馈,很难找到自己喜欢的壁纸,而壁纸网站可以免去我们去寻找壁纸 ...
Spring boot整合dubbo
GitHub dubbo的GitHub地址 https://github.com/apache/incubator-dubbo dubbo场景启动器 https://github.com/apache ...
Spring Boot----SpringBoot整合 Dubbo 和 Zookeeper
下载安装Zookeeper linux 使用docker部署 windows:参考(https://blog.csdn.net/ring300/article/details/80446918),下载 ...
【SpringBoot整合Dubbo和Zookeeper】
本笔记内容为狂神说SpringBoot集成Dubbo和Zookeeper部分目录一.Dubbo dubbo基本概念调用关系说明二.Dubbo环境搭建三.Window下安装zookeeper ...
spring boot配置dubbo(XML)
上一篇写的是spring boot在自己的properties配置文件中简单配置dubbo的步骤,那种配置有很多的功能(比如超时时间.是否检查)等等,配置起来也挺麻烦的,而我们也习惯传统的那种XML形 ...
spring boot配置dubbo(properties)
spring boot与dubbo配置(properties) dubbo和zookeeper配合使用,具体的它们之间的配置这里不说了. 一.spring boot与dubbo配置有两种方式: 1)s ...
spring boot整合spring security笔记
最近自己做了一个小项目,正在进行springboot和spring Security的整合,有一丢丢的感悟,在这里分享一下: 首先,spring boot整合spring security最好是使用T ...
RabbitMQ使用及与spring boot整合
1.MQ 消息队列(Message Queue,简称MQ)--应用程序和应用程序之间的通信方法应用:不同进程Process/线程Thread之间通信比较流行的中间件: ActiveMQ Rabbi ...

Spring Boot 整合dubbo与zookeeper实现不同项目之间数据通过服务的传递

Spring Boot 整合dubbo与zookeeper实现不同项目之间数据通过服务的传递相关推荐

最新文章

热门文章