导航：首页 > 互联网科技 >

Spring Cloud Alibaba+Nacos+Dubbo如何进行零成本实现RPC调用

发表于：2025-02-04 作者：千家信息网编辑

千家信息网最后更新 2025年02月04日，Spring Cloud Alibaba+Nacos+Dubbo如何进行零成本实现RPC调用，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题

千家信息网最后更新 2025年02月04日Spring Cloud Alibaba+Nacos+Dubbo如何进行零成本实现RPC调用

Spring Cloud Alibaba+Nacos+Dubbo如何进行零成本实现RPC调用，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

dubbo的rpc框架学习成本较高，代码入侵性强，本身生态不完整，需要整合多个外部组件，故选择了相对性能弱一点的Spring Cloud全家桶。

直到Spring Cloud Alibaba的出现，使用Nacos作为服务发现与注册，同时兼容使用Feign的http方式和使用dubbo的rpc方式调用。

Spring Cloud 为什么需要RPC

在Spring Cloud构建的微服务系统中，大多数的开发者使用都是官方提供的Feign组件来进行内部服务通信，这种声明式的HTTP客户端使用起来非常的简洁、方便、优雅，并且和开发平台、语言无关，但是通常情况下，HTTP并不会开启KeepAlive功能，即当前连接为短连接，短连接的缺点是每次请求都需要建立TCP连接，这使得其效率变的相当低下。

对外部提供REST API服务是一件非常好的事情，但是如果内部调用也是使用HTTP调用方式，就会显得显得性能低下，Spring Cloud默认使用的Feign组件进行内部服务调用就是使用的HTTP协议进行调用，这时，我们如果内部服务使用RPC调用，对外使用REST API，将会是一个非常不错的选择。

引用至：Dubbo 与 Spring Cloud 完美结合

使用Dubbo Spring Cloud使用内部的RPC协议调用几乎是零成本的改造。

一、系统结构

cloud-gateway 作为cloud集群的网关，外部的路由转发使用http协议，内部的服务调用使用dubbo协议
cloud-user和cloud-mq之间的远程调用使用dubbo协议
使用Nacos作为服务注册与发现和配置中心的服务
使用Sentinel作为服务间http和dubbo调用的流量控制服务

目录结构

├── cloud-admin         # 服务监控├── cloud-gateway       # 服务网关├── cloud-mq            # mq服务├── cloud-provider      # 服务接口└── cloud-user          # user服务

二、服务接口提供方实现

1. 服务接口定义

public interface UserProvider {    UserDTO checkUser(String userName, String password);    UserDTO findByUserName(String userName);}@Data@Builder@NoArgsConstructor@AllArgsConstructorpublic class UserDTO implements Serializable {    String userName;    String realName;    String password;}

服务接口是服务提供方和消费方的契约，包含服务的方法传输对象DTO。由于涉及多个应用服务的引入，最好是将其独立成Module
DTO对象必须实现Serializable接口

2. 引入dubbo包

POM

     com.alibaba.cloud    spring-cloud-starter-dubbo    org.springframework.boot    spring-boot-starter-actuator

spring-boot-starter-actuator 也是必须的

3. 服务接口实现

import org.apache.dubbo.config.annotation.Service;@Servicepublic class UserProviderImpl implements UserProvider {    @Autowired    private UserService userService;    @Override    public UserDTO checkUser(String userName, String password) {        User user = userService.checkUser(userName, password);        return UserConvertor.toDTO(user);    }}

@Service必须是org.apache.dubbo.config.annotation.Service

4. 配置dubbo服务相关的信息

spring:  main:    allow-bean-definition-overriding: true    dubbo:  scan:    base-packages: fun.barryhome.cloud.provider   #指定 Dubbo 服务实现类的扫描基准包  protocols:    dubbo:      name: dubbo   # Dubbo 的协议名称      port: -1      # port 为协议端口（ -1 表示自增端口，从 20880 开始）  registry:    address: spring-cloud://localhost       # 挂载到 Spring Cloud 注册中心

启动后有可能出现连接失败，不影响使用

java.net.ConnectException: Connection refused (Connection refused)        at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.8.0_111]        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[na:1.8.0_111]        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_111]

三、服务调用方实现

1. 引入依赖包

    fun.barryhome    cloud-provider    0.0.1-SNAPSHOT    compile     com.alibaba.cloud    spring-cloud-starter-dubbo    org.springframework.boot    spring-boot-starter-actuator

2. 调用服务接口

import org.apache.dubbo.config.annotation.Reference;public class UserController {    @Reference    private UserProvider userProvider;    @GetMapping(value = "/sessionUser")    public UserDTO sessionUser(HttpServletRequest request) {        String userName = request.getHeader("X-User-Name");        if (Strings.isEmpty(userName)) {            throw new RuntimeException("没有找到用户");        }        return userProvider.findByUserName(userName);    }}

3. 配置dubbo服务相关的信息

dubbo:  cloud:    subscribed-services: cloud-user   # 服务提供方的服务名  consumer:    check: false    loadbalance: "leastactive"    # 最小活跃数负载均衡  registry:    # 挂载到 Spring Cloud 注册中心    address: spring-cloud://localhost

dubbo.consumer.check：用于启动时是否检查服务提供方是否运行正常，如果不正常将不能启动调用方

dubbo.consumer.loadbalance：负载均衡策略