Spring Cloud 微服务环境搭建与工程初始化

商品服务数据库

-- 建库
create database if not exists cloud_product charset utf8mb4;

-- 产品表
DROP TABLE IF EXISTS product_detail;
CREATE TABLE product_detail (
  id INT NOT NULL AUTO_INCREMENT COMMENT '产品 id',
  product_name varchar(128) NULL COMMENT '产品名称',
  product_price BIGINT(20) NOT NULL COMMENT '产品价格',
  state TINYINT(4) NULL DEFAULT 0 COMMENT '产品状态 0-有效 1-下架',
  create_time DATETIME DEFAULT now(),
  update_time DATETIME DEFAULT now(),
  PRIMARY KEY (id)
) ENGINE = INNODB DEFAULT CHARACTER SET = utf8mb4 COMMENT = '产品表';

-- 数据初始化
insert into product_detail (id, product_name, product_price, state)
values (1001, 'T 恤', 101, 0), (1002, '短袖', 30, 0), (1003, '短裤', 44, 0),
       (1004, '卫衣', 58, 0), (1005, '马甲', 98, 0), (1006, '羽绒服', 101, 0),
       (1007, '冲锋衣', 30, 0), (1008, '袜子', 44, 0), (1009, '鞋子', 58, 0),
       (10010, '毛衣', 98, 0);

工程搭建

构建父子工程

创建父工程

1. 创建一个空的 Maven 项目，删除所有代码，只保留 pom.xml。
2. 目录结构如下：

3. 完善 pom.xml。 使用 properties 统一管理版本号，通过 dependencyManagement 管理依赖声明，并将打包方式设为 pom。

<?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>
    <groupId>org.example</groupId>
    <artifactId>spring-cloud-demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>3.1.6</version>
        <relativePath/>
    </parent>
    <properties>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
        <java.version>17</java.version>
        <mybatis.version>3.0.3</mybatis.version>
        <mysql.version>8.0.33</mysql.version>
        <spring-cloud.version>2022.0.3</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>
    <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>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis.version}</version>
            </dependency>
            <dependency>
                <groupId>com.mysql</groupId>
                <artifactId>mysql-connector-j</artifactId>
                <version>${mysql.version}</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter-test</artifactId>
                <version>${mybatis.version}</version>
                <scope>test</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

注意：dependencyManagement 只是声明依赖，不会自动引入 jar 包。子项目需要用到相关依赖时，需在各自的 pom.xml 中显式声明。如果子项目未指定版本，则会继承父工程中定义的版本。

创建子项目 - 订单服务

新建模块后，声明项目依赖和构建插件：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>com.mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
    </dependency>
</dependencies>
<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

创建子项目 - 商品服务

创建步骤同上，依赖配置也保持一致。

完善订单服务

启动类与配置

启动类：

@SpringBootApplication
public class OrderServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderServiceApplication.class, args);
    }
}

配置文件 (application.yml)：

server:
  port: 8080
spring:
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/cloud_order?characterEncoding=utf8&useSSL=false
    username: root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver
  mybatis:
    configuration:
      log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
      map-underscore-to-camel-case: true

业务代码实现

1. 实体类

@Data
public class OrderInfo {
    private Integer id;
    private Integer userId;
    private Integer productId;
    private Integer num;
    private Integer price;
    private Integer deleteFlag;
    private Date createTime;
    private Date updateTime;
}

2. Controller

@RequestMapping("/order")
@RestController
public class OrderController {
    @Autowired
    private OrderService orderService;

    @RequestMapping("/{orderId}")
    public OrderInfo getOrderById(@PathVariable("orderId") Integer orderId) {
        return orderService.selectOrderById(orderId);
    }
}

3. Service

@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;

    public OrderInfo selectOrderById(Integer orderId) {
        OrderInfo orderInfo = orderMapper.selectOrderById(orderId);
        return orderInfo;
    }
}

4. Mapper

@Mapper
public interface OrderMapper {
    @Select("select * from order_detail where id=#{orderId}")
    OrderInfo selectOrderById(Integer orderId);
}

商品服务的实现类似，此处省略。

远程调用

需求

在查询订单信息时，需要根据订单中的产品 ID，获取产品的详细信息并合并返回。

实现思路

order-service 向 product-service 发送 HTTP 请求，获取结果后融合订单数据返回给调用方。这里我们采用 Spring 提供的 RestTemplate。

1. 定义 RestTemplate Bean

@Configuration
public class BeanConfig {
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

2. 修改 OrderService

@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;
    
    @Autowired
    private RestTemplate restTemplate;

    public OrderInfo selectOrderById(Integer orderId) {
        OrderInfo orderInfo = orderMapper.selectOrderById(orderId);
        String url = "http://127.0.0.1:9090/product/" + orderInfo.getProductId();
        ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);
        orderInfo.setProductInfo(productInfo);
        return orderInfo;
    }
}

RestTemplate 与 RESTful

RestTemplate 是 Spring 3.0 开始支持的 HTTP 请求工具，它是一个同步的 REST API 客户端。

什么是 REST？

REST（Representational State Transfer）是一种软件架构风格，包含三个核心概念：

1. 资源：网络上的事物抽象为资源，有唯一标识符（URI）。
2. 表现层：资源的表现形式，如文本、JSON、XML 等。
3. 状态转移：通过 HTTP 协议进行交互，涉及数据的增删改查等操作。

RESTful 实践

RESTful API 满足上述设计风格。主要特征包括：

• 资源导向：URL 定位资源。
• 统一接口：使用 HTTP 方法（GET、POST、PUT、DELETE）区分操作。

例如：

• GET /blog/{blogId}：查询博客
• DELETE /blog/{blogId}：删除博客

实际开发中的考量

虽然 RESTful 很规范，但在实际互联网开发中，完全遵循有时会增加成本：

1. HTTP Method 不可见：调试时需抓包才能看到具体动作，不如 URL 直观。
2. 浏览器兼容性：部分浏览器对 PUT、DELETE 支持不友好。
3. 业务复杂性：某些复杂业务逻辑难以单纯用 CRUD 表达。

总之，无论哪种风格的 API，核心目的是方便团队协作和管理。尽信规范不如无规范，根据场景灵活选择即可。

当前存在的问题

目前的实现方式存在几个明显缺陷：

• 硬编码 IP：URL 写死了 127.0.0.1:9090，更换服务器需修改代码。
• 缺乏负载均衡：多机部署时无法分摊压力。
• 复用性差：URL 容易写错，且难以维护。
• 安全性风险：所有服务均可直接调用该接口。

这些问题正是微服务架构后续要解决的核心痛点，比如服务注册发现、负载均衡、网关路由等，我们将在后续内容中逐一探讨。