当前位置: 首页 > news >正文

Spring boot整合dubbo+zookeeper

Spring boot整合dubbo+zookeeper

下文将简述springboot整合dubbo+zookeeper实现api+provider+consumer模式,Api用于定于interface,provider和consumer依赖Api,provider实现api接口,consumer调用provider。
spring boot版本:3.5.3
jdk版本:java17

1.创建父工程

此处只勾选了spring web和lombok,需要Orm框架自行增加
在这里插入图片描述
在这里插入图片描述
2.父工程引入依赖
父工程pom.xml,引入dubbo和zookeeper相关依赖,修改packaging为pom不打包,并删除src目录

           <dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>3.2.10</version></dependency><!-- Zookeeper客户端 --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>5.2.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>5.2.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-x-discovery</artifactId><version>5.2.0</version> <!-- 与Zookeeper版本匹配 --></dependency><dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>3.5.3</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

3.创建api子模块

(1).新建dubbo-api module
在这里插入图片描述
(2).修改pom.xml文件
修改dubbo-api的pom.xml,parent修改为刚才新建的groupId、artifactId和version,再去掉重复的配置

<parent><groupId>com.example</groupId><artifactId>DubboDemo</artifactId><version>0.0.1-SNAPSHOT</version></parent>

父工程pom.xml增加子模块

<modules><module>dubbo-api</module></modules>

( 3).修改配置
修改application.properties为application.yml,并增加dubbo配置内容

spring:application:name: dubbo-apiconfig:activate:on-profile: default
server:port: 8080
dubbo:application:name: dubbo-apiprotocol:name: dubboport: 20880registry:address: zookeeper://192.168.48.154:2181

dubbo.protocol 此处协议不是自定义的,自由dubbo、rpc等类型
registry:配置zookeeper地址
(4)启动类,开启dubbo,
@EnableDubbo 注解用于开启dubbo客户端,scanBasePackages 可以配置包路径

@SpringBootApplication
@EnableDubbo
public class DubboApiApplication{public static void main(String[] args) {SpringApplication.run(DubboProviderApplication.class, args);}}

(5)新增Service接口

public interface TestService {String sayHello(String name);
}

4.创建provider子模块

(1)创建dubbo-provider模块,和上面一样,就不赘述了
(2)修改pom.xml文件
依赖中加入api模块的依赖

  <dependencies><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies>

(3)修改配置文件
application.yml

spring:application:name: providerconfig:activate:on-profile: default
server:port: 8081
dubbo:application:name: dubbo-providerqos-enable: trueqos-port: 22223registry:address: zookeeper://192.168.48.154:2181protocol:name: dubboport: 20881  #同一台机器不能相同

对比api模块增加了qos-enable和qos-port两个属性,QoS是Dubbo提供的运维和管理功能,表示开启;qos-port表示运维管理功能的端口
(4)启动类,开启dubbo,
@EnableDubbo 注解用于开启dubbo客户端,scanBasePackages 可以配置包路径

@SpringBootApplication
@EnableDubbo
public class DubboProviderApplication {public static void main(String[] args) {System.setProperty("zookeeper.sasl.client", "false");SpringApplication.run(DubboProviderApplication.class, args);}}

(5)实现TestService接口

package com.examplexu.dubboprovider.service;import com.examplexu.duubo.service.TestService;
import org.apache.dubbo.config.annotation.DubboService;@DubboService(version = "1.0.0")
public class TestServiceImpl implements TestService {@Overridepublic String sayHello(String name) {return "welcome"+name+" to dubbo!";}
}

@DubboService 的作用为标记TestService为服务提供者,暴露为dubbo服务,并注册到zookeeper并进行管理。可以配置的参数如下:
version: 服务版本号(必填)
timeout: 调用超时时间(毫秒)
loadbalance: 负载均衡策略
retries: 失败重试次数
check: 启动时检查依赖服务是否可用

5.创建consumer子模块

(1)创建dubbo-consumer模块,和上面一样,就不赘述了
(2)修改pom.xml文件
依赖中加入api模块的依赖

  <dependencies><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies>

(3)修改配置文件

spring:application:name: consumerconfig:activate:on-profile: default
server:port: 8084
dubbo:config:application:name: dubbo-consumerqos-enable: trueqos-port: 22224registry:address: zookeeper://192.168.48.154:2181timeout: 20000protocol:name: dubboport: 20882config-center:timeout: 20000

此处增加了超时时间,注册中心如果超时,会抛出异常,若配置了重试会进行重试操作;配置中心超时,会记录警告日志,可能会影响动态配置更新
(5)启动类,开启dubbo

@SpringBootApplication
@EnableDubbo
public class DubboConsumerApplication {public static void main(String[] args) {System.setProperty("zookeeper.sasl.client", "false");SpringApplication.run(DubboConsumerApplication.class, args);}}

