【SpringCloud Alibaba】 介绍及微服务模块搭建

2024-01-22 19:20
文章标签 java 模块 服务 介绍 spring 搭建 springcloud alibaba 及微

本文主要是介绍【SpringCloud Alibaba】 介绍及微服务模块搭建，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • SpringCloud Alibaba 介绍
    • 主要功能
    • 组件
  • 微服务环境搭建
    • 案例准备
      • 技术选型
      • 模块设计
      • 微服务调用
    • 创建父工程
    • 创建基础模块
      • 1、创建 shop-common 模块
      • 2、创建实体类
    • 创建用户微服务
      • 1、创建`pom.xml`
      • 2、编写主类
      • 3、创建配置文件
    • 创建商品微服务
      • 1、创建一个名为 shop-product 的模块
      • 2、创建工程的主类
      • 3、创建配置文件
      • 4、创建 controller-service-dao
      • 5、启动工程，等到数据库表创建完毕之后，加入测试数据
      • 6、通过浏览器访问服务
    • 创建订单微服务
      • 1、创建一个名为shop-order的模块
      • 2、创建工程的主类
      • 3、创建配置文件
      • 4、创建 controller-service-dao
      • 5、创建启动类
      • 6、通过浏览器访问
  • 总结

欢迎来到阿Q社区
https://bbs.csdn.net/topics/617897123

SpringCloud Alibaba 介绍

Spring Cloud Alibaba 致力于提供微服务开发的一站式解决方案。此项目包含开发分布式应用微服务的必需组件，方便开发者通过Spring Cloud编程模型轻松使用这些组件来开发分布式应用服务。

依托Spring Cloud Alibaba ，只需要添加一些注解和少量配置，就可以将Spring Cloud应用接入阿里微服务解决方案，通过阿里中间件来迅速搭建分布式应用系统。

主要功能

  • 服务限流降级：默认支持 WebServlet、WebFlux、OpenFeign、RestTemplate、SpringCloud Gateway、 Zuul、Dubbo和RocketMQ限流降级功能的接入，可以在运行时通过控制台实时修改限流降级规则，还支持查看限流降级Metrics监控。
  • 服务注册与发现：适配Spring Cloud服务注册与发现标准，默认集成了Ribbon的支持。
  • 分布式配置管理：支持分布式系统中的外部化配置，配置更改时自动刷新。
  • 消息驱动能力：基于Spring Cloud Stream为微服务应用构建消息驱动能力。
  • 分布式事务：使用@GlobalTransactional 注解，高效并且对业务零侵入地解决分布式事务问题。
  • 阿里云对象存储：阿里云提供的海量、安全、低成本、高可靠的云存储服务。支持在任何应用、任何时间、任何地点存储和访问任意类型的数据。
  • 分布式任务调度：提供秒级、精准、高可靠、高可用的定时(基于Cron表达式)任务调度服务。同时提供分布式的任务执行模型，如网格任务。网格任务支持海量子任务均匀分配到所有Worker(schedulerx-client)上执行。
  • 阿里云短信服务：覆盖全球的短信服务，友好、高效、智能的互联化通讯能力，帮助企业迅速搭建客户触达通道。

组件

  • Sentinel：把流量作为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
  • Nacos：一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。
  • RocketMQ：一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。
  • Dubbo：Apache Dubbo是一款高性能Java RPC框架。
  • Seata：阿里巴巴开源产品，一个易于使用的高性能微服务分布式事务解决方案。
  • Alibaba Cloud ACM：一款在分布式架构环境中对应用配置进行集中管理和推送的应用配置中心产品。
  • Alibaba Cloud OSS：阿里云对象存储服务(Object Storage Service, 简称OSS)，是阿里云提供的海量、安全、低成本、高可靠的云存储服务。您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。
  • Alibaba Cloud SchedulerX：阿里中间件团队开发的一款分布式任务调度产品，提供秒级、精准、高可靠、高可用的定时(基于Cron表达式)任务调度服务。
  • Alibaba Cloud SMS：覆盖全球的短信服务，友好、高效、智能的互联化通讯能力，帮助企业迅速搭建客户触达通道。

微服务环境搭建

我们本次是使用的电商项目中的商品、订单、用户为案例进行讲解。

案例准备

技术选型

  • maven： 3.3.9
  • 数据库：MySQL5.7
  • 持久层：Mybatis-Plus
  • 其他：SpringCloud Alibaba技术栈

模块设计

  • springcloud-alibaba 父工程；
  • shop-common 公共模块【实体类】；
  • shop-user用户微服务【端口:807x】；
  • shop-product商品微服务【端口:808×】；
  • shop-order订单微服务[端口:809×]

在这里插入图片描述

微服务调用

