Spring Cloud Alibaba & Spring Cloud 整合Dubbo和Nacos

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 目录一、Spring Cloud Alibaba依赖说明二、代码示例1、父工程spring-cloud-alibaba-learning版本依赖信息2、子工程spring-cloud-alibaba-seata-consumer服务消费者(1) 版本依赖(2) application.yml配置(3) Dubbo服务引用(4) 启动类3、子工程spring-cloud-alibaba-seata-provider服务提供者(1) 版本依赖(2) application.yml配置(3) 服务实现类(4) 启动类三、启动服务&查看Nacos控制台四、总结

目录

一、Spring Cloud Alibaba依赖说明

二、代码示例

1、父工程spring-cloud-alibaba-learning版本依赖信息

2、子工程spring-cloud-alibaba-seata-consumer服务消费者

(1) 版本依赖

(2) application.yml配置

(3) Dubbo服务引用

(4) 启动类

3、子工程spring-cloud-alibaba-seata-provider服务提供者

(1) 版本依赖

(2) application.yml配置

(3) 服务实现类

(4) 启动类

三、启动服务&查看Nacos控制台

四、总结

一、Spring Cloud Alibaba依赖说明



使用Spring Cloud Alibaba与其它组件集成时一定要先看下依赖说明,下图是Spring Cloud Alibaba各组件对应的版本信息。WechatIMG115548.jpeg下图是Spring Cloud AlibabaSpring Cloud以及Spring Boot对应的适配版本关系。

image.png备注:具体版本说明请参考Spring Cloud Alibaba版本说明

二、代码示例



1、父工程spring-cloud-alibaba-learning版本依赖信息

<groupId>com.universe</groupId>
<artifactId>spring-cloud-alibaba-learning</artifactId>
<packaging>pom</packaging>
<version>1.0.0-SNAPSHOT</version>
<modules>
        <module>spring-cloud-alibaba-seata-consumer</module>
        <module>spring-cloud-alibaba-seata-provider</module>
</modules>
<properties>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <spring.boot.version>2.3.12.RELEASE</spring.boot.version>
        <spring.cloud.version>Hoxton.SR12</spring.cloud.version>
        <spring.cloud.alibaba.version>2.2.6.RELEASE</spring.cloud.alibaba.version>
        <commons.lang3.version>3.12.0</commons.lang3.version>
</properties>
<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>${commons.lang3.version}</version>
        </dependency>
