微服务案例搭建

news2024/9/20 22:46:35

案例搭建

使⽤微服务架构的分布式系统,微服务之间通过⽹络通信。我们通过服务提供者与服务消费者来描述微服务间的调⽤关系。

服务提供者：服务的被调⽤⽅，提供调⽤接⼝的⼀⽅

服务消费者：服务的调⽤⽅，依赖于其他服务的⼀⽅

我们以电商系统中常⻅的⽤户下单为例，⽤户向订单微服务发起⼀个购买的请求。在进⾏保存订单之前需要调⽤商品微服务查询当前商品库存，单价等信息。在这种场景下，订单微服务就是⼀个服务消费者，商品微服务就是⼀个服务提供者。

3.1 数据库表

shop_order订单表 shop_product商品表 shop_user⽤户表

3.2 服务模块

1. 创建模块

创建公共⽗模块springcloud_alibaba

创建公共模块 shop_common ,⽤于存放公共的实体类和⼯具类

创建订单微服务模块 shop_order 端⼝809X

创建商品微服务模块 shop_product 端⼝808X

创建⽤户微服务模块 shop_user 端⼝807X

2. 在父模块的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 https://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.7.13</version>
    </parent>

    <!--父项目的子模块-->
    <modules>
        <module>spring_common</module>
        <module>shop_order</module>
        <module>shop_user</module>
        <module>shop_product</module>
    </modules>

    <groupId>com.apesource</groupId>
    <artifactId>springcloud_alibaba</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <!--pom:父文件-->
    <packaging>pom</packaging>
    <name>springcloud_alibaba</name>
    <description>springcloud_alibaba</description>

    <!--依赖版本的锁定-->
    <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.1.RELEASE</spring-cloud-alibaba.version>
    </properties>


    <!--
    dependencyManagement所包含的坐标，子项目不会直接继承，需要声明才可继承
    -->
    <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>


</project>

3. 在product、order、user子模块中导入公共子模块common的坐标

        <!--shop-common-->
        <dependency>
            <groupId>com.apesource</groupId>
            <artifactId>spring_common</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

3.3 服务调⽤

前⽂已经编写了三个基础的微服务，在⽤户下单时需要调⽤商品微服务获取商品数据。那应该怎么做呢？总⼈皆知商品微服务提供了供⼈调⽤的HTTP接⼝。所以可以再下定单的时候使⽤http请求的相关⼯具类完成，如常⻅的HttpClient ，OkHttp，当然也可以使⽤Spring提供的RestTemplate

3.3.1 RestTemplate介绍

Spring框架提供的RestTemplate类可⽤于在应⽤中调⽤rest服务，它简化了与http服务的通信⽅式，统⼀了RESTful的标准，封装了http链接，我们只需要传⼊url及返回值类型即可。相较于之前常⽤的 HttpClient ，RestTemplate是⼀种更优雅的调⽤RESTful服务的⽅式。

在Spring应⽤程序中访问第三⽅REST服务与使⽤Spring RestTemplate类有关。 RestTemplate类的设计原则与许多其他Spring 模板类(例如JdbcTemplate、JmsTemplate)相同，为执⾏复杂任务提供了⼀种具有默认⾏为的简化⽅法。 RestTemplate默认依赖JDK提供http连接的能⼒（HttpURLConnection），如果有需要的话也可以通过 setRequestFactory⽅法替换为例如 Apache HttpComponents、 Netty或OkHttp等其它HTTP library。考虑到RestTemplate类是为调⽤REST服务⽽设计的，因此它的主要⽅法与REST的基础紧密相连就不⾜为奇了，后者是HTTP协议的⽅法:HEAD、GET、 POST、 PUT、 DELETE和OPTIONS。例如， RestTemplate类具有headForHeaders()、getForObject()、 postForObject()、 put()和delete()等⽅法。

3.3.2 RestTemplate⽅法介绍

分为三组：

getForObject --- optionsForAllow 分为一组，这类方法是常规的 Rest API（GET、POST、DELETE 等）方法调用；
exchange：接收一个 RequestEntity 参数，可以自己设置 HTTP method，URL，headers 和 body，返回 ResponseEntity；
execute：通过 callback 接口，可以对请求和返回做更加全面的自定义控制。

3.3.3 通过RestTemplate调⽤微服务

（ 1 ）在 shop_order⼯程中配置RestTemplate

@SpringBootApplication
public class ShopOrderApplication {

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

（ 2 ）编写下订单⽅法 //通过restTemplate调⽤商品微服务 restTemplate .getForObject("http://127.0.0.1:8081/product/1" , Product.class);

//商品Controller类
@RestController
public class ProductController {

    @Autowired
    IProductService productService;

    @RequestMapping("/product/{pid}")
    public Product product(@PathVariable("pid") Integer pid){
        Product product = productService.getById(pid);
        return product;
    }
}

//订单Controller类
@RestController
public class OrderController {
    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private IOrderService orderService;

    @RequestMapping("/order/prod/{pid}")
    public Order order(@PathVariable("pid") Integer pid){
        //调用商品微服务，查询商品信息
        Product product = restTemplate.getForObject("http://localhost:8081/product/"+pid,Product.class);
        //下单（常见订单）
        Order order = new Order();
        order.setUid(1);
        order.setUsername("测试用户1");
        order.setPid(pid);
        order.setPname(product.getPname());
        order.setPprice(product.getPprice());
        order.setNumber(1);
        orderService.createOrder(order);
        return order;
    }
}