Spring Cloud Alibaba 实操 (十二) 集成dubbo

简介: 集成dubbo

1.概述

在之前 《什么是 Spring Cloud Alibaba》一文中我们有介绍过Dubbo,除了SpringCloud以外,Dubbo它也是用来作为微服务架构落地的成熟解决方案,并且它在服务通信上比SpringCloud性能更高,这取决于它的底层实现是基于原生的TCP协议,它的定位就是一款高性能的RPC(远程过程调用)框架,所以在国内很多的企业都选择Dubbo作为微服务框架,本文章的目的是帮助同学们将Dubbo这款高性能的RPC框架集成到SpringCloud中,真正实现SpringCloud 和 Dubbo的混用。

2.项目结构准备

我们采用多模块的方式来样式该案例,这里的工程分为一个父工程,一个提供者服务,一个消费者服务,一个公共的API模块,如下:

spring-cloud-alibaba
  springcloudalibaba-dubbo-api
  springcloudalibaba-dubbo-consumer-1080
  springcloudalibaba-dubbo-server-1070

注意:这里的 springcloudalibaba-dubbo-api模块是把公共的API接口进行抽取,如下图:
image.png

这里我们案例的流程是:消费者服务向提供者服务发起调用,提供者服务需要提供并返回数据,消费者获取到数据进行消费

3. API接口

这里我们 修改:springcloudalibaba-dubbo-api , 创建一个接口

//用户的API接口
public interface UserService {
   
   
    String getUserInfo(Long id);
}

注意:这个接口是公用的,消费者和提供者都会用到,所以消费者和提供者都需要依赖这个模块,请看后续....

4.提供者服务

4.1.导入依赖

修改 springcloudalibaba-dubbo-provider-1070 ,导入依赖,
这里提供者服务依赖了 dubbo-api 接口模块,导入了dubbo的依赖以及nacos服务发现的依赖如下:

<dependencies>
    <!-- 第一步中构建的API包 -->
    <dependency>
      <groupId>org.example</groupId>
      <artifactId>springcloudalibaba-dubbo-api</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
    <!--    监控的依赖-->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
<!--    整合dubbo-->
    <dependency>
      <groupId>com.alibaba.cloud</groupId>
      <artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
        <!--   nacos服务发现-->
    <dependency>
      <groupId>com.alibaba.cloud </groupId>
      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
  </dependencies>

4.2.主启动类

这里启用了服务发现功能

/**
 *主程序启动类
 */
@SpringBootApplication
@EnableDiscoveryClient  //开启服务发现客户端
public class DubboProviderApplication1070
{
   
   
    public static void main( String[] args )
    {
   
   
        SpringApplication.run(DubboProviderApplication1070.class);
    }
}

4.3.接口实现

该实现是提供者服务的具体服务的实现,在这里去实现 UserService 接口,返回相关的数据,消费者调用提供者的时候就是调用的该实现,---- 我们可以简单的理解为这里暴露了一个服务准备让消费者去调用。

//用户的API接口实现
//@Service : dubbo的注解 , 通过该注解把api发布出去
@org.apache.dubbo.config.annotation.Service
public class UserServiceImpl implements UserService {
   
   
    @Override
    public String getUserInfo(Long id) {
   
   
        return "成功获取到用户信息";
    }
}

需要注意的是,这里使用的是 dubbo的@Service注解,意思是发布一个远程服务

4.4.yml配置文件

spring:
  application:
    name: dubbo-provider
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #nacos注册中心
  main:
    allow-bean-definition-overriding: true #设置是否覆盖Bean定义 ,防止bean的重复定义而报错
server:
  port: 1070
dubbo:
  scan:
    base-packages: org.example.service #dubbo 的api实现类扫描包
  protocol:
    name: dubbo #通信协议:dubbo
    port: 20880 #dubbo通信端口
  registry:
    address: spring-cloud://localhost #注册中心地址,使用springcloud的注册中心

这里配置了 nacos.discovery 注册中心地址 , dubbo.scan 这里指向的是接口实现类所在的包,protocol 协议名字指定的是 dubbo,端口 20880 ,通过 dubbo.registry.address=spring-cloud 来指定使用SpringCloud的注册中心