</dependencies>
<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>${spring.boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring.cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>${spring.cloud.alibaba.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
</dependencyManagement>

1、这里我们Spring Cloud Alibaba的版本使用的是2.2.6.RELEASE,Spring Cloud的版本是Hoxton.SR12,Spring Boot的版本用的是2.3.12.RELEASE。


2、Spring Cloud Alibaba版本2.2.6.RELEASE也是可以和上述依赖互相兼容的。

2、子工程spring-cloud-alibaba-seata-consumer服务消费者

<parent>
        <groupId>com.universe</groupId>
        <artifactId>spring-cloud-alibaba-learning</artifactId>
        <version>1.0.0-SNAPSHOT</version>
</parent>
<artifactId>spring-cloud-alibaba-seata-consumer</artifactId>
<properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <seata.spring.boot.version>1.4.2</seata.spring.boot.version>
        <mybatis.plus.boot.version>3.5.1</mybatis.plus.boot.version>
        <druid.spring.boot.version>1.2.8</druid.spring.boot.version>
        <mysql.connector.version>8.0.28</mysql.connector.version>
</properties>
<dependencies>
        <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>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.connector.version}</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>${druid.spring.boot.version}</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>${mybatis.plus.boot.version}</version>
        </dependency>
    </dependencies>


(2) application.yml配置

# dubbo configuration
dubbo:
  registry:
    address: nacos://localhost:8848
  consumer:
    check: false
  scan:
    base-packages: com.universe.order.service.impl
spring:
  # datasource configuration
  datasource:
    druid:
      url: jdbc:mysql://localhost:3307/mall_order?serverTimeZone=UTC
      username: root
      password: root
      initial-size: 5
      max-active: 50
      max-wait: 3000
      test-on-borrow: false
      test-on-return: false
      min-idle: 10
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
  cloud:
    nacos:
      discovery:
        enabled: false # 禁用Nacos服务注册和发现
# mybatis-plus configuration
mybatis-plus:
  mapper-locations: classpath:mapper/*.xml
  configuration:
    map-underscore-to-camel-case: true
    call-setters-on-nulls: true


备注:

1、为什么配置dubbo.consumer.check为false呢?

如果服务启动时拉取不到服务提供者列表,启动时会报错。


2、为什么配置spring.cloud.nacos.discovery.enabled为false呢?

因为spring-cloud-starter-alibaba-nacos-discovery中有相关自动配置类会自动做服务注册和服务发现,导致服务启动报错。

(3) Dubbo服务引用

import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.universe.integral.MallIntegralService;
import com.universe.order.common.OrderStatusEnum;
import com.universe.order.mapper.MallOrderMapper;
import com.universe.order.pojo.ApiResponse;
import com.universe.order.pojo.domain.MallOrderDO;
import com.universe.order.service.MallOrderService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
 * @author 刘亚楼
 * @date 2022/4/11
 */
@Service
public class MallOrderServiceImpl implements MallOrderService {
  @Autowired
  private MallOrderMapper mallOrderMapper;
  @DubboReference(timeout = 3000)
  private MallIntegralService mallIntegralService;
  @Override
  public ApiResponse<Void> finishOrder(String orderNo, Long userId) {
    Wrapper<MallOrderDO> wrapper = Wrappers.<MallOrderDO>lambdaQuery().eq(MallOrderDO::getOrderNo, orderNo);
    MallOrderDO mallOrderDO = mallOrderMapper.selectOne(wrapper);
    if (mallOrderDO == null) {
      return ApiResponse.error("B0001");
    }
    mallOrderDO.setOrderStatus(OrderStatusEnum.FINISHED.getStatus());
    mallOrderDO.setUpdateTime(System.currentTimeMillis());
    Wrapper<MallOrderDO> updateWrapper = Wrappers.<MallOrderDO>lambdaUpdate().eq(MallOrderDO::getOrderNo, orderNo);
    mallOrderMapper.update(mallOrderDO, updateWrapper);
    return null;
  }
}

(4) 启动类

@MapperScan(basePackages = "com.universe.integral.mapper")
@SpringBootApplication
public class Application {
  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}


3、子工程spring-cloud-alibaba-seata-provider服务提供者

(1) 版本依赖

<parent>
        <artifactId>spring-cloud-alibaba-learning</artifactId>
        <groupId>com.universe</groupId>
        <version>1.0.0-SNAPSHOT</version>
</parent>
    <artifactId>spring-cloud-alibaba-seata-provider</artifactId>
<properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <seata.spring.boot.version>1.4.2</seata.spring.boot.version>
        <mybatis.plus.boot.version>3.5.1</mybatis.plus.boot.version>
        <druid.spring.boot.version>1.2.8</druid.spring.boot.version>
        <mysql.connector.version>8.0.28</mysql.connector.version>
</properties>
<dependencies>
        <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>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.connector.version}</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>${druid.spring.boot.version}</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>${mybatis.plus.boot.version}</version>
        </dependency>
    </dependencies>

(2) application.yml配置

# dubbo configuration
dubbo:
  registry:
    address: nacos://localhost:8848
  protocol:
    port: 20881
    name: dubbo # 这配置不能丢,丢了会报错
  scan:
    base-packages: com.universe.integral.service.impl
spring:
  # datasource configuration
  datasource:
    druid:
      url: jdbc:mysql://localhost:3307/mall_integral?serverTimeZone=UTC
      username: root
      password: root
      initial-size: 5
      max-active: 50
      max-wait: 3000
      test-on-borrow: false
      test-on-return: false
      min-idle: 10
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
  cloud:
    nacos:
      discovery:
        enabled: false # 禁用Nacos服务自动发现
# mybatis-plus configuration
mybatis-plus:
  mapper-locations: classpath:mapper/*.xml
  configuration:
    map-underscore-to-camel-case: true
    call-setters-on-nulls: true


422cb2ecf0684ed5871348bbfd443b87.png

(3) 服务实现类

package com.universe.integral.service.impl;
import com.universe.integral.mapper.UserIntegralMapper;
import com.universe.integral.pojo.ApiResponse;
import com.universe.integral.pojo.request.AddUserIntegralRequest;
import com.universe.integral.service.MallIntegralService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;
/**
 * @author 刘亚楼
 * @date 2022/4/11
 */
@DubboService
public class MallIntegralServiceImpl implements MallIntegralService {
  @Autowired
  private UserIntegralMapper userIntegralMapper;
  @Override
  public ApiResponse<AddUserIntegralRequest> dispatchUserIntegral(AddUserIntegralRequest request) {
    return null;
  }
}


(4) 启动类

