文章目录
- 环境准备
- dubbo简介
- Nacos环境准备
- Nacos与dubbo整合
- 项目管理规范
- dubbo整合nacos案例
- 创建公共接口模块
- 创建服务提供者模块
- 创建服务消费者模块
- 服务调用测试
- 本文小结
环境准备
dubbo简介
dubbo核心节点之间的调用关系
节点说明
调用关系说明
- 服务容器负责启动，加载，运行服务提供者。
- 服务提供者在启动时，向注册中心注册自己提供的服务。
- 服务消费者在启动时，向注册中心订阅自己所需的服务。
- 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
- 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
- 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
Nacos环境准备
启动nacos，本文使用的是nacos1.4.3版本
打开nacos的控制面板
Nacos与dubbo整合
为了方便大家理解，这里写出对应的生产方、消费方 Demo 代码，以及使用的注册中心。
项目管理规范
springboot，netflix和cloud alibaba之间有版本之间的对应关系，本文选择的版本如下
dubbo和cloud alibaba之间有版本之间的对应关系，本文选择的版本如下
为了后续方便使用SpringCloud Alibaba进行开发，首先创建一个pom类型的父项目，主要用于项目技术栈版本管理，创建一个maven项目，名称为spring-cloud-alibaba-example，去除src文件，修改pom文件
4.0.0
ah.wideth
spring-cloud-alibaba-example
1.0-SNAPSHOT
org.springframework.boot
spring-boot-starter-parent
2.3.12.RELEASE
pom
UTF-8
1.8
Hoxton.SR12
2.2.7.RELEASE
org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import
com.alibaba.cloud
spring-cloud-alibaba-dependencies
${com-alibaba-cloud.version}
pom
import
登录后复制
后续创建的项目都放到此目录下，只需要声明groupId和artifactId，会自动引用父项目spring-cloud-alibaba-example的版本。与其说是父项目，不如说是根项目: 因为下面每学习一个新的技术，就会新建一个真正的父项目，而在对应的父项目下面又会创建许多的子项目
dubbo整合nacos案例
本文的案例是在上文nacos开发实例的基础之上继续编写的。下面开始创建我们的项目，贴上我的目录结构。
模块说明
public-api公共接口模块（接口），供服务消费者和服务提供者调用。dubbo-provider服务提供者模块（接口实现类），引入了public-api模块dubbo-consumer服务消费者模块（controller），引入了public-api模块- 消费者和提供者通过公共接口模块进行rpc远程调用
父工程pom文件
4.0.0
spring-cloud-alibaba-example
ah.wideth
1.0-SNAPSHOT
public-api
dubbo-provider
dubbo-consumer
dubbo-nacos-example
dubbo-nacos-example
duboo与nacos整合的父工程
pom
1.8
utf-8
UTF-8
2.7.13
1.4.1
com.alibaba.cloud
spring-cloud-starter-alibaba-nacos-discovery
nacos-client
com.alibaba.nacos
org.apache.dubbo
dubbo-spring-boot-starter
${dubbo.version}
org.apache.dubbo
dubbo-registry-nacos
${dubbo.version}
com.alibaba.nacos
nacos-client
${nacos.version}
com.alibaba.spring
spring-context-support
1.0.11
org.apache.dubbo
dubbo
${dubbo.version}
org.springframework
spring
javax.servlet
servlet-api
log4j
log4j
登录后复制
创建公共接口模块
pom文件
4.0.0
dubbo-nacos-example
ah.wideth
1.0-SNAPSHOT
public-api
public-api
api公用接口
jar
1.8
utf-8
UTF-8
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-maven-plugin
登录后复制
公共接口模块里面只有一个接口，没有配置文件，打jar包
package ah.wideth.api;
/**
* 让生产者和服务消
* 费者来使用这个接口
*/
public interface InfoService {
String getInfo();
}
登录后复制
创建服务提供者模块
pom文件
4.0.0
dubbo-nacos-example
ah.wideth
1.0-SNAPSHOT
dubbo-provider
dubbo-provider
dubbo的服务提供者模块
1.8
utf-8
UTF-8
org.springframework.boot
spring-boot-starter-web
${project.groupId}
public-api
${project.version}
org.springframework.boot
spring-boot-maven-plugin
登录后复制
application.yml配置文件
server:
port: 8180
spring:
application:
name: dubbo-provider
dubbo:
registry:
address: nacos://127.0.0.1:8848 #注册地址
application:
name: dubbo-provider #应用名
protocol:
name: dubbo #dubbo协议
port: 20880 #协议端口
scan:
base-packages: ah.wideth.impl #扫包范围
provider:
timeout: 30000 #超时时间
登录后复制
接口实现类，该类实现了上面我们在公共接口模块创建的接口
package ah.wideth.impl;
import ah.wideth.api.InfoService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Component;
// dubbo提供的Service注解，用于声明对外暴露服务
// Service引入的是org.apache.dubbo.config.annotation.Service包
@Component
@DubboService
public class InfoServiceImpl implements InfoService {
@Override
public String getInfo() {
return "hello，这里是dubbo-provider模块！";
}
}
登录后复制
服务提供者启动类
package ah.wideth;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@EnableDubbo
@EnableDiscoveryClient
@SpringBootApplication
public class DubboProviderApplication {
public static void main(String[] args) {
SpringApplication.run(DubboProviderApplication.class, args);
System.out.println("dubbo服务提供者8180启动了");
}
}
登录后复制
创建服务消费者模块
pom文件
4.0.0
dubbo-nacos-example
ah.wideth
1.0-SNAPSHOT
dubbo-consumer
dubbo-consumer
dubbo的服务消费者模块
1.8
utf-8
UTF-8
org.springframework.boot
spring-boot-starter-web
${project.groupId}
public-api
${project.version}
org.springframework.boot
spring-boot-maven-plugin
登录后复制
application.yml配置文件
server:
port: 8181
spring:
application:
name: dubbo-consumer
dubbo:
registry:
address: nacos://127.0.0.1:8848 #注册地址
application:
name: dubbo-consumer #应用名
consumer:
timeout: 30000 #超时时间
登录后复制
controller，调用公共接口模块创建的接口
package ah.wideth.controller;
import ah.wideth.api.InfoService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class InfoController {
//dumbo提供的Reference注解，用于调用远程服务
@DubboReference(check = false)
private InfoService infoService;
@GetMapping("/getInfo")
public String getInfo(){
return infoService.getInfo();
}
}
登录后复制
服务消费者启动类
package ah.wideth;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@EnableDubbo
@EnableDiscoveryClient
@SpringBootApplication
public class DubboConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(DubboConsumerApplication.class, args);
System.out.println("dubbo服务消费者8181启动了");
}
}
登录后复制
服务调用测试
打开Nacos控制面板查看注册中心中的服务
启动nacos，启动服务提供者和服务消费者，调用服务消费者的getInfo方法，服务提供者会返回结果
本文小结
本文编写了一个例子来对dubbo整合nacos进行服务调用的例子，不过要注意jar包的冲突问题。
