【springcloud alibaba】一条龙服务实现微服务案例（上）-阿里云开发者社区

第一章微服务介绍

1.1 系统架构演变

1.1.1 SpringCloud

Spring Cloud是一系列框架的集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用Spring Boot的开发风格做到一键启动和部署。

Spring Cloud并没有重复制造轮子，它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过Spring Boot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。

1.1.2 SpringCloud Alibaba

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

1.2 SpringCloud Alibaba介绍

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

1.2.1 主要功能

服务限流降级：默认支持 WebServlet、WebFlux， OpenFeign、RestTemplate、Spring Cloud Gateway， Zuul， Dubbo 和 RocketMQ 限流降级功能的接入，可以在运行时通过控制台实时修改限流降级规则，还支持查看限流降级 Metrics 监控。

服务注册与发现：适配 Spring Cloud 服务注册与发现标准，默认集成了 Ribbon 的支持。

分布式配置管理：支持分布式系统中的外部化配置，配置更改时自动刷新。

消息驱动能力：基于 Spring Cloud Stream 为微服务应用构建消息驱动能力。

分布式事务：使用 @GlobalTransactional 注解，高效并且对业务零侵入地解决分布式事务问题。

阿里云对象存储：阿里云提供的海量、安全、低成本、高可靠的云存储服务。支持在任何应用、任何时间、任何地点存储和访问任意类型的数据。

分布式任务调度：提供秒级、精准、高可靠、高可用的定时（基于 Cron 表达式）任务调度服务。同时提供分布式的任务执行模型，如网格任务。网格任务支持海量子任务均匀分配到所有Worker（schedulerx-client）上执行。

阿里云短信服务：覆盖全球的短信服务，友好、高效、智能的互联化通讯能力，帮助企业迅速搭建客户触达通道。

1.2.2 组件

Sentinel：把流量作为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。

Nacos：一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。

RocketMQ：一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。

Dubbo：Apache Dubbo 是一款高性能 Java RPC 框架。

Seata：阿里巴巴开源产品，一个易于使用的高性能微服务分布式事务解决方案。

Alibaba Cloud ACM：一款在分布式架构环境中对应用配置进行集中管理和推送的应用配置中心产品。

OSS: 阿里云对象存储服务（Object Storage Service，简称 OSS），是阿里云提供的海量、安全、低成本、高可靠的云存储服务。您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。

Alibaba Cloud SchedulerX: 阿里中间件团队开发的一款分布式任务调度产品，提供秒级、精准、高可靠、高可用的定时（基于 Cron 表达式）任务调度服务。

Alibaba Cloud SMS: 覆盖全球的短信服务，友好、高效、智能的互联化通讯能力，帮助企业迅速搭建客户触达通道。

1.3 版本对应关系

第二章微服务环境搭建

2.1 商品、订单、用户

2.1.1 技术选型

maven：3.6.1

数据库：MySQL 5

持久层: SpingData Jpa

SpringCloud Alibaba 技术栈

2.1.2 模块设计

springcloud-alibaba 父工程

shop-common 公共模块【实体类】

shop-user 用户微服务【端口: 807x】

shop-product 商品微服务【端口: 808x】

shop-order 订单微服务【端口: 809x】

2.1.3 微服务调用

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

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

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

2.2 创建springcloud-alibaba父工程

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

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
    </parent>
    <properties>
        <java.version>1.8</java.version>
        <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>
            <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>

2.3 创建shop-common模块

创建shop-common 模块，在pom.xml中添加依赖

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.56</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
    </dependencies>

构建实体类

//用户 
@Entity(name = "shop_user") 
@Data
public class User { 
  @Id 
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Integer uid;//主键 
  private String username;//用户名
  private String password;//密码 
  private String telephone;//手机号
}
//商品
@Entity(name = "shop_product")
@Data public class Product { 
  @Id 
  @GeneratedValue(strategy = GenerationType.IDENTITY) 
  private Integer pid;//主键 
  private String pname;//商品名称 
  private Double pprice;//商品价格 
  private Integer stock;//库存 
}
//订单 
@Entity(name = "shop_order") 
@Data public class Order { 
  @Id 
  @GeneratedValue(strategy = GenerationType.IDENTITY) 
  private Long oid;//订单id 
  private Integer uid;//用户id 
  private String username;//用户名
  private Integer pid;//商品id 
  private String pname;//商品名称 
  private Double pprice;//商品单价
  private Integer number;//购买数量 
}

