基于rpc框架Dubbo实现的微服务转发实战

news2025/7/27 20:44:23

rpc微服务模块

导入依赖

配置dubbo

注解开启Dubbo

Dubbo的使用

特殊点并没有使用 @ Reference 注入

微服务之间调用

可以选用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

@EnableDubbo

package 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就行