在微服务架构中，最常见的场景就是微服务之间的相互调用。我们以电商系统中常见的用户下单为例来演示微服务的调用：客户向订单微服务发起一个下单的请求，在进行保存订单之前需要调用商品微服务查询商品的信息。

我们一般把服务的主动调用方称为服务消费者，把服务的被调用方称为服务提供者。

在这里插入图片描述

在这种场景下，订单微服务就是一个服务消费者，商品微服务就是一个服务提供者。

创建父工程

创建一个maven工程，然后在pom.xml文件中添加下面内容

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.3.RELEASE</version></parent><groupId>it.aq.cheetah</groupId><artifactId>microservice</artifactId><version>1.0-SNAPSHOT</version><packaging>pom</packaging><properties><java.version>1.8</java.version><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><spring-cloud.version>Greenwich.RELEASE</spring-cloud.version><spring-cloud-alibaba.version>2.1.0.RELEASE</spring-cloud-alibaba.version></properties><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement></project>

版本对应：

在这里插入图片描述

创建基础模块

1、创建 shop-common 模块

在pom.xml中添加依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>it.aq.cheetah</groupId><artifactId>microservice</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>shop-common</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.0</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.26</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.83</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.31</version></dependency></dependencies></project>

2、创建实体类

//用户信息
@Data
@TableName(value = "shop_user")
public class ShopUser {@TableId(value = "id",type = IdType.AUTO)private Integer id;//主键@TableField("username")private String username;//用户名@TableField("password")private String password;//密码@TableField("telephone")private String telephone;//手机号}//商品信息
@Data
@TableName(value = "shop_product")
public class ShopProduct {@TableId(value = "id",type = IdType.AUTO)private Long id;//主键@TableField("pname")private String pname;//商品名称@TableField("pprice")private Double pprice;//商品价格@TableField("stock")private Integer stock;//库存
}//订单信息
@Data
@TableName(value = "shop_order")
public class ShopOrder {@TableId(value = "id",type = IdType.AUTO)private Long id;//订单id@TableField("uid")private Long uid;//用户id@TableField("username")private String username;//用户名@TableField("pid")private Long pid;//商品id@TableField("pname")private String pname;//商品名称
}

创建用户微服务

  1. 创建模块导入依赖；
  2. 创建 SpringBoot 主类；
  3. 加入配置文件；
  4. 创建必要的接口和实现类(controller-service-dao)；

新建一个shop-user模块，然后进行下面操作

1、创建pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>it.aq.cheetah</groupId><artifactId>microservice</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>shop-user</artifactId><dependencies><dependency><groupId>it.aq.cheetah</groupId><artifactId>shop-common</artifactId><version>1.0-SNAPSHOT</version></dependency></dependencies></project>

2、编写主类

@SpringBootApplication
public class UserApplication {public static void main(String[] args) {SpringApplication.run(UserApplication.class,args);}
}

3、创建配置文件

server:port: 8071#数据库配置
spring:application:name: shop-userdatasource:url: jdbc:mysql://127.0.0.1:3306/microservice?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTCusername: rootpassword: 123456#模板引擎配置thymeleaf:encoding: UTF-8#suffix: .html  默认后缀#prefix: classpath:/templates/  默认前缀mybatis-plus:# 配置mapper的扫描，找到所有的mapper.xml映射文件mapper-locations: classpath:mapper/*Mapper.xml# 加载全局的配置文件config-location: classpath:mybatis-config.xml# 搜索指定包别名typeAliasesPackage: it.aq.cheetah.**.entity

创建商品微服务

1、创建一个名为 shop-product 的模块

添加 springboot 依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>it.aq.cheetah</groupId><artifactId>microservice</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>shop-product</artifactId><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>it.aq.cheetah</groupId><artifactId>shop-common</artifactId><version>1.0-SNAPSHOT</version></dependency></dependencies></project>

2、创建工程的主类

@SpringBootApplication
public class ProductApplication {public static void main(String[] args) {SpringApplication.run(ProductApplication.class,args);}
}

3、创建配置文件

server:port: 8081#数据库配置
spring:application:name: shop-productdatasource:url: jdbc:mysql://127.0.0.1:3306/microservice?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTCusername: rootpassword: 123456#模板引擎配置thymeleaf:encoding: UTF-8#suffix: .html  默认后缀#prefix: classpath:/templates/  默认前缀mybatis-plus:# 配置mapper的扫描，找到所有的mapper.xml映射文件mapper-locations: classpath:mapper/*Mapper.xml# 加载全局的配置文件config-location: classpath:mybatis-config.xml# 搜索指定包别名typeAliasesPackage: it.aq.cheetah.**.entity

4、创建 controller-service-dao

@RestController
@RequestMapping("/product")
@Slf4j
public class ProductController {@Autowiredprivate IProductservice productService;/*** @Description:查询商品信息* @Author: cheetah* @Date: 2024/1/22 9:40* @param id:* @return: it.aq.cheetah.entity.ShopProduct**/@GetMapping("/{id}")public ShopProduct product(@PathVariable("id") Long id) {ShopProduct product = productService.findByPid(id);log.info("查询到商品:" + JSON.toJSONString(product));return product;}/*** @Description:扣减库存* @Author: cheetah* @Date: 2024/1/22 9:40* @param productReduceDTO:* @return: it.aq.cheetah.entity.ShopProduct**/@PostMapping("/reduceStock")public Integer reduceStock(@RequestBody ProductReduceDTO productReduceDTO) {return productService.reduceStock(productReduceDTO);}}@Service
public class ProductServiceImpl implements IProductservice {@Autowiredprivate ProductMapper productMapper;@Overridepublic ShopProduct findByPid(Long pid) {return productMapper.selectById(pid);}@Overridepublic Integer reduceStock(ProductReduceDTO productReduceDTO) {ShopProduct shopProduct = productMapper.selectById(productReduceDTO.getProductId());Integer stock = shopProduct.getStock();if(stock < productReduceDTO.getReductCount()){throw new RuntimeException("库存不足，请联系管理员增加库存");}shopProduct.setStock(stock-productReduceDTO.getReductCount());return productMapper.updateById(shopProduct);}
}@Mapper
public interface ProductMapper extends BaseMapper<ShopProduct> {}

5、启动工程，等到数据库表创建完毕之后，加入测试数据

INSERT INTO shop_product VALUE(NULL,'小米','1000','5000');
INSERT INTO shop_product VALUE(NULL,'华为','2000','5000');
INSERT INTO shop_product VALUE(NULL,'苹果','3000','5000');
INSERT INTO shop_product VALUE(NULL,'OPPO','4000','5000');

6、通过浏览器访问服务

在这里插入图片描述

创建订单微服务

1、创建一个名为shop-order的模块

添加 springboot 依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>it.aq.cheetah</groupId><artifactId>microservice</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>shop-order</artifactId><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>it.aq.cheetah</groupId><artifactId>shop-common</artifactId><version>1.0-SNAPSHOT</version></dependency></dependencies></project>

2、创建工程的主类

@SpringBootApplication
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class,args);}
}

