【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后端知识，请点击文末名片与我交流吧。留下您的一键三连，让我们在这个寒冷的东西互相温暖吧！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/421790.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

第4章-IP基本原理

第4章-IP基本原理

目录 1. IP协议概述 1.1. 定义 1.2. 功能 1.3. IP网络的结构 1.4. IP头格式 2. IP地址和地址映射 3. IP包转发 4. 其他相关协议介绍 1. IP协议概述 1.1. 定义 IP协议&#xff1a;IP协议是网际互连协议&#xff1b; 工作层次&#xff1a;网络层&#xff1b; 封装&#…
阅读更多...
空调网关BL121AC 实现工业空调设备与OPC UA系统高效通信

空调网关BL121AC 实现工业空调设备与OPC UA系统高效通信

随着工业4.0的迅猛发展&#xff0c;人们深刻认识到在工业生产和生活中&#xff0c;实时、可靠、安全的数据传输至关重要。在此背景下&#xff0c;高性能的工业电力数据传输解决方案——协议转换网关应运而生&#xff0c;广泛应用于工业自动化和数字化工厂应用环境中。 钡铼技术…
阅读更多...
本地git切换地区后，无法使用ssh访问github 22端口解决方案

本地git切换地区后，无法使用ssh访问github 22端口解决方案

问题 由于放假回家&#xff0c;发现之前一直使用正常的git&#xff0c;与github无法通讯&#xff0c;pull和push都无法连接。报错如下&#xff1a; connect to host github.com port 22: Connection timed out fatal: Could not read from remote repository. 原因 可能是所…
阅读更多...
SSL证书免费和付费的有什么区别？

SSL证书免费和付费的有什么区别？

品牌和信任度 免费SSL证书通常由非营利性的组织提供&#xff0c;而付费SSL证书则由知名的证书颁发机构&#xff08;CA&#xff09;提供&#xff0c;如DigiCert、GlobalSign、GeoTrust等。相较于免费证书&#xff0c;付费证书的品牌和信任度更高&#xff0c;更容易获得用户的信…
阅读更多...
C语言第五弹---分支语句(上)

C语言第五弹---分支语句(上)

✨个人主页&#xff1a; 熬夜学编程的小林 &#x1f497;系列专栏&#xff1a; 【C语言详解】 【数据结构详解】 分支语句 1、if语句1.1、if1.2、 else1.3、 分支中包含多条语句1.4、嵌套if1.5、 悬空else问题 2、关系操作符3、 条件操作符总结 C语言是结构化的程序设计语言&…
阅读更多...
【C++】类和对象（上篇）

【C++】类和对象（上篇）

文章目录 &#x1f6df;一、面向过程和面向对象初步认识&#x1f6df;二、类的引入&#x1f6df;三、类的定义&#x1f4dd;1、类的两种定义方式&#x1f4dd;2、成员变量命名规则的建议 &#x1f6df;四、类的访问限定符及封装&#x1f369;1、访问限定符&#x1f369;2、封装…
阅读更多...
【EI会议征稿通知】2024年第四届数字信号与计算机通信国际学术会议（DSCC 2024）

【EI会议征稿通知】2024年第四届数字信号与计算机通信国际学术会议（DSCC 2024）

2024年第四届数字信号与计算机通信国际学术会议&#xff08;DSCC 2024&#xff09; 2024 4th International Conference on Digital Signal and Computer Communications 第四届数字信号与计算机通信国际会议(DSCC 2024)将于2024年4月12日至14日在中国-香港举行。DSCC 2024旨…
阅读更多...
Pandas.DataFrame.std() 样本标准差/总体标准差 详解 含代码 含测试数据集 随Pandas版本持续更新

Pandas.DataFrame.std() 样本标准差/总体标准差 详解 含代码 含测试数据集 随Pandas版本持续更新

关于Pandas版本&#xff1a; 本文基于 pandas2.1.2 编写。 关于本文内容更新&#xff1a; 随着pandas的stable版本更迭&#xff0c;本文持续更新&#xff0c;不断完善补充。 Pandas稳定版更新及变动内容整合专题&#xff1a; Pandas稳定版更新及变动迭持续更新。 Pandas API参…
阅读更多...
精密、CMOS、轨到轨输入/输出、宽带运算放大器

精密、CMOS、轨到轨输入/输出、宽带运算放大器

MS8601/MS8602/MS8604 分别是单 / 双 / 四通道、轨到轨输入和输出、 单电源放大器&#xff0c;具有极低的失调电压和宽信号带宽。它采用 1.8V 至 5V 单电 源&#xff08; 0.9 V 至 2.5 V 双电源&#xff09;供电。 MS8601/MS8602/MS8604 低失调、极低的输入偏置电流和高速…
阅读更多...
零售电商经营分析体系建设咨询案例

零售电商经营分析体系建设咨询案例

一、项目背景 在当前经济形式下&#xff0c;外贸出口面临着巨大压力&#xff0c;跨境电商行业在经营上需要更加精细化。为了应对这一挑战&#xff0c;某跨境电商决定进行零售电商经营分析体系的建设&#xff0c;以提升企业的运营效率和决策准确性。 二、项目目标 建立一套完…
阅读更多...
Pandas.Series.mean() 平均值 详解 含代码 含测试数据集 随Pandas版本持续更新

Pandas.Series.mean() 平均值 详解 含代码 含测试数据集 随Pandas版本持续更新

关于Pandas版本&#xff1a; 本文基于 pandas2.1.2 编写。 关于本文内容更新&#xff1a; 随着pandas的stable版本更迭&#xff0c;本文持续更新&#xff0c;不断完善补充。 Pandas稳定版更新及变动内容整合专题&#xff1a; Pandas稳定版更新及变动迭持续更新。 Pandas API参…
阅读更多...
2023 年值得一读的技术文章 ｜ NebulaGraph 技术社区

2023 年值得一读的技术文章 ｜ NebulaGraph 技术社区

在之前的产品篇&#xff0c;我们了解到了 NebulaGraph 内核及周边工具在 2023 年经历了什么样的变化。伴随着这些特性的变更和上线&#xff0c;在【文章】博客分类中&#xff0c;一篇篇的博文记录下了这些功能背后的设计思考和研发实践。当中&#xff0c;既有对内存管理 Memory…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023