Spring Cloud Alibaba & Spring Cloud 整合Dubbo和Nacos

本文涉及的产品
RDS AI 助手,专业版
RDS MySQL DuckDB 分析主实例,集群系列 4核8GB
RDS MySQL DuckDB 分析主实例,基础系列 4核8GB
简介: 目录一、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

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
相关文章
|
5月前
|
人工智能 Java Nacos
基于 Spring AI Alibaba + Nacos 的分布式 Multi-Agent 构建指南
本文将针对 Spring AI Alibaba + Nacos 的分布式多智能体构建方案展开介绍,同时结合 Demo 说明快速开发方法与实际效果。
4329 85
|
5月前
|
人工智能 运维 Java
Spring AI Alibaba Admin 开源!以数据为中心的 Agent 开发平台
Spring AI Alibaba Admin 正式发布!一站式实现 Prompt 管理、动态热更新、评测集构建、自动化评估与全链路可观测,助力企业高效构建可信赖的 AI Agent 应用。开源共建,现已上线!
6626 90
|
5月前
|
人工智能 监控 Java
Spring AI Alibaba实践|后台定时Agent
基于Spring AI Alibaba框架,可构建自主运行的AI Agent,突破传统Chat模式限制,支持定时任务、事件响应与人工协同,实现数据采集、分析到决策的自动化闭环,提升企业智能化效率。
Spring AI Alibaba实践|后台定时Agent
|
SpringCloudAlibaba API 开发者
新版-SpringCloud+SpringCloud Alibaba
新版-SpringCloud+SpringCloud Alibaba
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要,常用于异步数据处理、自动化运维等场景。在单体应用中,利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而,进入微服务架构后,任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块,提供轻量级、高可用的分布式定时任务解决方案,支持防重复执行、分片运行等功能,并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案(如ShedLock)
492 1
|
负载均衡 Dubbo Java
Spring Cloud Alibaba与Spring Cloud区别和联系?
Spring Cloud Alibaba与Spring Cloud区别和联系?
|
人工智能 SpringCloudAlibaba 自然语言处理
SpringCloud Alibaba AI整合DeepSeek落地AI项目实战
在现代软件开发领域,微服务架构因其灵活性、可扩展性和模块化特性而受到广泛欢迎。微服务架构通过将大型应用程序拆分为多个小型、独立的服务,每个服务运行在其独立的进程中,服务与服务间通过轻量级通信机制(通常是HTTP API)进行通信。这种架构模式有助于提升系统的可维护性、可扩展性和开发效率。
4758 2
|
SpringCloudAlibaba 负载均衡 Dubbo
【SpringCloud Alibaba系列】Dubbo高级特性篇
本章我们介绍Dubbo的常用高级特性,包括序列化、地址缓存、超时与重试机制、多版本、负载均衡。集群容错、服务降级等。
1973 7
【SpringCloud Alibaba系列】Dubbo高级特性篇
|
Java Nacos Sentinel
Spring Cloud Alibaba:一站式微服务解决方案
Spring Cloud Alibaba(简称SCA) 是一个基于 Spring Cloud 构建的开源微服务框架,专为解决分布式系统中的服务治理、配置管理、服务发现、消息总线等问题而设计。
2956 13
Spring Cloud Alibaba:一站式微服务解决方案
|
存储 SpringCloudAlibaba Java
【SpringCloud Alibaba系列】一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论
一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论。
【SpringCloud Alibaba系列】一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论

热门文章

最新文章