2.4 创建用户shop-user微服务

1 创建pom.xml

    <dependencies>
        <dependency>
            <groupId>com.itheima</groupId>
            <artifactId>shop-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

2.修改yml

server:
  port: 8071
spring:
  application:
    name: service-user
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql:///shop?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    username: root
    password: 123456
  jpa:
    properties:
      hibernate:
        hbm2ddl:
          auto: update
        dialect: org.hibernate.dialect.MySQL5InnoDBDialect

2.5 创建商品shop-product微服务

1.修改pom

    <dependencies>
        <dependency>
            <groupId>com.itheima</groupId>
            <artifactId>shop-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

2.修改yml

server:
  port: 8081
spring:
  application:
    name: service-product
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql:///shop?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    username: root
    password: 123456
  jpa:
    properties:
      hibernate:
        hbm2ddl:
          auto: update
        dialect: org.hibernate.dialect.MySQL5InnoDBDialect

2.5 创建订单shop-order微服务

1.pom

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.itheima</groupId>
            <artifactId>shop-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>

2.yml

server:
  port: 8091
spring:
  application:
    name: service-order
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql:///shop?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    username: root
    password: 123456
  jpa:
    properties:
      hibernate:
        hbm2ddl:
          auto: update
        dialect: org.hibernate.dialect.MySQL5InnoDBDialect

第三章 RestTemplate基础服务调用

3.1shop-product 服务

@RestController
public class ProductController {
    @Autowired
    private ProductService productService;
    @RequestMapping("/product/{pid}")
    public Product product(@PathVariable("pid") Integer pid){
        Product product = productService.findByPid(pid);
        String s = JSON.toJSONString(product);
        System.out.println(s);
        return product;
    }
}

3.2 shop-order 服务

3.2.1 RestTemplate注册组件

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

3.2.2 order 调用product

@RestController
public class OrderController {
    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private OrderService orderService;
    @RequestMapping("/order/prod/{pid}")
    public Order order(@PathVariable("pid") Integer pid){
        // 1.查询商品服务
        Product product = restTemplate.getForObject("http://localhost:8081/product/"+pid,Product.class);
        String s = JSON.toJSONString(product);
        // 2.模拟下单
        Order order = new Order();
        order.setUid(1);
        order.setUsername("测试用户");
        order.setPid(pid);
        order.setPname(product.getPname());
        order.setPprice(product.getPprice());
        order.setNumber(1);
        orderService.createOrder(order);
        return order;
    }
}

测试调用：http://localhost:8091/order/prod/2

返回值：{“oid”:1,“uid”:1,“username”:“测试用户”,“pid”:2,“pname”:“华为”,“pprice”:2000.0,“number”:1}

第四章 Nacos注册中心

4.1 安装

略，启动bin下的nacos服务器。

web: http://localhost:8848/nacos

用户名密码都是 nacos

4.2 shop-product注册到nacos

1.pom依赖

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

2.主类添加注解

@EnableDiscoveryClient

3.yml配置文件添加服务器地址

spring：
 cloud:
  nacos:
    discovery:
      server-addr: 127.0.0.1:8848

启动测试，观看nacos控制台

4.3 shop-product注册到nacos

如同以上步骤

4.4 nacos进行服务调用

1.修改order服务

