当前位置: 代码迷 >> 综合 >> 【springboot+dubbo+zookeeper】编写provider和consumer详解
  详细解决方案

【springboot+dubbo+zookeeper】编写provider和consumer详解

热度:82   发布时间:2023-10-23 13:03:48.0

前提:zookeeper作为注册中心是已经启动了,而且端口已经放行

【springboot+dubbo+zookeeper】编写provider和consumer详解

 项目结构

【springboot+dubbo+zookeeper】编写provider和consumer详解

服务提供者和消费者,导入的pom依赖一致

<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>3.0.1</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-zookeeper</artifactId><version>3.0.1</version><exclusions><exclusion><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency>

 服务提供者(service)

配置文件

server:port: 8001 #端口
spring:application:name: dubbo-service
dubbo:application:#dubbo向注册中心zookeeper中注册的名称,唯一name: dubbo-service#dubbo注册中心和地址registry:#注册中心protocol: zookeeper#注册中心地址address: zookeeper://192.168.146.128:2181#连接的超时时间timeout: 600000protocol:name: dubbo #dubbo协议port: 20880#dubbo通过扫描包的形式注册 提供服务接口也就是@DubboService所在的位置scan:base-packages: com.xx.dubbo.service.impl

提供的服务接口,测试代码,没有具体的逻辑

【springboot+dubbo+zookeeper】编写provider和consumer详解

 随后就可以启动service了,zookeeper注意是开启的

服务消费者(consumer)

配置文件

server:port: 8002 #端口
spring:application:name: dubbo-consumer
dubbo:application:#dubbo向注册中心zookeeper中注册的名称,唯一name: dubbo-consumer#dubbo注册中心协议和地址registry:protocol: zookeeperaddress: zookeeper://192.168.146.128:2181timeout: 600000

工程内提供一个zookeeper中注入的服务接口,注意:接口的路径和提供者provider中的路径一致

【springboot+dubbo+zookeeper】编写provider和consumer详解

 【springboot+dubbo+zookeeper】编写provider和consumer详解

测试调用:通过@dubboreference注入 

【springboot+dubbo+zookeeper】编写provider和consumer详解

 测试:

【springboot+dubbo+zookeeper】编写provider和consumer详解

至此调用成功。

有个优化代码的点:consumer中的提供的调用者的接口可以抽取出来,比如提供一个子工程,专为写要提供的接口,consumer和provider都依赖这个工程,随后进行重写或者直接继承,这样当接口特别多时就不用再consumer中重新定义 

  相关解决方案