Spring Boot集成dubbo+zookeeper

2024-09-02 06:48
文章标签 java spring boot dubbo 集成 zookeeper

本文主要是介绍Spring Boot集成dubbo+zookeeper，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

版本环境

名称版本号
JDK1.8
Spring Boot1.5.8
dubbo2.5.6
zookeeper3.4.9
zkclient0.2
Nodejs0.2
Vue2.0
Maven3.0.5
IDEA2018.3

Zookeeper

ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务。很多中间件，比如Kafka、Hadoop、HBase，都用到了 Zookeeper。可以说在分布式系统中，Zookeeper已经已经占据举足轻重的地位。
Zookeeper下载地址

Dubbo

Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和Spring框架无缝集成。

Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
dubbo官网

集成方式

Spring Boot集成dubbo有多种方式，有通过注解实现，也有通过配置文件的方式

创建Spring Boot工程

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

建好dubbo空工程后然后新建4个module分别是：

  • dubbo-api目录：接口工程
  • dubbo-consumer目录：服务消费者工程
  • dubbo-parent目录：父依赖工程
  • dubbo-provider目录：服务提供者工程

最终的工程目录如下图
在这里插入图片描述

dubbo-parent(父工程)

这个父工程只是用来管理依赖和版本，src目录可以删掉

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.8.RELEASE</version></parent><groupId>com.laowang</groupId><artifactId>dubbo-parent</artifactId><version>0.0.1-SNAPSHOT</version><name>dubbo-parent</name><packaging>pom</packaging><modules><module>../dubbo-api</module><module>../dubbo-consumer</module><module>../dubbo-provider</module></modules><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><java.version>1.8</java.version><dubbo.version>2.5.6</dubbo.version><zookeeper.version>3.4.9</zookeeper.version><zkclient.version>0.2</zkclient.version></properties><dependencyManagement><dependencies><!--Dubbo 依赖 --><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version><exclusions><exclusion><artifactId>spring</artifactId><groupId>org.springframework</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>${zookeeper.version}</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></exclusion></exclusions></dependency><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>${zkclient.version}</version></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

dubbo-api(接口模块)

新建库存接口类，写一个添加库存的接口，如下图
在这里插入图片描述

dubbo-provider(服务提供者)

pom.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.laowang</groupId><artifactId>dubbo-parent</artifactId><version>0.0.1-SNAPSHOT</version><relativePath>../dubbo-parent/pom.xml</relativePath></parent><groupId>com.laowang</groupId><artifactId>dubbo-provider</artifactId><version>0.0.1-SNAPSHOT</version><name>dubbo-provider</name><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.laowang</groupId><artifactId>dubbo-api</artifactId><version>${project.version}</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></dependency><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

新建实现类，实现OrderService接口，并且加入Service注解

在这里插入图片描述

application.properties配置

#服务启动端口
server.port=8090
#zookeeper地址
zkAddress=127.0.0.1:2181
#dubbo端口
dubbo.port=20880
#dubbo-version
dubbo-version=1.0

在resources目录新建dubbo-provider.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/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsd"><!-- 服务提供方应用名，用于计算依赖关系 --><dubbo:application name="dubbo-provider" owner="dubbo-provider" /><!-- 定义 zookeeper 注册中心地址及协议 --><dubbo:registry protocol="zookeeper" address="${zkAddress}"/><!-- 用dubbo协议在20880端口暴露服务 --><dubbo:protocol name="dubbo" port="${dubbo.port}"/><!-- 声明需要暴露的服务接口 --><dubbo:service interface="com.laowang.dubboapi.service.OrderService" ref="orderService" timeout="5000" version="${dubbo-version}"/></beans>

启动类

在DubboProviderApplication中加入注解@ImportResource(value = “classpath:dubbo-provider.xml”)
在这里插入图片描述

然后启动，如下图控制台打印信息说明成功，dubbo服务提供完成

在这里插入图片描述

dubbo-consumer(服务消费者)

pom.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.laowang</groupId><artifactId>dubbo-parent</artifactId><version>0.0.1-SNAPSHOT</version><relativePath>../dubbo-parent/pom.xml</relativePath></parent><groupId>com.laowang</groupId><artifactId>dubbo-consumer</artifactId><version>0.0.1-SNAPSHOT</version><name>dubbo-consumer</name><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></dependency><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId></dependency><dependency><groupId>com.laowang</groupId><artifactId>dubbo-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

新建controller

注入service 的时候用dubbo的Reference实现远程调用
在这里插入图片描述

application.properties配置文件

server.port=8091
#zookeeper地址
zkAddress=127.0.0.1:2181

在resources目录新建dubbo-consumer.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/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsd"><!-- 服务提供方应用名，用于计算依赖关系 --><dubbo:application name="dubbo-consumer" owner="dubbo-consumer" /><!-- 定义 zookeeper 注册中心地址及协议 --><dubbo:registry protocol="zookeeper" address="${zkAddress}"/><!--数据接口--><dubbo:annotation package="com.laowang.dubboconsumer.controller" />
</beans>

启动类

加上@ImportResource(locations={“classpath:dubbo-consumer.xml”})注解
在这里插入图片描述

然后启动，控制台打印如下信息说明成功

在这里插入图片描述

然后测试一下

在浏览器输入http://localhost:8091/helloDubbo，如下图，说明成功，然后去dubbo admin 中去看看

