前提: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: 600000protocol: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: zookeeperaddress: zookeeper://192.168.146.128:2181timeout: 600000
工程内提供一个zookeeper中注入的服务接口,注意:接口的路径和提供者provider中的路径一致
测试调用:通过@dubboreference注入
测试:
至此调用成功。
有个优化代码的点:consumer中的提供的调用者的接口可以抽取出来,比如提供一个子工程,专为写要提供的接口,consumer和provider都依赖这个工程,随后进行重写或者直接继承,这样当接口特别多时就不用再consumer中重新定义