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

03-13 阅读 0评论

文章目录

  • 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社区

                  【SpringCloud Alibaba】 介绍及微服务模块搭建,【SpringCloud Alibaba】 介绍及微服务模块搭建,词库加载错误:未能找到文件“C:\Users\Administrator\Desktop\火车头9.8破解版\Configuration\Dict_Stopwords.txt”。,使用,我们,管理,第1张
                  （图片来源网络，侵删）

                  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×]

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

                          微服务调用

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

                          【SpringCloud Alibaba】 介绍及微服务模块搭建,【SpringCloud Alibaba】 介绍及微服务模块搭建,词库加载错误:未能找到文件“C:\Users\Administrator\Desktop\火车头9.8破解版\Configuration\Dict_Stopwords.txt”。,使用,我们,管理,第3张
                          （图片来源网络，侵删）

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

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

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

                          创建父工程

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

                          
    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.1.3.RELEASE
    
    it.aq.cheetah
    microservice
    1.0-SNAPSHOT
    pom
    
        1.8
        8
        8
        UTF-8
        UTF-8
        Greenwich.RELEASE
        2.1.0.RELEASE
    
    
        
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring-cloud.version}
                pom
                import

                          版本对应：

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

                          【SpringCloud Alibaba】 介绍及微服务模块搭建,【SpringCloud Alibaba】 介绍及微服务模块搭建,词库加载错误:未能找到文件“C:\Users\Administrator\Desktop\火车头9.8破解版\Configuration\Dict_Stopwords.txt”。,使用,我们,管理,第6张
                          （图片来源网络，侵删）

                          创建基础模块

                          1、创建 shop-common 模块

                          在pom.xml中添加依赖

                          
    4.0.0
    
        it.aq.cheetah
        microservice
        1.0-SNAPSHOT
    
    shop-common
    
        8
        8
        UTF-8
    
    
        
            com.baomidou
            mybatis-plus-boot-starter
            3.5.0
        
        
            org.projectlombok
            lombok
            1.18.26
        
        
            com.alibaba
            fastjson
            1.2.83
        
        
            mysql
            mysql-connector-java
            8.0.31

                          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

                          
    4.0.0
    
        it.aq.cheetah
        microservice
        1.0-SNAPSHOT
    
    shop-user
    
    
        
            it.aq.cheetah
            shop-common
            1.0-SNAPSHOT

                          2、编写主类

                          @SpringBootApplication
public class UserApplication {
    public static void main(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=UTC
    username: 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 依赖

                          
    4.0.0
    
        it.aq.cheetah
        microservice
        1.0-SNAPSHOT
    
    shop-product
    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            it.aq.cheetah
            shop-common
            1.0-SNAPSHOT

                          2、创建工程的主类

                          @SpringBootApplication
public class ProductApplication {
    public static void main(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=UTC
    username: 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")
@Slf4j
public class ProductController {
    @Autowired
    private 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 {
    @Autowired
    private ProductMapper productMapper;
    @Override
    public ShopProduct findByPid(Long pid) {
        return productMapper.selectById(pid);
    }
    @Override
    public Integer reduceStock(ProductReduceDTO productReduceDTO) {
        ShopProduct shopProduct = productMapper.selectById(productReduceDTO.getProductId());
        Integer stock = shopProduct.getStock();
        if(stock  

                          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、通过浏览器访问服务
                           

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

                          创建订单微服务
                           

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

                          添加 springboot 依赖
                           

                          
    4.0.0
    
        it.aq.cheetah
        microservice
        1.0-SNAPSHOT
    
    shop-order
    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            it.aq.cheetah
            shop-common
            1.0-SNAPSHOT
        
    


                           

                          2、创建工程的主类
                           

                          @SpringBootApplication
public class OrderApplication {
    public static void main(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=UTC
    username: 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")
@Slf4j
public class OrderController {
    @Autowired
    private IOrderService orderService;
    @Autowired
    private 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 implements IOrderService {}
@Mapper
public interface OrderMapper extends BaseMapper {}

                           

                          5、创建启动类
                           

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

                           

                          6、通过浏览器访问
                           

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

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

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

                          总结
                           

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

相关阅读：

1、Android Studio音乐播放器（使用sqlite创建数据库）

2、Windows下载安装配置并使用Redis（保姆级教程）

3、【菜狗学前端】在原生微信小程序使用腾讯地图API接口

4、1984asp.net宿舍管理系统VS开发sqlserver数据库web结构c#编程Microsoft Visual Studio

5、开源 复刻GPT-4o - Moshi；自动定位和解决软件开发中的问题；ComfyUI中使用MimicMotion；自动生成React前端代码

免责声明
本网站所收集的部分公开资料来源于AI生成和互联网，转载的目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。
文章版权声明：除非注明，否则均为主机测评原创文章，转载或复制请以超链接形式并注明出处。

相关阅读

发表评论

快捷回复： 表情：
评论列表 （暂无评论，人围观）

还没有评论，来说两句吧...

目录[+]