在这里插入图片描述

注意这里有个坑，就是可能会有controller中Reference注入service空指针错误，那就肯定是版本问题了，检查一下自己版本

dubbo管理平台（最新版）

从dubbo2.6.1之后，dubbo admin 管理平台已经分离出来单独维护了，也新增了很多功能。最新的管理平台也前后台分离，后台用的spring boot，前台用的vue，所有需要node来安装依赖
dubbo管理平台下载地址

在这里插入图片描述

下载完成后解压，目录如下图

在这里插入图片描述

修改application.properties配置文件
主要是看看端口号，ip地址是否需要修改，如果是127.0.0.1可忽略此步骤
在这里插入图片描述

admin.registry.address=zookeeper://127.0.0.1:2181
admin.config-center=zookeeper://127.0.0.1:2181
admin.metadata-report.address=zookeeper://127.0.0.1:2181admin.registry.group=dubbo
admin.apollo.token=e16e5cd903fd0c97a116c873b448544b9d086de9
admin.apollo.appId=test
admin.apollo.env=dev
admin.apollo.cluster=default
admin.apollo.namespace=dubbo

然后cmd进入dubbo-admin-server目录下

分别执行mvn claen package命令，如下图代表成功

在这里插入图片描述

然后cmd进入dubbo-admin-server\target目录，就是刚刚打包编译后的目录
执行java -jar dubbo-admin-server-0.1.jar启动项目
如下图说明启动成功
在这里插入图片描述

然后浏览器打开http://localhost:8080/swagger-ui.html，说明后台已经启动成功
在这里插入图片描述

然后进入dubbo-admin-ui，打包vue组件
首先需要nodejs的环境，如果没有安装过node可以参考: Nodejs环境搭建

进入dubbo-admin-ui目录，执行npm install安装依赖，这里需要几分钟时间，如果嫌慢试试cnpm install，这个是用的阿里国内镜像，要稍微快点。然后安装完成时候执行cnpm run dev启动，如下图
在这里插入图片描述

然后浏览器输入http://localhost:8081

在这里插入图片描述

点击查看详情，如果使用dubbo2.7以上版本还可以查看元数据
在这里插入图片描述

源码下载

点击进入CSDN下载
包含demo源码和dubbo admin源码

这篇关于Spring Boot集成dubbo+zookeeper的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1129291。

相关文章

Debezium 与 Apache Kafka 的集成方式步骤详解

Debezium 与 Apache Kafka 的集成方式步骤详解

《Debezium与ApacheKafka的集成方式步骤详解》本文详细介绍了如何将Debezium与ApacheKafka集成,包括集成概述、步骤、注意事项等,通过KafkaConnect,D... 目录一、集成概述二、集成步骤1. 准备 Kafka 环境2. 配置 Kafka Connect3. 安装 D
阅读更多...
Java中ArrayList和LinkedList有什么区别举例详解

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》：本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程
阅读更多...
JavaScript中的reduce方法执行过程、使用场景及进阶用法

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》：本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程
阅读更多...
如何使用Java实现请求deepseek

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2
阅读更多...
Java调用DeepSeek API的最佳实践及详细代码示例

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》：本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.
阅读更多...
Spring AI集成DeepSeek的详细步骤

Spring AI集成DeepSeek的详细步骤

《SpringAI集成DeepSeek的详细步骤》DeepSeek作为一款卓越的国产AI模型,越来越多的公司考虑在自己的应用中集成,对于Java应用来说,我们可以借助SpringAI集成DeepSe... 目录DeepSeek 介绍Spring AI 是什么？1、环境准备2、构建项目2.1、pom依赖2.2
阅读更多...
Spring Cloud LoadBalancer 负载均衡详解

Spring Cloud LoadBalancer 负载均衡详解

《SpringCloudLoadBalancer负载均衡详解》本文介绍了如何在SpringCloud中使用SpringCloudLoadBalancer实现客户端负载均衡,并详细讲解了轮询策略和... 目录1. 在 idea 上运行多个服务2. 问题引入3. 负载均衡4. Spring Cloud Load
阅读更多...
Springboot中分析SQL性能的两种方式详解

Springboot中分析SQL性能的两种方式详解

《Springboot中分析SQL性能的两种方式详解》文章介绍了SQL性能分析的两种方式：MyBatis-Plus性能分析插件和p6spy框架,MyBatis-Plus插件配置简单,适用于开发和测试环... 目录SQL性能分析的两种方式:功能介绍实现方式:实现步骤:SQL性能分析的两种方式:功能介绍记录
阅读更多...
在 Spring Boot 中使用 @Autowired和 @Bean注解的示例详解

在 Spring Boot 中使用 @Autowired和 @Bean注解的示例详解

《在SpringBoot中使用@Autowired和@Bean注解的示例详解》本文通过一个示例演示了如何在SpringBoot中使用@Autowired和@Bean注解进行依赖注入和Bean... 目录在 Spring Boot 中使用 @Autowired 和 @Bean 注解示例背景1. 定义 Stud
阅读更多...
如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

《如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解》：本文主要介绍如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别的相关资料,描述了如何使用海康威视设备网络SD... 目录前言开发流程问题和解决方案dll库加载不到的问题老旧版本sdk不兼容的问题关键实现流程总结前言作为
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2