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

?项目结构

服务提供者和消费者,导入的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: 600000
protocol:
name: dubbo #dubbo协议
port: 20880
#dubbo通过扫描包的形式注册 提供服务接口也就是@DubboService所在的位置
scan:
base-packages: com.xx.dubbo.service.impl
提供的服务接口,测试代码,没有具体的逻辑

?随后就可以启动service了,zookeeper注意是开启的
服务消费者(consumer)
配置文件
server:
port: 8002 #端口
spring:
application:
name: dubbo-consumer
dubbo:
application:
#dubbo向注册中心zookeeper中注册的名称,唯一
name: dubbo-consumer
#dubbo注册中心协议和地址
registry:
protocol: zookeeper
address: zookeeper://192.168.146.128:2181
timeout: 600000
工程内提供一个zookeeper中注入的服务接口,注意:接口的路径和提供者provider中的路径一致

?
测试调用:通过@dubboreference注入?

?测试:

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