3、创建配置文件

server:port: 8091#数据库配置
spring:application:name: shop-orderdatasource:url: jdbc:mysql://127.0.0.1:3306/microservice?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTCusername: rootpassword: 123456#模板引擎配置thymeleaf:encoding: UTF-8#suffix: .html  默认后缀#prefix: classpath:/templates/  默认前缀mybatis-plus:# 配置mapper的扫描，找到所有的mapper.xml映射文件mapper-locations: classpath:mapper/*Mapper.xml# 加载全局的配置文件config-location: classpath:mybatis-config.xml# 搜索指定包别名typeAliasesPackage: it.aq.cheetah.**.entity

4、创建 controller-service-dao

@RestController
@RequestMapping("/order")
@Slf4j
public class OrderController {@Autowiredprivate IOrderService orderService;@Autowiredprivate RestTemplate restTemplate;@GetMapping("/{pid}")public ShopOrder order(@PathVariable("pid") Long pid) {log.info("客户下单，这时候要调用商品微服务查询商品信息。。。");ShopProduct shopProduct = restTemplate.getForObject("http://127.0.0.1:8081/product/" + pid, ShopProduct.class);log.info("当前用户信息为自己，假设我们设置为1");ShopOrder shopOrder = new ShopOrder();shopOrder.setUid(1L);shopOrder.setUsername("公众号：阿Q说代码");shopOrder.setPid(shopProduct.getId());shopOrder.setPname(shopProduct.getPname());orderService.save(shopOrder);//商品扣减库存的逻辑ProductReduceDTO productReduceDTO = new ProductReduceDTO();productReduceDTO.setProductId(pid);productReduceDTO.setReductCount(1);Integer count = restTemplate.postForObject("http://127.0.0.1:8081/product/reduceStock", productReduceDTO, Integer.class);return shopOrder;}}@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, ShopOrder> implements IOrderService {}@Mapper
public interface OrderMapper extends BaseMapper<ShopOrder> {}

5、创建启动类

@SpringBootApplication
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class,args);}@Beanpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}

6、通过浏览器访问

同时启动商品服务和订单服务，执行http://127.0.0.1:8091/order/1完成后，查看数据库数据

在这里插入图片描述

在这里插入图片描述

总结