(6)增加Controller调用provider

@RestController
@RequestMapping("/consumer")
public class TestController {@DubboReference(version = "1.0.0",timeout = 5000,loadbalance = "roundrobin",retries = 3,check = false)private TestService testService;@GetMapping("/sayHello")public String test(String name) {return testService.sayHello(name);}
}

@DubboReference 用于标记引用Dubbo服务,自动从注册中心发现并创建服务代理,实现服务的远程调用。主要配置参数如下:
version 版本号,与服务提供者提供的version一直
timeout 单次调用超时时间
loadbalance 负载均衡策略有random/roundrobin/leastactive策略,即随机、轮询、近期最少使用
retries 失败自动重试次数
check 启动时是否检查依赖服务的可用性

6.启动服务

依次启动dubbo-api、dubbo-provider、dubbo-consumer;启动时可以查看日志会出现很多zookeeper和dubbo的日志
在这里插入图片描述
在这里插入图片描述
启动过程中如果报错:

2025-07-10T15:28:14.979+08:00 ERROR 37840 --- [consumer] [           main] o.a.d.c.deploy.DefaultModuleDeployer     :  [DUBBO] Model reference failed: Dubbo Module[1.1.1] , catch error : Can not create registry service-discovery-registry://192.168.48.154:2181/org.apache.dubbo.registry.RegistryService?application=dubbo-consumer&dubbo=2.0.2&executor-management-mode=isolation&file-cache=true&interface=org.apache.dubbo.registry.RegistryService&pid=37840&qos.enable=true&qos.port=22224&registry=zookeeper&release=3.2.10&timeout=20000, dubbo version: 3.2.10, current host: 192.168.1.93, error code: 5-15. This may be caused by , go to https://dubbo.apache.org/faq/5/15 to find instructions. java.lang.RuntimeException: Can not create registry service-discovery-registry://192.168.48.154:2181/org.apache.dubbo.registry.RegistryService?application=dubbo-consumer&dubbo=2.0.2&executor-management-mode=isolation&file-cache=true&interface=org.apache.dubbo.registry.RegistryService&pid=37840&qos.enable=true&qos.port=22224&registry=zookeeper&release=3.2.10&timeout=20000at org.apache.dubbo.registry.support.AbstractRegistryFactory.getRegistry(AbstractRegistryFactory.java:105) ~[dubbo-3.2.10.jar:3.2.10]at org.apache.dubbo.registry.RegistryFactoryWrapper.getRegistry(RegistryFactoryWrapper.java:33) ~[dubbo-3.2.10.jar:3.2.10]

启动类中新增:

 System.setProperty("zookeeper.sasl.client", "false");

表示不进行SASL认证,生产环境视要求具体设置

测试结果

当dubbo-api、dubbo-provider和dubbo-consumer都启动完成后,使用消费者接口访问。
在这里插入图片描述
可以发现此处消费者调用的是提供者的实现内容。

http://www.dtcms.com/a/272801.html

相关文章:

  • 26-计组-外存
  • 基于云端EC2的O3DE机器人仿真环境搭建指南
  • python自动化面试问题——关于python
  • 029_构造器重载与默认构造器
  • 【报错】Could not find a package configuration file provided by ‘glog’”
  • “Datawhale AI夏令营”基于带货视频评论的用户洞察挑战赛
  • 使用Tensorflow和CNN进行猫狗图片训练的实战总结
  • P1722 矩阵 II 题解 DFS深度优先遍历与卡特兰数(Catalan number)解
  • Spring Boot+Redis+Caffeine 二级缓存架构的终极实现方案、包含万级QPS下的黄金配置参数、全文超过2500字(博君一赞)
  • XGBoosting算法详解(Boosting思想的代表算法)
  • C语言<数据结构-链表>
  • LangChain RAG 实战
  • Transformers 和 PyTorch 的区别与安装指南
  • Docker 高级管理--Dockerfile镜像制作
  • Context Engineering Framework 系统详细介绍
  • 链表算法之【合并两个有序链表】
  • 牛客笔试题 除2!
  • 读取按键的四种方式
  • IMU误差模型
  • 显卡GPU的架构和工作原理
  • 输入框过滤选项列表,el-checkbox-group单选
  • JDK 1.7 vs JDK 1.8
  • 为什么域名加端口访问需要放行端口?
  • 【算法训练营Day11】二叉树part1
  • c语言初阶 指针
  • CH9121T电路及配置详解
  • 【算法笔记 day three】滑动窗口(其他类型)
  • Spring Security 技术原理与实战全景详解
  • 【OD机试题解法笔记】根据IP查找城市
  • 观众信息设置与统计(视频高级分析与统计功能)