0
0

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

文章目录

欢迎来到阿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"?><projectxmlns="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"?><projectxmlns="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")publicclassShopUser{@TableId(value ="id",type =IdType.AUTO)privateInteger id;//主键@TableField("username")privateString username;//用户名@TableField("password")privateString password;//密码@TableField("telephone")privateString telephone;//手机号}//商品信息@Data@TableName(value ="shop_product")publicclassShopProduct{@TableId(value ="id",type =IdType.AUTO)privateLong id;//主键@TableField("pname")privateString pname;//商品名称@TableField("pprice")privateDouble pprice;//商品价格@TableField("stock")privateInteger stock;//库存}//订单信息@Data@TableName(value ="shop_order")publicclassShopOrder{@TableId(value ="id",type =IdType.AUTO)privateLong id;//订单id@TableField("uid")privateLong uid;//用户id@TableField("username")privateString username;//用户名@TableField("pid")privateLong pid;//商品id@TableField("pname")privateString pname;//商品名称}

创建用户微服务

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

新建一个

shop-user

模块，然后进行下面操作

1、创建

pom.xml

<?xml version="1.0" encoding="UTF-8"?><projectxmlns="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、编写主类

@SpringBootApplicationpublicclassUserApplication{publicstaticvoidmain(String[] args){SpringApplication.run(UserApplication.class,args);}}

3、创建配置文件

server:port:8071#数据库配置spring:application:name: shop-user
  datasource:url: jdbc:mysql://127.0.0.1:3306/microservice?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTCusername: root
    password: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"?><projectxmlns="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、创建工程的主类

@SpringBootApplicationpublicclassProductApplication{publicstaticvoidmain(String[] args){SpringApplication.run(ProductApplication.class,args);}}

3、创建配置文件

server:port:8081#数据库配置spring:application:name: shop-product
  datasource:url: jdbc:mysql://127.0.0.1:3306/microservice?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTCusername: root
    password: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")@Slf4jpublicclassProductController{@AutowiredprivateIProductservice productService;/**
     * @Description:查询商品信息
     * @Author: cheetah
     * @Date: 2024/1/22 9:40
     * @param id:
     * @return: it.aq.cheetah.entity.ShopProduct
     **/@GetMapping("/{id}")publicShopProductproduct(@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")publicIntegerreduceStock(@RequestBodyProductReduceDTO productReduceDTO){return productService.reduceStock(productReduceDTO);}}@ServicepublicclassProductServiceImplimplementsIProductservice{@AutowiredprivateProductMapper productMapper;@OverridepublicShopProductfindByPid(Long pid){return productMapper.selectById(pid);}@OverridepublicIntegerreduceStock(ProductReduceDTO productReduceDTO){ShopProduct shopProduct = productMapper.selectById(productReduceDTO.getProductId());Integer stock = shopProduct.getStock();if(stock < productReduceDTO.getReductCount()){thrownewRuntimeException("库存不足，请联系管理员增加库存");}
        shopProduct.setStock(stock-productReduceDTO.getReductCount());return productMapper.updateById(shopProduct);}}@MapperpublicinterfaceProductMapperextendsBaseMapper<ShopProduct>{}

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

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

6、通过浏览器访问服务

在这里插入图片描述

创建订单微服务

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

添加 springboot 依赖

<?xml version="1.0" encoding="UTF-8"?><projectxmlns="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、创建工程的主类

@SpringBootApplicationpublicclassOrderApplication{publicstaticvoidmain(String[] args){SpringApplication.run(OrderApplication.class,args);}}

3、创建配置文件

server:port:8091#数据库配置spring:application:name: shop-order
  datasource:url: jdbc:mysql://127.0.0.1:3306/microservice?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTCusername: root
    password: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")@Slf4jpublicclassOrderController{@AutowiredprivateIOrderService orderService;@AutowiredprivateRestTemplate restTemplate;@GetMapping("/{pid}")publicShopOrderorder(@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 =newShopOrder();
        shopOrder.setUid(1L);
        shopOrder.setUsername("公众号：阿Q说代码");
        shopOrder.setPid(shopProduct.getId());
        shopOrder.setPname(shopProduct.getPname());
        orderService.save(shopOrder);//商品扣减库存的逻辑ProductReduceDTO productReduceDTO =newProductReduceDTO();
        productReduceDTO.setProductId(pid);
        productReduceDTO.setReductCount(1);Integer count = restTemplate.postForObject("http://127.0.0.1:8081/product/reduceStock", productReduceDTO,Integer.class);return shopOrder;}}@ServicepublicclassOrderServiceImplextendsServiceImpl<OrderMapper,ShopOrder>implementsIOrderService{}@MapperpublicinterfaceOrderMapperextendsBaseMapper<ShopOrder>{}

5、创建启动类

@SpringBootApplicationpublicclassOrderApplication{publicstaticvoidmain(String[] args){SpringApplication.run(OrderApplication.class,args);}@BeanpublicRestTemplategetRestTemplate(){returnnewRestTemplate();}}

6、通过浏览器访问

同时启动商品服务和订单服务，执行

http://127.0.0.1:8091/order/1

完成后，查看数据库数据

在这里插入图片描述

在这里插入图片描述

总结

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

标签： spring cloud 微服务 spring
本文转载自: https://blog.csdn.net/Qingai521/article/details/135741643
版权归原作者 阿Q说代码 所有， 如有侵权，请联系我们删除。
登录后发布评论

“【SpringCloud Alibaba】 介绍及微服务模块搭建”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

机器人技术在安全领域的重要作用

安全学习记录——网络篇（一）

图腾柱PFC：HP1010为您的电动两轮车之旅提供绿色，高效，安全的动力

单元测试数据库回滚问题

这才是单元测试，之前我们都错了

【C语言基础】：字符函数和字符串函数

ChatGPT-Next-Web SSRF漏洞+XSS漏洞复现(CVE-2023-49785)

文章导航