到这儿，我们的微服务搭建基本完成了。接下来的文章，我们将继续完善我们的微服务系统，集成更多的Alibaba组件。让我们期待下一篇的文章吧！想要了解更多JAVA后端知识，请点击文末名片与我交流吧。留下您的一键三连，让我们在这个寒冷的东西互相温暖吧！

这篇关于【SpringCloud Alibaba】 介绍及微服务模块搭建的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/633995。

相关文章

Linux搭建ftp服务器的步骤

Linux搭建ftp服务器的步骤

《Linux搭建ftp服务器的步骤》本文给大家分享Linux搭建ftp服务器的步骤,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录ftp搭建1：下载vsftpd工具2：下载客户端工具3：进入配置文件目录vsftpd.conf配置文件4:
阅读更多...
Java 正则表达式的使用实战案例

Java 正则表达式的使用实战案例

《Java正则表达式的使用实战案例》本文详细介绍了Java正则表达式的使用方法,涵盖语法细节、核心类方法、高级特性及实战案例,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录一、正则表达式语法详解1. 基础字符匹配2. 字符类（[]定义）3. 量词（控制匹配次数）4. 边
阅读更多...
Java Scanner类解析与实战教程

Java Scanner类解析与实战教程

《JavaScanner类解析与实战教程》JavaScanner类（java.util包）是文本输入解析工具,支持基本类型和字符串读取,基于Readable接口与正则分隔符实现,适用于控制台、文件输... 目录一、核心设计与工作原理1.底层依赖2.解析机制A.核心逻辑基于分隔符（delimiter）和模式匹
阅读更多...
Java中的stream流分组示例详解

Java中的stream流分组示例详解

《Java中的stream流分组示例详解》Java8StreamAPI以函数式风格处理集合数据,支持分组、统计等操作,可按单/多字段分组,使用String、Map.Entry或Java16record... 目录什么是stream流1、根据某个字段分组2、按多个字段分组（组合分组）1、方法一：使用 Stri
阅读更多...
Java+AI驱动实现PDF文件数据提取与解析

Java+AI驱动实现PDF文件数据提取与解析

《Java+AI驱动实现PDF文件数据提取与解析》本文将和大家分享一套基于AI的体检报告智能评估方案,详细介绍从PDF上传、内容提取到AI分析、数据存储的全流程自动化实现方法,感兴趣的可以了解下... 目录一、核心流程：从上传到评估的完整链路二、第一步：解析 PDF，提取体检报告内容1. 引入依赖2. 封装
阅读更多...
使用Spring Cache本地缓存示例代码

使用Spring Cache本地缓存示例代码

《使用SpringCache本地缓存示例代码》缓存是提高应用程序性能的重要手段,通过将频繁访问的数据存储在内存中,可以减少数据库访问次数,从而加速数据读取,：本文主要介绍使用SpringCac... 目录一、Spring Cache简介核心特点：二、基础配置1. 添加依赖2. 启用缓存3. 缓存配置方案方案
阅读更多...
Java实现复杂查询优化的7个技巧小结

Java实现复杂查询优化的7个技巧小结

《Java实现复杂查询优化的7个技巧小结》在Java项目中,复杂查询是开发者面临的“硬骨头”,本文将通过7个实战技巧,结合代码示例和性能对比,手把手教你如何让复杂查询变得优雅,大家可以根据需求进行选择... 目录一、复杂查询的痛点：为何你的代码“又臭又长”1.1冗余变量与中间状态1.2重复查询与性能陷阱1.
阅读更多...
深度剖析SpringBoot日志性能提升的原因与解决

深度剖析SpringBoot日志性能提升的原因与解决

《深度剖析SpringBoot日志性能提升的原因与解决》日志记录本该是辅助工具,却为何成了性能瓶颈,SpringBoot如何用代码彻底破解日志导致的高延迟问题,感兴趣的小伙伴可以跟随小编一起学习一下... 目录前言第一章：日志性能陷阱的底层原理1.1 日志级别的“双刃剑”效应1.2 同步日志的“吞吐量杀手”
阅读更多...
Spring创建Bean的八种主要方式详解

Spring创建Bean的八种主要方式详解

《Spring创建Bean的八种主要方式详解》Spring（尤其是SpringBoot）提供了多种方式来让容器创建和管理Bean,@Component、@Configuration+@Bean、@En... 目录引言一、Spring 创建 Bean 的 8 种主要方式1. @Component 及其衍生注解
阅读更多...
SpringBoot通过main方法启动web项目实践

SpringBoot通过main方法启动web项目实践

《SpringBoot通过main方法启动web项目实践》SpringBoot通过SpringApplication.run()启动Web项目,自动推断应用类型,加载初始化器与监听器,配置Spring... 目录1. 启动入口：SpringApplication.run()2. SpringApplicat
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2