到这里我们的服务提供者告一段落,就是简单的配置了一个用户服务实现,通过Dubbo暴露出去,接下来我们来配置消费者服务

5.消费者服务

5.1.导入依赖

修改 springcloudalibaba-dubbo-consumer-1080 ,导入依赖,消费者的依赖和提供者的依赖差不多,都需要公共的dubbo-api模块,以及dubbo的依赖和服务发现的依赖

<dependencies>
    <!-- 第一步中构建的API包 -->
    <dependency>
      <groupId>org.example</groupId>
      <artifactId>springcloudalibaba-dubbo-api</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!--    整合dubbo-->
    <dependency>
      <groupId>com.alibaba.cloud</groupId>
      <artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <dependency>
      <groupId>com.alibaba.cloud </groupId>
      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
  </dependencies>

5.2.主启动类

/**
 *主程序启动类
 */
@SpringBootApplication
@EnableDiscoveryClient  //开启服务发现客户端
public class DubboConsumerApplication1080
{
   
   
    public static void main( String[] args )
    {
   
   
        SpringApplication.run(DubboConsumerApplication1080.class);
    }
}

5.3.控制器

编写一个测试的控制器

@RestController
public class UserController {
   
   

    @org.apache.dubbo.config.annotation.Reference
    private UserService userService ;

    @GetMapping("/userinfo/{id}")
    public String getUserInfo(@PathVariable("id")Long id){
   
   
        return userService.getUserInfo(id);
    }
}

这里通过 userService.getUserInfo 实现远程服务的调用,感觉在调用本地Service,其实不是,在UserService上使用的是@Reference标签而不是@Autowired 自动注入,通过@Reference标签,Dubbo会自动代理UserServcie,实现服务的远程调用,所以这里其实调用的是提供者服务的UserService实现。

5.4.yml配置

spring:
  application:
    name: dubbo-consumer
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #nacos注册中心
  main:
    allow-bean-definition-overriding: true #设置是否覆盖Bean定义 ,防止bean的重复定义而报错
server:
  port: 1080
dubbo:
  scan:
    base-packages: org.example.service #dubbo 的api实现类扫描包
  protocol:
    name: dubbo #通信协议:dubbo
    port: 20881 #dubbo通信端口
  registry:
    address: spring-cloud://localhost #注册中心地址,使用springcloud的注册中心
  cloud:
    subscribed-services: dubbo-provider #订阅的服务,指向提供者的服务名

这里同样使用Nacos作为注册中心,通过dubbo.scan.base-packages配置了dubbo的扫描包,主要是扫描 @Reference注解,通过dubbo.protocol配置了dubbo相关协议,通过dubbo.registry.address配置注册中心地址使用SpringCloud的注册中心。

需要注意的是 这里通过 subscribed-services:订阅了提供者服务,即要向谁发起请求这里就要跟上谁的服务名

6. 测试

依次启动Nacos注册中心,提供者服务,消费者服务,启动 Nacos ,启动 提供者,启动消费者, 浏览器访问 :http://localhost:1080/userinfo/111 ,不出意外应该会返回如下信息:
image.png

这个返回结果是消费者服务从提供者服务那儿获取到的结果并返回给浏览器,说明使用Dubbo实现服务的通信已经搞定了。

7. 总结

我们用一个图来理解一下Dubbo实现远程服务调用过程
image.png

1.首先提供者服务对UserService做了实现,并且通过 @Service发布服务

2.消费者服务在Controller中通过@Reference引入UserService ,该UserServer接口当然也会被代理掉,在调用接口时会向提供者发起远程访问

3.提供者监听到请求,执行相关的业务逻辑,并返回数据

4.消费者获取到结果,最终把数据展示到浏览器上

有兴趣的小伙伴可以去了解一下Dubbo的底层工作机制哟....