@MapperScan(basePackages = "com.universe.integral.mapper")
@SpringBootApplication
public class Application {
  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}

三、启动服务&查看Nacos控制台


8f6b33a1729347c68064186352a839fa.png

四、总结



2、spring-cloud-starter-dubbo依赖会引入dubbo-spring-boot-starter依赖,这里我们使用的dubbo版本是2.7.8。


3、注意禁用spring-cloud-starter-alibaba-nacos-discovery的服务自动注册和发现,或者如果我们不禁用,可以通过@SpringBootApplication注解排除NacosServiceRegistryAutoConfiguration和NacosDiscoveryClientConfiguration的自动配置,如下:

764a7aa12ddb415f9befe33a7965e606.png

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
25天前
|
监控 Java Nacos
使用Spring Boot集成Nacos
通过上述步骤,Spring Boot应用可以成功集成Nacos,利用Nacos的服务发现和配置管理功能来提升微服务架构的灵活性和可维护性。通过这种集成,开发者可以更高效地管理和部署微服务。
153 17
|
23天前
|
人工智能 安全 Java
AI 时代:从 Spring Cloud Alibaba 到 Spring AI Alibaba
本次分享由阿里云智能集团云原生微服务技术负责人李艳林主讲,主题为“AI时代:从Spring Cloud Alibaba到Spring AI Alibaba”。内容涵盖应用架构演进、AI agent框架发展趋势及Spring AI Alibaba的重磅发布。分享介绍了AI原生架构与传统架构的融合,强调了API优先、事件驱动和AI运维的重要性。同时,详细解析了Spring AI Alibaba的三层抽象设计,包括模型支持、工作流智能体编排及生产可用性构建能力,确保安全合规、高效部署与可观测性。最后,结合实际案例展示了如何利用私域数据优化AI应用,提升业务价值。
|
2月前
|
SpringCloudAlibaba 负载均衡 Dubbo
【SpringCloud Alibaba系列】Dubbo高级特性篇
本章我们介绍Dubbo的常用高级特性,包括序列化、地址缓存、超时与重试机制、多版本、负载均衡。集群容错、服务降级等。
【SpringCloud Alibaba系列】Dubbo高级特性篇
|
2月前
|
存储 SpringCloudAlibaba Java
【SpringCloud Alibaba系列】一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论
一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论。
【SpringCloud Alibaba系列】一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论
|
2月前
|
SpringCloudAlibaba JavaScript Dubbo
【SpringCloud Alibaba系列】Dubbo dubbo-admin安装教程篇
本文介绍了 Dubbo-Admin 的安装和使用步骤。Dubbo-Admin 是一个前后端分离的项目,前端基于 Vue,后端基于 Spring Boot。安装前需确保开发环境(Windows 10)已安装 JDK、Maven 和 Node.js,并在 Linux CentOS 7 上部署 Zookeeper 作为注册中心。
【SpringCloud Alibaba系列】Dubbo dubbo-admin安装教程篇
|
2月前
|
SpringCloudAlibaba Dubbo Java
【SpringCloud Alibaba系列】Dubbo基础入门篇
Dubbo是一款高性能、轻量级的开源Java RPC框架,提供面向接口代理的高性能RPC调用、智能负载均衡、服务自动注册和发现、运行期流量调度、可视化服务治理和运维等功能。
【SpringCloud Alibaba系列】Dubbo基础入门篇
|
1月前
|
人工智能 自然语言处理 Java
Spring Cloud Alibaba AI 入门与实践
本文将介绍 Spring Cloud Alibaba AI 的基本概念、主要特性和功能,并演示如何完成一个在线聊天和在线画图的 AI 应用。
293 7
|
2月前
|
Java Nacos Sentinel
Spring Cloud Alibaba:一站式微服务解决方案
Spring Cloud Alibaba(简称SCA) 是一个基于 Spring Cloud 构建的开源微服务框架,专为解决分布式系统中的服务治理、配置管理、服务发现、消息总线等问题而设计。
378 13
Spring Cloud Alibaba:一站式微服务解决方案
|
3月前
|
存储 Java Nacos
Spring Cloud+Nacos+KMS 动态配置最佳实践
本文讲述了 Spring Cloud 应用中结合 Nacos 实现了运行期配置动态更新的功能,以及在此基础上结合 KMS 在不改动代码的情况下对应用使用的敏感配置进行保护,解决将配置迁移到 Nacos 中可能存在的数据安全顾虑,并对其底层工作原理做了简单介绍。
674 19
|
2月前
|
负载均衡 Java 开发者
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
191 5