@RestController
public class OrderController {
@Autowired
private DiscoveryClient discoveryClient;
        List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
        ServiceInstance instance = instances.get(0);
      // 修改如下
        Product product = restTemplate.getForObject("http://"+instance.getHost()+":"+instance.getPort()+"/product/"+pid,Product.class);

测试服务调用：http://localhost:8091/order/prod/1

调用结果：{“oid”:2,“uid”:1,“username”:“测试用户”,“pid”:1,“pname”:“小米”,“pprice”:1000.0,“number”:1}

第五章 Ribbon负载均衡

5.1 复制一个shop-product应用

5.2 自定义负载均衡

@RestController
public class OrderController {
   @Autowired
    private DiscoveryClient discoveryClient;
    @RequestMapping("/order/prod/{pid}")
    public Order order(@PathVariable("pid") Integer pid){
        // 1.查询商品服务
        List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
        // 2.自定义到随机一台机器
        int index = new Random().nextInt(instances.size()); // 0 1
        ServiceInstance instance = instances.get(index);
        Product product = restTemplate.getForObject("http://"+instance.getHost()+":"+instance.getPort()+"/product/"+pid,Product.class);

5.3 Ribbon负载均衡

1.在RestTemplate的方法中添加 @LoadBalanced注解

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

2.OrderController 修改服务调用

@RestController
public class OrderController {
    @Autowired
    private DiscoveryClient discoveryClient;
    @RequestMapping("/order/prod/{pid}")
    public Order order(@PathVariable("pid") Integer pid){
        // 1.查询商品服务
        Product product = restTemplate.getForObject("http://service-product/product/"+pid,Product.class);

默认是轮询的算法策略。

测试服务调用：http://localhost:8091/order/prod/1

3.在yml中调整负载均衡策略为随机试试看

service-product:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

【springcloud alibaba】一条龙服务实现微服务案例（上）

第一章微服务介绍

1.1 系统架构演变

1.1.1 SpringCloud

1.1.2 SpringCloud Alibaba

1.2 SpringCloud Alibaba介绍

1.2.1 主要功能

1.2.2 组件

1.3 版本对应关系

第二章微服务环境搭建

2.1 商品、订单、用户

2.1.1 技术选型

2.1.2 模块设计

2.1.3 微服务调用

2.2 创建springcloud-alibaba父工程

2.3 创建shop-common模块

2.4 创建用户shop-user微服务

2.5 创建商品shop-product微服务

2.5 创建订单shop-order微服务

第三章 RestTemplate基础服务调用

3.1shop-product 服务

3.2 shop-order 服务

3.2.1 RestTemplate注册组件

3.2.2 order 调用product

第四章 Nacos注册中心

4.1 安装

4.2 shop-product注册到nacos

4.3 shop-product注册到nacos

4.4 nacos进行服务调用

第五章 Ribbon负载均衡

5.1 复制一个shop-product应用

5.2 自定义负载均衡

5.3 Ribbon负载均衡

微服务

热门文章

最新文章

相关课程

相关电子书

【springcloud alibaba】 一条龙服务实现微服务案例（上）

第一章 微服务介绍

1.1 系统架构演变

1.1.1 SpringCloud

1.1.2 SpringCloud Alibaba

1.2 SpringCloud Alibaba介绍

1.2.1 主要功能

1.2.2 组件

1.3 版本对应关系

第二章 微服务环境搭建

2.1 商品、订单、用户

2.1.1 技术选型

2.1.2 模块设计

2.1.3 微服务调用

2.2 创建springcloud-alibaba父工程

2.3 创建shop-common模块

2.4 创建用户shop-user微服务

2.5 创建商品shop-product微服务

2.5 创建订单shop-order微服务

第三章 RestTemplate基础服务调用

3.1shop-product 服务

3.2 shop-order 服务

3.2.1 RestTemplate注册组件

3.2.2 order 调用product

第四章 Nacos注册中心

4.1 安装

4.2 shop-product注册到nacos

4.3 shop-product注册到nacos

4.4 nacos进行服务调用

第五章 Ribbon负载均衡

5.1 复制一个shop-product应用

5.2 自定义负载均衡

5.3 Ribbon负载均衡

微服务

热门文章

最新文章

相关课程

相关电子书

【springcloud alibaba】一条龙服务实现微服务案例（上）

第一章微服务介绍

第二章微服务环境搭建