目录
相关文章
|
19天前
|
Dubbo Java 应用服务中间件
Spring Cloud Dubbo:微服务通信的高效解决方案
【10月更文挑战第15天】随着信息技术的发展,微服务架构成为企业应用开发的主流。Spring Cloud Dubbo结合了Dubbo的高性能RPC和Spring Cloud的生态系统,提供高效、稳定的微服务通信解决方案。它支持多种通信协议,具备服务注册与发现、负载均衡及容错机制,简化了服务调用的复杂性,使开发者能更专注于业务逻辑的实现。
44 2
|
6天前
|
人工智能 前端开发 Java
基于开源框架Spring AI Alibaba快速构建Java应用
本文旨在帮助开发者快速掌握并应用 Spring AI Alibaba,提升基于 Java 的大模型应用开发效率和安全性。
基于开源框架Spring AI Alibaba快速构建Java应用
|
26天前
|
JSON SpringCloudAlibaba Java
Springcloud Alibaba + jdk17+nacos 项目实践
本文基于 `Springcloud Alibaba + JDK17 + Nacos2.x` 介绍了一个微服务项目的搭建过程,包括项目依赖、配置文件、开发实践中的新特性(如文本块、NPE增强、模式匹配)以及常见的问题和解决方案。通过本文,读者可以了解如何高效地搭建和开发微服务项目,并解决一些常见的开发难题。项目代码已上传至 Gitee,欢迎交流学习。
100 1
Springcloud Alibaba + jdk17+nacos 项目实践
|
14天前
|
消息中间件 自然语言处理 Java
知识科普:Spring Cloud Alibaba基本介绍
知识科普:Spring Cloud Alibaba基本介绍
45 2
|
20天前
|
人工智能 开发框架 Java
总计 30 万奖金,Spring AI Alibaba 应用框架挑战赛开赛
Spring AI Alibaba 应用框架挑战赛邀请广大开发者参与开源项目的共建,助力项目快速发展,掌握 AI 应用开发模式。大赛分为《支持 Spring AI Alibaba 应用可视化调试与追踪本地工具》和《基于 Flow 的 AI 编排机制设计与实现》两个赛道,总计 30 万奖金。
|
21天前
|
人工智能 Java API
阿里云开源 AI 应用开发框架:Spring AI Alibaba
近期,阿里云重磅发布了首款面向 Java 开发者的开源 AI 应用开发框架:Spring AI Alibaba(项目 Github 仓库地址:alibaba/spring-ai-alibaba),Spring AI Alibaba 项目基于 Spring AI 构建,是阿里云通义系列模型及服务在 Java AI 应用开发领域的最佳实践,提供高层次的 AI API 抽象与云原生基础设施集成方案,帮助开发者快速构建 AI 应用。本文将详细介绍 Spring AI Alibaba 的核心特性,并通过「智能机票助手」的示例直观的展示 Spring AI Alibaba 开发 AI 应用的便利性。示例源
|
22天前
|
Dubbo Java 应用服务中间件
Dubbo学习圣经:从入门到精通 Dubbo3.0 + SpringCloud Alibaba 微服务基础框架
尼恩团队的15大技术圣经,旨在帮助开发者系统化、体系化地掌握核心技术,提升技术实力,从而在面试和工作中脱颖而出。本文介绍了如何使用Dubbo3.0与Spring Cloud Gateway进行整合,解决传统Dubbo架构缺乏HTTP入口的问题,实现高性能的微服务网关。
|
26天前
|
人工智能 Java API
阿里云开源 AI 应用开发框架:Spring AI Alibaba
阿里云开源 Spring AI Alibaba,旨在帮助 Java 开发者快速构建 AI 应用,共同构建物理新世界。
|
2月前
|
人工智能 前端开发 Java
Spring Cloud Alibaba AI,阿里AI这不得玩一下
🏀闪亮主角: 大家好,我是JavaDog程序狗。今天分享Spring Cloud Alibaba AI,基于Spring AI并提供阿里云通义大模型的Java AI应用。本狗用SpringBoot+uniapp+uview2对接Spring Cloud Alibaba AI,带你打造聊天小AI。 📘故事背景: 🎁获取源码: 关注公众号“JavaDog程序狗”,发送“alibaba-ai”即可获取源码。 🎯主要目标:
68 0
|
4月前
|
监控 druid Java
spring boot 集成配置阿里 Druid监控配置
spring boot 集成配置阿里 Druid监控配置
271 6