目录
微服务之间调用
可以选用Http 也可以Dubbo
我们 Dubbo 的实现需要一个注册中心
我作为一个服务的提供者 我需要把我的服务注册到注册中心去
调用方需要注册中心去把服务拉过来
注册中心是一个桥梁
我们之前是使用nacos作为配置中心的
rpc微服务模块
我们定义一个微服务模块叫rpc
导入依赖
<dependencies>
<!-- dubbo -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-registry-nacos</artifactId>
</dependency>
<dependency>
<groupId>cn.hollis</groupId>
<artifactId>nft-turbo-base</artifactId>
</dependency>
</dependencies>配置dubbo
一开始是一个检查 检查dubbo调用者是否存在
# Dubbo 配置的根节点，用于配置 Dubbo 框架的相关参数
dubbo:
# 消费者配置，用于设置 Dubbo 服务消费者的相关参数
consumer:
# 服务调用超时时间，单位为毫秒。这里设置为 3000 毫秒，即 3 秒。
# 若服务调用在 3 秒内未返回结果，将抛出超时异常
timeout: 3000
# 启动时是否检查提供者是否存在。设置为 false 表示启动时不检查，
# 即使没有可用的提供者，消费者也能正常启动
check: false
# 协议配置，用于设置 Dubbo 服务通信所使用的协议
protocol:
# 协议名称，这里使用 Dubbo 原生协议进行服务调用
name: dubbo
# 协议端口号。设置为 -1 表示自动选择一个可用端口
port: -1
# 注册中心配置，用于配置 Dubbo 服务的注册与发现信息
registry:
# 注册中心地址，使用 Nacos 作为注册中心。
# ${nft.turbo.nacos.server.url} 是一个占位符，实际值会从配置文件中获取
address: nacos://${nft.turbo.nacos.server.url}
# 注册中心的额外参数配置
parameters:
# Nacos 命名空间，用于隔离不同环境或项目的服务。
# ${nft.turbo.dubbo.nacos.namespace} 是占位符，实际值从配置文件获取
namespace: ${nft.turbo.dubbo.nacos.namespace}
# Nacos 分组，用于对服务进行分组管理。
# ${nft.turbo.dubbo.nacos.group} 是占位符，实际值从配置文件获取
group: ${nft.turbo.dubbo.nacos.group}
# 应用配置，用于设置当前 Dubbo 应用的相关信息
application:
# 应用名称，使用 Spring 应用的名称。
# ${spring.application.name} 是占位符，实际值从 Spring 配置文件获取
name: ${spring.application.name}
# 是否启用 QoS（Quality of Service）功能。QoS 提供了一个命令行工具，
# 可用于在运行时管理 Dubbo 应用，如查看服务列表、关闭服务等。设置为 true 表示启用
qos-enable: true
# QoS 是否允许外部 IP 访问。设置为 false 表示只允许本地 IP 访问 QoS 服务，
# 增强了安全性，防止外部非法访问
qos-accept-foreign-ip: false我们使用命名空间给一系列调用中心归类 用于隔离不同环境或项目的服务
注解 开启Dubbo
@EnableDubbopackage cn.hollis.nft.turbo.rpc.config;
import cn.hollis.nft.turbo.rpc.facade.FacadeAspect;
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Rpc 配置
*
* @author hollis
*/
@EnableDubbo
@Configuration
public class RpcConfiguration {
@Bean
public FacadeAspect facadeAspect() {
return new FacadeAspect();
}
}
我们接下来的引用
jar包 + 配置
Dubbo的使用
注册的话我们直接使用 @ DubboService 注解即可
这个注解说明的当前类不仅仅是一个 Service
而且要注册到 注册中心里面去 用Dubbo进行一个调用
当你要进行远程调用的时候
你可以使用 @ DubboReference 注解 去调用服务提供者
特殊点 并没有使用 @ Reference 注入
绕一把
package cn.hollis.nft.turbo.user.infrastructure;
import cn.hollis.nft.turbo.api.chain.service.ChainFacadeService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 该配置类用于配置 Dubbo 服务引用，并将其注册为 Spring Bean。
* 主要负责引用链服务接口，并在 Spring 容器中管理该服务实例。
*
* @author Hollis
*/
@Configuration
public class UserDubboConfiguration {
/**
* 使用 Dubbo 的 @DubboReference 注解引用远程的 ChainFacadeService 服务。
* version = "1.0.0" 表示引用版本号为 1.0.0 的服务。
* 该注解会将远程服务代理注入到当前字段中，以便在本地使用。
*/
@DubboReference(version = "1.0.0")
private ChainFacadeService chainFacadeService;
/**
* 定义一个 Spring Bean，Bean 的名称默认为方法名 "chainFacadeService"。
* @ConditionalOnMissingBean 注解表示只有当 Spring 容器中不存在名称为 "chainFacadeService" 的 Bean 时，
* 才会执行此方法来创建该 Bean。
* 该方法返回之前通过 @DubboReference 注解注入的 ChainFacadeService 实例，
* 从而将 Dubbo 引用的服务注册为 Spring Bean，方便在 Spring 应用中使用。
*
* @return ChainFacadeService 实例
*/
@Bean
@ConditionalOnMissingBean(name = "chainFacadeService")
public ChainFacadeService chainFacadeService() {
return chainFacadeService;
}
}为了单测...
如果单元测试的话 还是会远程代理bean进行调用
是不能mock掉的
而autowired是可以进行mock的
@ MockBean就行
