{"id":64307,"date":"2026-01-23T10:24:26","date_gmt":"2026-01-23T02:24:26","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/64307.html"},"modified":"2026-01-23T10:24:26","modified_gmt":"2026-01-23T02:24:26","slug":"spring-cloud%e5%ae%9e%e6%88%98%ef%bc%9a%e7%94%b5%e5%95%86%e5%be%ae%e6%9c%8d%e5%8a%a1%e7%b3%bb%e7%bb%9f%e4%bb%8e0%e5%88%b01%ef%bc%8825000%e5%ad%97%e7%bb%88%e6%9e%81%e5%ae%9e%e6%88%98%e6%8c%87%e5%8d%97","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/64307.html","title":{"rendered":"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09"},"content":{"rendered":"

\u7b2c\u4e00\u7ae0：\u9879\u76ee\u67b6\u6784\u8bbe\u8ba1\u4e0e\u6280\u672f\u9009\u578b<\/h3>\n

1.1 \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u5206\u6790 \u4f20\u7edf\u5355\u4f53\u7535\u5546\u7cfb\u7edf\u7684\u75db\u70b9：<\/p>\n

java \/\/ \u4f20\u7edf\u5355\u4f53\u7535\u5546\u67b6\u6784\u7684\u95ee\u9898 \u5355\u70b9\u6545\u969c：\u5546\u54c1\u670d\u52a1\u5d29\u6e83 \u2192 \u6574\u4e2a\u7f51\u7ad9\u4e0d\u53ef\u7528 \u6280\u672f\u6808\u56fa\u5316：\u6240\u6709\u6a21\u5757\u5fc5\u987b\u4f7f\u7528\u76f8\u540c\u6280\u672f \u6269\u5c55\u56f0\u96be：\u4fc3\u9500\u65f6\u53ea\u80fd\u6574\u4f53\u6269\u5bb9 \u53d1\u5e03\u98ce\u9669：\u5c0f\u6539\u52a8\u9700\u8981\u5168\u7ad9\u53d1\u5e03 \u56e2\u961f\u534f\u4f5c：\u4ee3\u7801\u51b2\u7a81\u3001\u6c9f\u901a\u6210\u672c\u9ad8<\/p>\n

\/\/ \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b： \u7528\u6237\u6d4f\u89c8 \u2192 \u52a0\u5165\u8d2d\u7269\u8f66 \u2192 \u4e0b\u5355 \u2192 \u652f\u4ed8 \u2192 \u53d1\u8d27 \u2192 \u6536\u8d27 \u2192 \u8bc4\u4ef7 \u2193 \u2193 \u2193 \u2193 \u2193 \u2193 \u2193 \u5546\u54c1\u670d\u52a1 \u8d2d\u7269\u8f66\u670d\u52a1 \u8ba2\u5355\u670d\u52a1 \u652f\u4ed8\u670d\u52a1 \u5e93\u5b58\u670d\u52a1 \u7269\u6d41\u670d\u52a1 \u8bc4\u4ef7\u670d\u52a1 \u5fae\u670d\u52a1\u62c6\u5206\u7b56\u7565：<\/p>\n

text \u7535\u5546\u5fae\u670d\u52a1\u62c6\u5206\u539f\u5219：<\/p>\n

  • \u6309\u4e1a\u52a1\u9886\u57df\u62c6\u5206（DDD\u9886\u57df\u9a71\u52a8\u8bbe\u8ba1）<\/li>\n
  • \u6309\u529f\u80fd\u72ec\u7acb\u6027\u62c6\u5206<\/li>\n
  • \u6309\u6570\u636e\u8fb9\u754c\u62c6\u5206<\/li>\n
  • \u6309\u56e2\u961f\u7ed3\u6784\u62c6\u5206<\/li>\n
  • \u6309\u6027\u80fd\u9700\u6c42\u62c6\u5206<\/li>\n

    \u6838\u5fc3\u670d\u52a1\u5212\u5206： \u7528\u6237\u57df：\u7528\u6237\u670d\u52a1\u3001\u8ba4\u8bc1\u670d\u52a1\u3001\u4f1a\u5458\u670d\u52a1 \u5546\u54c1\u57df：\u5546\u54c1\u670d\u52a1\u3001\u7c7b\u76ee\u670d\u52a1\u3001\u641c\u7d22\u670d\u52a1 \u4ea4\u6613\u57df：\u8d2d\u7269\u8f66\u670d\u52a1\u3001\u8ba2\u5355\u670d\u52a1\u3001\u652f\u4ed8\u670d\u52a1 \u5e93\u5b58\u57df：\u5e93\u5b58\u670d\u52a1\u3001\u4ed3\u5e93\u670d\u52a1 \u7269\u6d41\u57df：\u7269\u6d41\u670d\u52a1\u3001\u5730\u5740\u670d\u52a1 \u8425\u9500\u57df：\u4f18\u60e0\u5238\u670d\u52a1\u3001\u6d3b\u52a8\u670d\u52a1 \u8fd0\u8425\u57df：\u7edf\u8ba1\u670d\u52a1\u3001\u901a\u77e5\u670d\u52a1 1.2 \u6280\u672f\u6808\u5168\u666f\u56fe \u5b8c\u6574\u6280\u672f\u9009\u578b：<\/p>\n

    xml<\/p>\n

    \u6838\u5fc3\u6280\u672f：Spring Boot 3.1 + Spring Cloud 2022 + JDK 17 \u6ce8\u518c\u4e2d\u5fc3：Nacos 2.2（\u670d\u52a1\u53d1\u73b0+\u914d\u7f6e\u4e2d\u5fc3） API\u7f51\u5173：Spring Cloud Gateway + Sentinel \u670d\u52a1\u901a\u4fe1：OpenFeign + LoadBalancer \u7194\u65ad\u964d\u7ea7：Resilience4j + Sentinel \u94fe\u8def\u8ffd\u8e2a：Sleuth + Zipkin + SkyWalking \u914d\u7f6e\u4e2d\u5fc3：Nacos Config \u5206\u5e03\u5f0f\u4e8b\u52a1：Seata \u6d88\u606f\u961f\u5217：RocketMQ 5.0 \u7f13\u5b58：Redis 7 + Redisson \u6570\u636e\u5e93：MySQL 8.0 + MyBatis-Plus \u641c\u7d22\u5f15\u64ce：Elasticsearch 8.0 \u5bf9\u8c61\u5b58\u50a8：MinIO \u76d1\u63a7\u544a\u8b66：Prometheus + Grafana + AlertManager \u5bb9\u5668\u5316：Docker + Kubernetes CI\/CD：Jenkins + GitLab<\/p>\n

    \u7b2c\u4e8c\u7ae0：\u9879\u76ee\u521d\u59cb\u5316\u4e0e\u57fa\u7840\u67b6\u6784<\/h3>\n

    2.1 \u521b\u5efa\u7236\u5de5\u7a0b\u4e0e\u6a21\u5757\u5212\u5206 \u9879\u76ee\u6574\u4f53\u7ed3\u6784：<\/p>\n

    text e-commerce-microservices\/ \u251c\u2500\u2500 README.md \u251c\u2500\u2500 pom.xml # \u7236\u5de5\u7a0b \u251c\u2500\u2500 docker-compose.yml \u251c\u2500\u2500 sql\/ # \u6570\u636e\u5e93\u811a\u672c \u251c\u2500\u2500 config\/ # \u914d\u7f6e\u6587\u4ef6 \u251c\u2500\u2500 scripts\/ # \u90e8\u7f72\u811a\u672c \u251c\u2500\u2500 docs\/ # \u6587\u6863 \u251c\u2500\u2500 e-commerce-parent\/ # \u7236\u6a21\u5757 \u2502 \u251c\u2500\u2500 e-commerce-common\/ # \u516c\u5171\u6a21\u5757 \u2502 \u2502 \u251c\u2500\u2500 common-core\/ # \u6838\u5fc3\u5de5\u5177 \u2502 \u2502 \u251c\u2500\u2500 common-dto\/ # \u901a\u7528DTO \u2502 \u2502 \u251c\u2500\u2500 common-feign\/ # Feign\u5ba2\u6237\u7aef \u2502 \u2502 \u251c\u2500\u2500 common-redis\/ # Redis\u914d\u7f6e \u2502 \u2502 \u251c\u2500\u2500 common-mybatis\/ # MyBatis\u914d\u7f6e \u2502 \u2502 \u2514\u2500\u2500 common-security\/ # \u5b89\u5168\u914d\u7f6e \u2502 \u2502 \u2502 \u251c\u2500\u2500 e-commerce-gateway\/ # API\u7f51\u5173 \u2502 \u251c\u2500\u2500 e-commerce-auth\/ # \u8ba4\u8bc1\u4e2d\u5fc3 \u2502 \u251c\u2500\u2500 e-commerce-user\/ # \u7528\u6237\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-product\/ # \u5546\u54c1\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-cart\/ # \u8d2d\u7269\u8f66\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-order\/ # \u8ba2\u5355\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-payment\/ # \u652f\u4ed8\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-inventory\/ # \u5e93\u5b58\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-coupon\/ # \u4f18\u60e0\u5238\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-search\/ # \u641c\u7d22\u670d\u52a1 \u2502 \u251c\u2500\u2500 e-commerce-notification\/ # \u901a\u77e5\u670d\u52a1 \u2502 \u2514\u2500\u2500 e-commerce-monitor\/ # \u76d1\u63a7\u670d\u52a1 \u2514\u2500\u2500 infrastructure\/ # \u57fa\u7840\u8bbe\u65bd \u251c\u2500\u2500 nacos\/ # Nacos\u914d\u7f6e \u251c\u2500\u2500 seata\/ # Seata\u914d\u7f6e \u251c\u2500\u2500 sentinel\/ # Sentinel\u914d\u7f6e \u2514\u2500\u2500 prometheus\/ # Prometheus\u914d\u7f6e \u7236\u5de5\u7a0bpom.xml：<\/p>\n

    xml<\/p>\n

    <?xml version="1.0" encoding="UTF-8"?> <\/p>\n

    <modelVersion>4.0.0<\/modelVersion><\/p>\n

    <groupId>com.ecommerce<\/groupId>
    \n<artifactId>e-commerce-microservices<\/artifactId>
    \n<version>1.0.0<\/version>
    \n<packaging>pom<\/packaging>
    \n<name>e-commerce-microservices<\/name>
    \n<description>\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf<\/description><\/p>\n

    <!– \u6a21\u5757\u5b9a\u4e49 –>
    \n<modules>
    \n <module>e-commerce-parent\/e-commerce-common\/common-core<\/module>
    \n <module>e-commerce-parent\/e-commerce-common\/common-dto<\/module>
    \n <module>e-commerce-parent\/e-commerce-common\/common-feign<\/module>
    \n <module>e-commerce-parent\/e-commerce-common\/common-redis<\/module>
    \n <module>e-commerce-parent\/e-commerce-common\/common-mybatis<\/module>
    \n <module>e-commerce-parent\/e-commerce-common\/common-security<\/module>
    \n <module>e-commerce-parent\/e-commerce-gateway<\/module>
    \n <module>e-commerce-parent\/e-commerce-auth<\/module>
    \n <module>e-commerce-parent\/e-commerce-user<\/module>
    \n <module>e-commerce-parent\/e-commerce-product<\/module>
    \n <module>e-commerce-parent\/e-commerce-cart<\/module>
    \n <module>e-commerce-parent\/e-commerce-order<\/module>
    \n <module>e-commerce-parent\/e-commerce-payment<\/module>
    \n <module>e-commerce-parent\/e-commerce-inventory<\/module>
    \n <module>e-commerce-parent\/e-commerce-coupon<\/module>
    \n <module>e-commerce-parent\/e-commerce-search<\/module>
    \n <module>e-commerce-parent\/e-commerce-notification<\/module>
    \n <module>e-commerce-parent\/e-commerce-monitor<\/module>
    \n<\/modules><\/p>\n

    <!– \u7edf\u4e00\u7248\u672c\u7ba1\u7406 –>
    \n<parent>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-parent<\/artifactId>
    \n <version>3.1.0<\/version>
    \n <relativePath\/>
    \n<\/parent><\/p>\n

    <properties>
    \n <!– \u57fa\u7840\u7248\u672c –>
    \n <java.version>17<\/java.version>
    \n <project.build.sourceEncoding>UTF-8<\/project.build.sourceEncoding>
    \n <project.reporting.outputEncoding>UTF-8<\/project.reporting.outputEncoding><\/p>\n

    <!– Spring Cloud –>
    \n <spring-cloud.version>2022.0.3<\/spring-cloud.version>
    \n <spring-cloud-alibaba.version>2022.0.0.0<\/spring-cloud-alibaba.version><\/p>\n

    <!– \u6301\u4e45\u5c42 –>
    \n <mybatis-plus.version>3.5.3.1<\/mybatis-plus.version>
    \n <druid.version>1.2.18<\/druid.version><\/p>\n

    <!– \u5de5\u5177 –>
    \n <mapstruct.version>1.5.5.Final<\/mapstruct.version>
    \n <lombok.version>1.18.28<\/lombok.version>
    \n <hutool.version>5.8.20<\/hutool.version><\/p>\n

    <!– \u7f13\u5b58 –>
    \n <redisson.version>3.20.0<\/redisson.version><\/p>\n

    <!– \u5206\u5e03\u5f0f\u4e8b\u52a1 –>
    \n <seata.version>1.7.1<\/seata.version><\/p>\n

    <!– \u6d88\u606f\u961f\u5217 –>
    \n <rocketmq.version>2.2.3<\/rocketmq.version><\/p>\n

    <!– \u670d\u52a1\u7aef\u53e3 –>
    \n <gateway.port>8080<\/gateway.port>
    \n <auth.port>8081<\/auth.port>
    \n <user.port>8082<\/user.port>
    \n <product.port>8083<\/product.port>
    \n <cart.port>8084<\/cart.port>
    \n <order.port>8085<\/order.port>
    \n <payment.port>8086<\/payment.port>
    \n <inventory.port>8087<\/inventory.port>
    \n<\/properties><\/p>\n

    <!– \u4f9d\u8d56\u7ba1\u7406 –>
    \n<dependencyManagement>
    \n <dependencies>
    \n <!– Spring Cloud –>
    \n <dependency>
    \n <groupId>org.springframework.cloud<\/groupId>
    \n <artifactId>spring-cloud-dependencies<\/artifactId>
    \n <version>${spring-cloud.version}<\/version>
    \n <type>pom<\/type>
    \n <scope>import<\/scope>
    \n <\/dependency><\/p>\n

    <!– Spring Cloud Alibaba –>
    \n <dependency>
    \n <groupId>com.alibaba.cloud<\/groupId>
    \n <artifactId>spring-cloud-alibaba-dependencies<\/artifactId>
    \n <version>${spring-cloud-alibaba.version}<\/version>
    \n <type>pom<\/type>
    \n <scope>import<\/scope>
    \n <\/dependency><\/p>\n

    <!– MyBatis Plus –>
    \n <dependency>
    \n <groupId>com.baomidou<\/groupId>
    \n <artifactId>mybatis-plus-boot-starter<\/artifactId>
    \n <version>${mybatis-plus.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– Druid –>
    \n <dependency>
    \n <groupId>com.alibaba<\/groupId>
    \n <artifactId>druid-spring-boot-starter<\/artifactId>
    \n <version>${druid.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– MapStruct –>
    \n <dependency>
    \n <groupId>org.mapstruct<\/groupId>
    \n <artifactId>mapstruct<\/artifactId>
    \n <version>${mapstruct.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– Redisson –>
    \n <dependency>
    \n <groupId>org.redisson<\/groupId>
    \n <artifactId>redisson-spring-boot-starter<\/artifactId>
    \n <version>${redisson.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– Hutool –>
    \n <dependency>
    \n <groupId>cn.hutool<\/groupId>
    \n <artifactId>hutool-all<\/artifactId>
    \n <version>${hutool.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– Seata –>
    \n <dependency>
    \n <groupId>io.seata<\/groupId>
    \n <artifactId>seata-spring-boot-starter<\/artifactId>
    \n <version>${seata.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– RocketMQ –>
    \n <dependency>
    \n <groupId>org.apache.rocketmq<\/groupId>
    \n <artifactId>rocketmq-spring-boot-starter<\/artifactId>
    \n <version>${rocketmq.version}<\/version>
    \n <\/dependency>
    \n <\/dependencies>
    \n<\/dependencyManagement><\/p>\n

    <!– \u901a\u7528\u4f9d\u8d56 –>
    \n<dependencies>
    \n <!– Lombok –>
    \n <dependency>
    \n <groupId>org.projectlombok<\/groupId>
    \n <artifactId>lombok<\/artifactId>
    \n <optional>true<\/optional>
    \n <\/dependency><\/p>\n

    <!– \u6d4b\u8bd5 –>
    \n <dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-test<\/artifactId>
    \n <scope>test<\/scope>
    \n <\/dependency>
    \n<\/dependencies><\/p>\n

    <!– \u6784\u5efa\u914d\u7f6e –>
    \n<build>
    \n <plugins>
    \n <!– \u7f16\u8bd1\u5668\u63d2\u4ef6 –>
    \n <plugin>
    \n <groupId>org.apache.maven.plugins<\/groupId>
    \n <artifactId>maven-compiler-plugin<\/artifactId>
    \n <configuration>
    \n <source>${java.version}<\/source>
    \n <target>${java.version}<\/target>
    \n <encoding>${project.build.sourceEncoding}<\/encoding>
    \n <annotationProcessorPaths>
    \n <path>
    \n <groupId>org.projectlombok<\/groupId>
    \n <artifactId>lombok<\/artifactId>
    \n <version>${lombok.version}<\/version>
    \n <\/path>
    \n <path>
    \n <groupId>org.mapstruct<\/groupId>
    \n <artifactId>mapstruct-processor<\/artifactId>
    \n <version>${mapstruct.version}<\/version>
    \n <\/path>
    \n <path>
    \n <groupId>org.projectlombok<\/groupId>
    \n <artifactId>lombok-mapstruct-binding<\/artifactId>
    \n <version>0.2.0<\/version>
    \n <\/path>
    \n <\/annotationProcessorPaths>
    \n <\/configuration>
    \n <\/plugin><\/p>\n

    <!– Spring Boot Maven\u63d2\u4ef6 –>
    \n <plugin>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-maven-plugin<\/artifactId>
    \n <configuration>
    \n <excludes>
    \n <exclude>
    \n <groupId>org.projectlombok<\/groupId>
    \n <artifactId>lombok<\/artifactId>
    \n <\/exclude>
    \n <\/excludes>
    \n <\/configuration>
    \n <\/plugin>
    \n <\/plugins>
    \n<\/build>
    \n 2.2 \u516c\u5171\u6a21\u5757\u8bbe\u8ba1 common-core \u6838\u5fc3\u5de5\u5177\u6a21\u5757： <\/p>\n

    java \/\/ 1. \u7edf\u4e00\u54cd\u5e94\u7c7b package com.ecommerce.common.core.response;<\/p>\n

    import lombok.Data; import lombok.experimental.Accessors;<\/p>\n

    import java.io.Serializable;<\/p>\n

    @Data @Accessors(chain = true) public class ApiResponse implements Serializable {<\/p>\n

    private Integer code;
    \nprivate String message;
    \nprivate T data;
    \nprivate Long timestamp;<\/p>\n

    public static <T> ApiResponse<T> success() {
    \n return success(null);
    \n}<\/p>\n

    public static <T> ApiResponse<T> success(T data) {
    \n return new ApiResponse<T>()
    \n .setCode(200)
    \n .setMessage("\u6210\u529f")
    \n .setData(data)
    \n .setTimestamp(System.currentTimeMillis());
    \n}<\/p>\n

    public static <T> ApiResponse<T> success(String message, T data) {
    \n return new ApiResponse<T>()
    \n .setCode(200)
    \n .setMessage(message)
    \n .setData(data)
    \n .setTimestamp(System.currentTimeMillis());
    \n}<\/p>\n

    public static <T> ApiResponse<T> error(Integer code, String message) {
    \n return new ApiResponse<T>()
    \n .setCode(code)
    \n .setMessage(message)
    \n .setTimestamp(System.currentTimeMillis());
    \n}<\/p>\n

    public static <T> ApiResponse<T> error(String message) {
    \n return error(500, message);
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 2. \u4e1a\u52a1\u5f02\u5e38\u7c7b package com.ecommerce.common.core.exception;<\/p>\n

    import lombok.Getter;<\/p>\n

    @Getter public class BusinessException extends RuntimeException {<\/p>\n

    private final Integer code;
    \nprivate final String message;<\/p>\n

    public BusinessException(String message) {
    \n super(message);
    \n this.code = 500;
    \n this.message = message;
    \n}<\/p>\n

    public BusinessException(Integer code, String message) {
    \n super(message);
    \n this.code = code;
    \n this.message = message;
    \n}<\/p>\n

    public BusinessException(ErrorCode errorCode) {
    \n super(errorCode.getMessage());
    \n this.code = errorCode.getCode();
    \n this.message = errorCode.getMessage();
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 3. \u9519\u8bef\u7801\u679a\u4e3e package com.ecommerce.common.core.exception;<\/p>\n

    import lombok.Getter;<\/p>\n

    @Getter public enum ErrorCode {<\/p>\n

    \/\/ \u901a\u7528\u9519\u8bef\u7801
    \nSUCCESS(200, "\u6210\u529f"),
    \nPARAM_ERROR(400, "\u53c2\u6570\u9519\u8bef"),
    \nUNAUTHORIZED(401, "\u672a\u6388\u6743"),
    \nFORBIDDEN(403, "\u7981\u6b62\u8bbf\u95ee"),
    \nNOT_FOUND(404, "\u8d44\u6e90\u4e0d\u5b58\u5728"),
    \nMETHOD_NOT_ALLOWED(405, "\u65b9\u6cd5\u4e0d\u5141\u8bb8"),
    \nSYSTEM_ERROR(500, "\u7cfb\u7edf\u9519\u8bef"),
    \nSERVICE_UNAVAILABLE(503, "\u670d\u52a1\u4e0d\u53ef\u7528"),<\/p>\n

    \/\/ \u4e1a\u52a1\u9519\u8bef\u7801 1000-1999
    \nUSER_NOT_EXIST(1001, "\u7528\u6237\u4e0d\u5b58\u5728"),
    \nUSER_DISABLED(1002, "\u7528\u6237\u5df2\u88ab\u7981\u7528"),
    \nUSER_PASSWORD_ERROR(1003, "\u5bc6\u7801\u9519\u8bef"),
    \nUSER_EXISTS(1004, "\u7528\u6237\u5df2\u5b58\u5728"),<\/p>\n

    \/\/ \u5546\u54c1\u9519\u8bef\u7801 2000-2999
    \nPRODUCT_NOT_EXIST(2001, "\u5546\u54c1\u4e0d\u5b58\u5728"),
    \nPRODUCT_OFF_SHELF(2002, "\u5546\u54c1\u5df2\u4e0b\u67b6"),
    \nPRODUCT_INSUFFICIENT_STOCK(2003, "\u5546\u54c1\u5e93\u5b58\u4e0d\u8db3"),<\/p>\n

    \/\/ \u8ba2\u5355\u9519\u8bef\u7801 3000-3999
    \nORDER_NOT_EXIST(3001, "\u8ba2\u5355\u4e0d\u5b58\u5728"),
    \nORDER_STATUS_ERROR(3002, "\u8ba2\u5355\u72b6\u6001\u9519\u8bef"),
    \nORDER_CANCEL_FAILED(3003, "\u8ba2\u5355\u53d6\u6d88\u5931\u8d25"),<\/p>\n

    \/\/ \u652f\u4ed8\u9519\u8bef\u7801 4000-4999
    \nPAYMENT_FAILED(4001, "\u652f\u4ed8\u5931\u8d25"),
    \nPAYMENT_NOT_EXIST(4002, "\u652f\u4ed8\u8bb0\u5f55\u4e0d\u5b58\u5728"),<\/p>\n

    \/\/ \u5e93\u5b58\u9519\u8bef\u7801 5000-5999
    \nINVENTORY_LOCK_FAILED(5001, "\u5e93\u5b58\u9501\u5b9a\u5931\u8d25"),
    \nINVENTORY_RELEASE_FAILED(5002, "\u5e93\u5b58\u91ca\u653e\u5931\u8d25"),<\/p>\n

    \/\/ \u4f18\u60e0\u5238\u9519\u8bef\u7801 6000-6999
    \nCOUPON_NOT_EXIST(6001, "\u4f18\u60e0\u5238\u4e0d\u5b58\u5728"),
    \nCOUPON_EXPIRED(6002, "\u4f18\u60e0\u5238\u5df2\u8fc7\u671f"),
    \nCOUPON_USED(6003, "\u4f18\u60e0\u5238\u5df2\u4f7f\u7528");<\/p>\n

    private final Integer code;
    \nprivate final String message;<\/p>\n

    ErrorCode(Integer code, String message) {
    \n this.code = code;
    \n this.message = message;
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 4. \u7edf\u4e00\u5f02\u5e38\u5904\u7406\u5668 package com.ecommerce.common.core.handler;<\/p>\n

    import com.ecommerce.common.core.response.ApiResponse; import lombok.extern.slf4j.Slf4j; import org.springframework.validation.BindException; import org.springframework.validation.FieldError; import org.springframework.web.bind.MethodArgumentNotValidException; import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.RestControllerAdvice;<\/p>\n

    import java.util.HashMap; import java.util.Map;<\/p>\n

    @Slf4j @RestControllerAdvice public class GlobalExceptionHandler {<\/p>\n

    @ExceptionHandler(BusinessException.class)
    \npublic ApiResponse<?> handleBusinessException(BusinessException e) {
    \n log.error("\u4e1a\u52a1\u5f02\u5e38: code={}, message={}", e.getCode(), e.getMessage());
    \n return ApiResponse.error(e.getCode(), e.getMessage());
    \n}<\/p>\n

    @ExceptionHandler(MethodArgumentNotValidException.class)
    \npublic ApiResponse<?> handleValidationException(MethodArgumentNotValidException e) {
    \n Map<String, String> errors = new HashMap<>();
    \n e.getBindingResult().getAllErrors().forEach(error -> {
    \n String fieldName = ((FieldError) error).getField();
    \n String errorMessage = error.getDefaultMessage();
    \n errors.put(fieldName, errorMessage);
    \n });<\/p>\n

    log.error("\u53c2\u6570\u9a8c\u8bc1\u5931\u8d25: {}", errors);
    \n return ApiResponse.error(400, "\u53c2\u6570\u9a8c\u8bc1\u5931\u8d25").setData(errors);
    \n}<\/p>\n

    @ExceptionHandler(Exception.class)
    \npublic ApiResponse<?> handleGlobalException(Exception e) {
    \n log.error("\u7cfb\u7edf\u5f02\u5e38: ", e);
    \n return ApiResponse.error(500, "\u7cfb\u7edf\u5f02\u5e38，\u8bf7\u7a0d\u540e\u91cd\u8bd5");
    \n}<\/p>\n

    } common-dto \u6570\u636e\u4f20\u8f93\u5bf9\u8c61：<\/p>\n

    java \/\/ 1. \u5206\u9875\u8bf7\u6c42DTO package com.ecommerce.common.dto;<\/p>\n

    import lombok.Data;<\/p>\n

    @Data public class PageRequest {<\/p>\n

    private Integer pageNum = 1;
    \nprivate Integer pageSize = 10;
    \nprivate String orderBy;
    \nprivate Boolean asc = true;<\/p>\n

    public Integer getOffset() {
    \n return (pageNum – 1) * pageSize;
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 2. \u5206\u9875\u54cd\u5e94DTO package com.ecommerce.common.dto;<\/p>\n

    import lombok.Data; import lombok.NoArgsConstructor;<\/p>\n

    import java.util.List;<\/p>\n

    @Data @NoArgsConstructor public class PageResult {<\/p>\n

    private Integer pageNum;
    \nprivate Integer pageSize;
    \nprivate Long total;
    \nprivate Integer pages;
    \nprivate List<T> list;<\/p>\n

    public PageResult(Integer pageNum, Integer pageSize, Long total, List<T> list) {
    \n this.pageNum = pageNum;
    \n this.pageSize = pageSize;
    \n this.total = total;
    \n this.pages = (int) Math.ceil((double) total \/ pageSize);
    \n this.list = list;
    \n}<\/p>\n

    public static <T> PageResult<T> of(Integer pageNum, Integer pageSize, Long total, List<T> list) {
    \n return new PageResult<>(pageNum, pageSize, total, list);
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 3. \u7528\u6237\u4e0a\u4e0b\u6587DTO package com.ecommerce.common.dto;<\/p>\n

    import lombok.Data;<\/p>\n

    @Data public class UserContext {<\/p>\n

    private Long userId;
    \nprivate String username;
    \nprivate String nickname;
    \nprivate String phone;
    \nprivate String email;
    \nprivate Integer userType;
    \nprivate String token;<\/p>\n

    public static UserContext empty() {
    \n return new UserContext();
    \n}<\/p>\n

    public boolean isLogin() {
    \n return userId != null;
    \n}<\/p>\n

    } common-feign Feign\u5ba2\u6237\u7aef\u914d\u7f6e：<\/p>\n

    java \/\/ 1. Feign\u914d\u7f6e\u7c7b package com.ecommerce.common.feign.config;<\/p>\n

    import com.ecommerce.common.feign.interceptor.FeignAuthInterceptor; import feign.Logger; import feign.Request; import feign.Retryer; import feign.codec.ErrorDecoder; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;<\/p>\n

    import java.util.concurrent.TimeUnit;<\/p>\n

    @Configuration public class FeignConfig {<\/p>\n

    @Bean
    \npublic Logger.Level feignLoggerLevel() {
    \n return Logger.Level.FULL;
    \n}<\/p>\n

    @Bean
    \npublic Request.Options options() {
    \n return new Request.Options(
    \n 5, TimeUnit.SECONDS, \/\/ \u8fde\u63a5\u8d85\u65f6
    \n 30, TimeUnit.SECONDS, \/\/ \u8bfb\u53d6\u8d85\u65f6
    \n true \/\/ \u8ddf\u968f\u91cd\u5b9a\u5411
    \n );
    \n}<\/p>\n

    @Bean
    \npublic Retryer feignRetryer() {
    \n \/\/ \u6700\u5927\u91cd\u8bd53\u6b21，\u521d\u59cb\u95f4\u9694100ms
    \n return new Retryer.Default(100, TimeUnit.SECONDS.toMillis(1), 3);
    \n}<\/p>\n

    @Bean
    \npublic FeignAuthInterceptor feignAuthInterceptor() {
    \n return new FeignAuthInterceptor();
    \n}<\/p>\n

    @Bean
    \npublic ErrorDecoder errorDecoder() {
    \n return new FeignErrorDecoder();
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 2. Feign\u8ba4\u8bc1\u62e6\u622a\u5668 package com.ecommerce.common.feign.interceptor;<\/p>\n

    import feign.RequestInterceptor; import feign.RequestTemplate; import lombok.extern.slf4j.Slf4j; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes;<\/p>\n

    import jakarta.servlet.http.HttpServletRequest; import java.util.Enumeration;<\/p>\n

    @Slf4j public class FeignAuthInterceptor implements RequestInterceptor {<\/p>\n

    @Override
    \npublic void apply(RequestTemplate template) {
    \n \/\/ \u4f20\u9012\u8ba4\u8bc1\u4fe1\u606f
    \n ServletRequestAttributes attributes =
    \n (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();<\/p>\n

    if (attributes != null) {
    \n HttpServletRequest request = attributes.getRequest();
    \n Enumeration<String> headerNames = request.getHeaderNames();<\/p>\n

    while (headerNames.hasMoreElements()) {
    \n String headerName = headerNames.nextElement();
    \n if (headerName.startsWith("x-") ||
    \n headerName.equalsIgnoreCase("authorization")) {
    \n String headerValue = request.getHeader(headerName);
    \n template.header(headerName, headerValue);
    \n }
    \n }
    \n }<\/p>\n

    \/\/ \u6dfb\u52a0Feign\u8c03\u7528\u6807\u8bc6
    \n template.header("X-Feign-Request", "true");
    \n template.header("X-Request-ID", generateRequestId());<\/p>\n

    log.debug("Feign\u8bf7\u6c42: {} {}, Headers: {}",
    \n template.method(), template.url(), template.headers());
    \n}<\/p>\n

    private String generateRequestId() {
    \n return java.util.UUID.randomUUID().toString();
    \n}<\/p>\n

    }<\/p>\n

    \/\/ 3. Feign\u964d\u7ea7\u5de5\u5382 package com.ecommerce.common.feign.fallback;<\/p>\n

    import feign.hystrix.FallbackFactory; import lombok.extern.slf4j.Slf4j;<\/p>\n

    @Slf4j public class CommonFallbackFactory implements FallbackFactory {<\/p>\n

    private final Class<T> targetType;<\/p>\n

    public CommonFallbackFactory(Class<T> targetType) {
    \n this.targetType = targetType;
    \n}<\/p>\n

    @Override
    \npublic T create(Throwable cause) {
    \n log.error("Feign\u8c03\u7528\u5931\u8d25，\u670d\u52a1: {}, \u9519\u8bef: {}",
    \n targetType.getSimpleName(), cause.getMessage());<\/p>\n

    return new FallbackProxy<>(targetType, cause).createProxy();
    \n}<\/p>\n

    } 2.3 \u6570\u636e\u5e93\u8bbe\u8ba1\u4e0e\u521d\u59cb\u5316 \u6570\u636e\u5e93\u8bbe\u8ba1\u539f\u5219：<\/p>\n

    sql \u2013 1. \u7528\u6237\u6570\u636e\u5e93 (user_db) CREATE DATABASE IF NOT EXISTS user_db DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;<\/p>\n

    \u2013 \u7528\u6237\u8868 CREATE TABLE user_db.tb_user ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u7528\u6237ID\u2019, username VARCHAR(50) NOT NULL COMMENT \u2018\u7528\u6237\u540d\u2019, password VARCHAR(100) NOT NULL COMMENT \u2018\u5bc6\u7801\u2019, nickname VARCHAR(50) COMMENT \u2018\u6635\u79f0\u2019, phone VARCHAR(20) COMMENT \u2018\u624b\u673a\u53f7\u2019, email VARCHAR(100) COMMENT \u2018\u90ae\u7bb1\u2019, avatar VARCHAR(500) COMMENT \u2018\u5934\u50cf\u2019, gender TINYINT DEFAULT 0 COMMENT \u2018\u6027\u522b 0-\u672a\u77e5 1-\u7537 2-\u5973\u2019, birthday DATE COMMENT \u2018\u751f\u65e5\u2019, status TINYINT DEFAULT 1 COMMENT \u2018\u72b6\u6001 0-\u7981\u7528 1-\u6b63\u5e38\u2019, user_type TINYINT DEFAULT 1 COMMENT \u2018\u7528\u6237\u7c7b\u578b 1-\u666e\u901a\u7528\u6237 2-\u4f1a\u5458 3-\u7ba1\u7406\u5458\u2019, last_login_time DATETIME COMMENT \u2018\u6700\u540e\u767b\u5f55\u65f6\u95f4\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT \u2018\u66f4\u65b0\u65f6\u95f4\u2019, PRIMARY KEY (id), UNIQUE KEY uk_username (username), UNIQUE KEY uk_phone (phone), UNIQUE KEY uk_email (email), KEY idx_status (status), KEY idx_create_time (create_time) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u7528\u6237\u8868\u2019;<\/p>\n

    \u2013 \u7528\u6237\u5730\u5740\u8868 CREATE TABLE user_db.tb_user_address ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u5730\u5740ID\u2019, user_id BIGINT NOT NULL COMMENT \u2018\u7528\u6237ID\u2019, receiver_name VARCHAR(50) NOT NULL COMMENT \u2018\u6536\u8d27\u4eba\u59d3\u540d\u2019, receiver_phone VARCHAR(20) NOT NULL COMMENT \u2018\u6536\u8d27\u4eba\u7535\u8bdd\u2019, province VARCHAR(50) COMMENT \u2018\u7701\u2019, city VARCHAR(50) COMMENT \u2018\u5e02\u2019, district VARCHAR(50) COMMENT \u2018\u533a\u2019, detail VARCHAR(200) COMMENT \u2018\u8be6\u7ec6\u5730\u5740\u2019, postal_code VARCHAR(10) COMMENT \u2018\u90ae\u653f\u7f16\u7801\u2019, is_default TINYINT DEFAULT 0 COMMENT \u2018\u662f\u5426\u9ed8\u8ba4\u5730\u5740 0-\u5426 1-\u662f\u2019, status TINYINT DEFAULT 1 COMMENT \u2018\u72b6\u6001 0-\u5220\u9664 1-\u6b63\u5e38\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT \u2018\u66f4\u65b0\u65f6\u95f4\u2019, PRIMARY KEY (id), KEY idx_user_id (user_id), KEY idx_is_default (is_default), CONSTRAINT fk_user_address_user FOREIGN KEY (user_id) REFERENCES tb_user (id) ON DELETE CASCADE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u7528\u6237\u5730\u5740\u8868\u2019;<\/p>\n

    \u2013 2. \u5546\u54c1\u6570\u636e\u5e93 (product_db) CREATE DATABASE IF NOT EXISTS product_db DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;<\/p>\n

    \u2013 \u5546\u54c1\u8868 CREATE TABLE product_db.tb_product ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u5546\u54c1ID\u2019, spu_code VARCHAR(50) NOT NULL COMMENT \u2018SPU\u7f16\u7801\u2019, name VARCHAR(200) NOT NULL COMMENT \u2018\u5546\u54c1\u540d\u79f0\u2019, sub_title VARCHAR(500) COMMENT \u2018\u526f\u6807\u9898\u2019, category_id BIGINT NOT NULL COMMENT \u2018\u5206\u7c7bID\u2019, brand_id BIGINT COMMENT \u2018\u54c1\u724cID\u2019, main_image VARCHAR(500) COMMENT \u2018\u4e3b\u56fe\u2019, images TEXT COMMENT \u2018\u5546\u54c1\u56fe\u7247JSON\u6570\u7ec4\u2019, detail TEXT COMMENT \u2018\u5546\u54c1\u8be6\u60c5\u2019, specifications TEXT COMMENT \u2018\u89c4\u683c\u53c2\u6570JSON\u2019, price DECIMAL(10,2) NOT NULL COMMENT \u2018\u4ef7\u683c\u2019, market_price DECIMAL(10,2) COMMENT \u2018\u5e02\u573a\u4ef7\u683c\u2019, cost_price DECIMAL(10,2) COMMENT \u2018\u6210\u672c\u4ef7\u2019, stock INT NOT NULL DEFAULT 0 COMMENT \u2018\u5e93\u5b58\u2019, sales INT DEFAULT 0 COMMENT \u2018\u9500\u91cf\u2019, status TINYINT DEFAULT 1 COMMENT \u2018\u72b6\u6001 0-\u4e0b\u67b6 1-\u4e0a\u67b6 2-\u5f85\u5ba1\u6838\u2019, weight DECIMAL(10,3) COMMENT \u2018\u91cd\u91cf(kg)\u2019, volume DECIMAL(10,3) COMMENT \u2018\u4f53\u79ef(m\u00b3)\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT \u2018\u66f4\u65b0\u65f6\u95f4\u2019, PRIMARY KEY (id), UNIQUE KEY uk_spu_code (spu_code), KEY idx_category_id (category_id), KEY idx_brand_id (brand_id), KEY idx_status (status), KEY idx_create_time (create_time) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u5546\u54c1\u8868\u2019;<\/p>\n

    \u2013 \u5546\u54c1SKU\u8868 CREATE TABLE product_db.tb_product_sku ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018SKU ID\u2019, product_id BIGINT NOT NULL COMMENT \u2018\u5546\u54c1ID\u2019, sku_code VARCHAR(50) NOT NULL COMMENT \u2018SKU\u7f16\u7801\u2019, specifications VARCHAR(500) COMMENT \u2018\u89c4\u683cJSON\u2019, price DECIMAL(10,2) NOT NULL COMMENT \u2018\u4ef7\u683c\u2019, market_price DECIMAL(10,2) COMMENT \u2018\u5e02\u573a\u4ef7\u683c\u2019, stock INT NOT NULL DEFAULT 0 COMMENT \u2018\u5e93\u5b58\u2019, sales INT DEFAULT 0 COMMENT \u2018\u9500\u91cf\u2019, image VARCHAR(500) COMMENT \u2018SKU\u56fe\u7247\u2019, status TINYINT DEFAULT 1 COMMENT \u2018\u72b6\u6001 0-\u7981\u7528 1-\u6b63\u5e38\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT \u2018\u66f4\u65b0\u65f6\u95f4\u2019, PRIMARY KEY (id), UNIQUE KEY uk_sku_code (sku_code), KEY idx_product_id (product_id), KEY idx_status (status), CONSTRAINT fk_product_sku_product FOREIGN KEY (product_id) REFERENCES tb_product (id) ON DELETE CASCADE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u5546\u54c1SKU\u8868\u2019;<\/p>\n

    \u2013 3. \u8ba2\u5355\u6570\u636e\u5e93 (order_db) CREATE DATABASE IF NOT EXISTS order_db DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;<\/p>\n

    \u2013 \u8ba2\u5355\u8868 CREATE TABLE order_db.tb_order ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u8ba2\u5355ID\u2019, order_no VARCHAR(32) NOT NULL COMMENT \u2018\u8ba2\u5355\u53f7\u2019, user_id BIGINT NOT NULL COMMENT \u2018\u7528\u6237ID\u2019, total_amount DECIMAL(10,2) NOT NULL COMMENT \u2018\u8ba2\u5355\u603b\u91d1\u989d\u2019, discount_amount DECIMAL(10,2) DEFAULT 0 COMMENT \u2018\u4f18\u60e0\u91d1\u989d\u2019, shipping_amount DECIMAL(10,2) DEFAULT 0 COMMENT \u2018\u8fd0\u8d39\u2019, pay_amount DECIMAL(10,2) NOT NULL COMMENT \u2018\u5b9e\u4ed8\u91d1\u989d\u2019, payment_type TINYINT COMMENT \u2018\u652f\u4ed8\u65b9\u5f0f 1-\u5fae\u4fe1 2-\u652f\u4ed8\u5b9d\u2019, status TINYINT NOT NULL COMMENT \u2018\u8ba2\u5355\u72b6\u6001 1-\u5f85\u4ed8\u6b3e 2-\u5f85\u53d1\u8d27 3-\u5df2\u53d1\u8d27 4-\u5df2\u5b8c\u6210 5-\u5df2\u53d6\u6d88\u2019, payment_time DATETIME COMMENT \u2018\u652f\u4ed8\u65f6\u95f4\u2019, shipping_time DATETIME COMMENT \u2018\u53d1\u8d27\u65f6\u95f4\u2019, receive_time DATETIME COMMENT \u2018\u6536\u8d27\u65f6\u95f4\u2019, cancel_time DATETIME COMMENT \u2018\u53d6\u6d88\u65f6\u95f4\u2019, cancel_reason VARCHAR(200) COMMENT \u2018\u53d6\u6d88\u539f\u56e0\u2019, remark VARCHAR(500) COMMENT \u2018\u8ba2\u5355\u5907\u6ce8\u2019, receiver_name VARCHAR(50) NOT NULL COMMENT \u2018\u6536\u8d27\u4eba\u59d3\u540d\u2019, receiver_phone VARCHAR(20) NOT NULL COMMENT \u2018\u6536\u8d27\u4eba\u7535\u8bdd\u2019, receiver_address VARCHAR(500) NOT NULL COMMENT \u2018\u6536\u8d27\u5730\u5740\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT \u2018\u66f4\u65b0\u65f6\u95f4\u2019, PRIMARY KEY (id), UNIQUE KEY uk_order_no (order_no), KEY idx_user_id (user_id), KEY idx_status (status), KEY idx_create_time (create_time) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u8ba2\u5355\u8868\u2019;<\/p>\n

    \u2013 \u8ba2\u5355\u5546\u54c1\u8868 CREATE TABLE order_db.tb_order_item ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u8ba2\u5355\u5546\u54c1ID\u2019, order_id BIGINT NOT NULL COMMENT \u2018\u8ba2\u5355ID\u2019, product_id BIGINT NOT NULL COMMENT \u2018\u5546\u54c1ID\u2019, product_name VARCHAR(200) NOT NULL COMMENT \u2018\u5546\u54c1\u540d\u79f0\u2019, product_image VARCHAR(500) COMMENT \u2018\u5546\u54c1\u56fe\u7247\u2019, sku_id BIGINT COMMENT \u2018SKU ID\u2019, sku_code VARCHAR(50) COMMENT \u2018SKU\u7f16\u7801\u2019, specifications VARCHAR(500) COMMENT \u2018\u89c4\u683c\u2019, price DECIMAL(10,2) NOT NULL COMMENT \u2018\u5355\u4ef7\u2019, quantity INT NOT NULL COMMENT \u2018\u6570\u91cf\u2019, total_amount DECIMAL(10,2) NOT NULL COMMENT \u2018\u603b\u91d1\u989d\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, PRIMARY KEY (id), KEY idx_order_id (order_id), KEY idx_product_id (product_id), CONSTRAINT fk_order_item_order FOREIGN KEY (order_id) REFERENCES tb_order (id) ON DELETE CASCADE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u8ba2\u5355\u5546\u54c1\u8868\u2019;<\/p>\n

    \u2013 4. \u5e93\u5b58\u6570\u636e\u5e93 (inventory_db) CREATE DATABASE IF NOT EXISTS inventory_db DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;<\/p>\n

    \u2013 \u5e93\u5b58\u8868 CREATE TABLE inventory_db.tb_inventory ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u5e93\u5b58ID\u2019, product_id BIGINT NOT NULL COMMENT \u2018\u5546\u54c1ID\u2019, sku_id BIGINT COMMENT \u2018SKU ID\u2019, warehouse_id BIGINT NOT NULL COMMENT \u2018\u4ed3\u5e93ID\u2019, total_stock INT NOT NULL DEFAULT 0 COMMENT \u2018\u603b\u5e93\u5b58\u2019, available_stock INT NOT NULL DEFAULT 0 COMMENT \u2018\u53ef\u7528\u5e93\u5b58\u2019, locked_stock INT DEFAULT 0 COMMENT \u2018\u9501\u5b9a\u5e93\u5b58\u2019, occupied_stock INT DEFAULT 0 COMMENT \u2018\u5360\u7528\u5e93\u5b58\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT \u2018\u66f4\u65b0\u65f6\u95f4\u2019, PRIMARY KEY (id), UNIQUE KEY uk_product_warehouse (product_id, warehouse_id), KEY idx_sku_id (sku_id), KEY idx_warehouse_id (warehouse_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u5e93\u5b58\u8868\u2019;<\/p>\n

    \u2013 \u5e93\u5b58\u64cd\u4f5c\u8bb0\u5f55\u8868 CREATE TABLE inventory_db.tb_inventory_log ( id BIGINT NOT NULL AUTO_INCREMENT COMMENT \u2018\u65e5\u5fd7ID\u2019, product_id BIGINT NOT NULL COMMENT \u2018\u5546\u54c1ID\u2019, sku_id BIGINT COMMENT \u2018SKU ID\u2019, warehouse_id BIGINT NOT NULL COMMENT \u2018\u4ed3\u5e93ID\u2019, order_no VARCHAR(32) COMMENT \u2018\u8ba2\u5355\u53f7\u2019, operation_type TINYINT NOT NULL COMMENT \u2018\u64cd\u4f5c\u7c7b\u578b 1-\u5165\u5e93 2-\u51fa\u5e93 3-\u9501\u5b9a 4-\u89e3\u9501 5-\u5360\u7528 6-\u91ca\u653e\u2019, quantity INT NOT NULL COMMENT \u2018\u64cd\u4f5c\u6570\u91cf\u2019, before_stock INT NOT NULL COMMENT \u2018\u64cd\u4f5c\u524d\u5e93\u5b58\u2019, after_stock INT NOT NULL COMMENT \u2018\u64cd\u4f5c\u540e\u5e93\u5b58\u2019, remark VARCHAR(200) COMMENT \u2018\u5907\u6ce8\u2019, operator VARCHAR(50) COMMENT \u2018\u64cd\u4f5c\u4eba\u2019, create_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT \u2018\u521b\u5efa\u65f6\u95f4\u2019, PRIMARY KEY (id), KEY idx_product_id (product_id), KEY idx_order_no (order_no), KEY idx_create_time (create_time) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT=\u2018\u5e93\u5b58\u64cd\u4f5c\u8bb0\u5f55\u8868\u2019;<\/p>\n

    \u7b2c\u4e09\u7ae0：\u7528\u6237\u670d\u52a1\u5b9e\u73b0<\/h3>\n

    3.1 \u7528\u6237\u670d\u52a1\u6838\u5fc3\u529f\u80fd \u7528\u6237\u670d\u52a1pom.xml：<\/p>\n

    xml<\/p>\n

    <?xml version="1.0" encoding="UTF-8"?> <\/p>\n

    <modelVersion>4.0.0<\/modelVersion><\/p>\n

    <parent>
    \n <groupId>com.ecommerce<\/groupId>
    \n <artifactId>e-commerce-microservices<\/artifactId>
    \n <version>1.0.0<\/version>
    \n<\/parent><\/p>\n

    <artifactId>e-commerce-user<\/artifactId>
    \n<name>e-commerce-user<\/name>
    \n<description>\u7528\u6237\u670d\u52a1<\/description><\/p>\n

    <properties>
    \n <service.port>8082<\/service.port>
    \n<\/properties><\/p>\n

    <dependencies>
    \n <!– \u516c\u5171\u6a21\u5757 –>
    \n <dependency>
    \n <groupId>com.ecommerce<\/groupId>
    \n <artifactId>common-core<\/artifactId>
    \n <version>${project.version}<\/version>
    \n <\/dependency><\/p>\n

    <dependency>
    \n <groupId>com.ecommerce<\/groupId>
    \n <artifactId>common-dto<\/artifactId>
    \n <version>${project.version}<\/version>
    \n <\/dependency><\/p>\n

    <!– Spring Boot –>
    \n <dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-web<\/artifactId>
    \n <\/dependency><\/p>\n

    <dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-validation<\/artifactId>
    \n <\/dependency><\/p>\n

    <!– Spring Cloud –>
    \n <dependency>
    \n <groupId>org.springframework.cloud<\/groupId>
    \n <artifactId>spring-cloud-starter-bootstrap<\/artifactId>
    \n <\/dependency><\/p>\n

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

    <dependency>
    \n <groupId>com.alibaba.cloud<\/groupId>
    \n <artifactId>spring-cloud-starter-alibaba-nacos-config<\/artifactId>
    \n <\/dependency><\/p>\n

    <!– \u6301\u4e45\u5c42 –>
    \n <dependency>
    \n <groupId>com.baomidou<\/groupId>
    \n <artifactId>mybatis-plus-boot-starter<\/artifactId>
    \n <\/dependency><\/p>\n

    <dependency>
    \n <groupId>com.alibaba<\/groupId>
    \n <artifactId>druid-spring-boot-starter<\/artifactId>
    \n <\/dependency><\/p>\n

    <!– \u6570\u636e\u5e93\u9a71\u52a8 –>
    \n <dependency>
    \n <groupId>com.mysql<\/groupId>
    \n <artifactId>mysql-connector-j<\/artifactId>
    \n <scope>runtime<\/scope>
    \n <\/dependency><\/p>\n

    <!– Redis –>
    \n <dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-data-redis<\/artifactId>
    \n <\/dependency><\/p>\n

    <!– JWT –>
    \n <dependency>
    \n <groupId>io.jsonwebtoken<\/groupId>
    \n <artifactId>jjwt-api<\/artifactId>
    \n <version>0.11.5<\/version>
    \n <\/dependency><\/p>\n

    <dependency>
    \n <groupId>io.jsonwebtoken<\/groupId>
    \n <artifactId>jjwt-impl<\/artifactId>
    \n <version>0.11.5<\/version>
    \n <scope>runtime<\/scope>
    \n <\/dependency><\/p>\n

    <dependency>
    \n <groupId>io.jsonwebtoken<\/groupId>
    \n <artifactId>jjwt-jackson<\/artifactId>
    \n <version>0.11.5<\/version>
    \n <scope>runtime<\/scope>
    \n <\/dependency><\/p>\n

    <!– \u76d1\u63a7 –>
    \n <dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-actuator<\/artifactId>
    \n <\/dependency><\/p>\n

    <!– \u6d4b\u8bd5 –>
    \n <dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-test<\/artifactId>
    \n <scope>test<\/scope>
    \n <\/dependency>
    \n<\/dependencies><\/p>\n

    <build>
    \n <plugins>
    \n <plugin>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-maven-plugin<\/artifactId>
    \n <\/plugin>
    \n <\/plugins>
    \n<\/build>
    \n \u7528\u6237\u670d\u52a1\u914d\u7f6e\u6587\u4ef6： <\/p>\n

    yaml<\/p>\n

    bootstrap.yml<\/h2>\n

    spring: application: name: user-service<\/p>\n

    profiles: active: dev<\/p>\n

    cloud: nacos: discovery: server-addr: <\/p>\n

    N<\/p>\n

    A<\/p>\n

    C<\/p>\n

    O<\/p>\n

    S<\/p>\n

    H<\/p>\n

    O<\/p>\n

    S<\/p>\n

    T<\/p>\n

    :<\/p>\n

    l<\/p>\n

    o<\/p>\n

    c<\/p>\n

    a<\/p>\n

    l<\/p>\n

    h<\/p>\n

    o<\/p>\n

    s<\/p>\n

    t<\/p>\n

    :<\/p>\n

    {NACOS_HOST:localhost}:<\/p>\n

    <\/span><\/span>N<\/span>A<\/span>CO<\/span>S<\/span><\/span>H<\/span><\/span><\/span><\/span>\u200b<\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span>OST<\/span><\/span>:<\/span><\/span>l<\/span>oc<\/span>a<\/span>l<\/span>h<\/span>os<\/span>t<\/span><\/span><\/span>:<\/span><\/span><\/span><\/span><\/span>{NACOS_PORT:8848} namespace: ${NACOS_NAMESPACE:public} group: ${NACOS_GROUP:DEFAULT_GROUP} metadata: version: 1.0.0<\/p>\n

    config:
    \n server-addr: ${spring.cloud.nacos.discovery.server-addr}
    \n namespace: ${spring.cloud.nacos.discovery.namespace}
    \n group: ${spring.cloud.nacos.discovery.group}
    \n file-extension: yaml
    \n shared-configs:
    \n – data-id: common.yaml
    \n group: ${spring.cloud.nacos.discovery.group}
    \n refresh: true
    \n – data-id: datasource.yaml
    \n group: ${spring.cloud.nacos.discovery.group}
    \n refresh: true
    \n – data-id: redis.yaml
    \n group: ${spring.cloud.nacos.discovery.group}
    \n refresh: true<\/p>\n

    application-dev.yml<\/h2>\n

    server: port: 8082 servlet: context-path: \/user<\/p>\n

    spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql:\/\/localhost:3306\/user_db?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia\/Shanghai username: root password: 123456 druid: initial-size: 5 min-idle: 5 max-active: 20 max-wait: 60000 time-between-eviction-runs-millis: 60000 min-evictable-idle-time-millis: 300000 validation-query: SELECT 1 test-while-idle: true test-on-borrow: false test-on-return: false pool-prepared-statements: true max-pool-prepared-statement-per-connection-size: 20<\/p>\n

    redis: host: localhost port: 6379 password: database: 0 lettuce: pool: max-active: 20 max-wait: -1ms max-idle: 10 min-idle: 0 shutdown-timeout: 100ms<\/p>\n

    mybatis-plus: mapper-locations: classpath:\/mapper\/*.xml type-aliases-package: com.ecommerce.user.entity configuration: map-underscore-to-camel-case: true log-impl: org.apache.ibatis.logging.stdout.StdOutImpl global-config: db-config: id-type: auto logic-delete-field: deleted logic-delete-value: 1 logic-not-delete-value: 0<\/p>\n

    JWT\u914d\u7f6e<\/h2>\n

    jwt: secret: ecommerce-user-secret-key-2023-spring-cloud-microservices expiration: 86400000 # 24\u5c0f\u65f6 header: Authorization token-prefix: Bearer<\/p>\n

    \u7528\u6237\u670d\u52a1\u914d\u7f6e<\/h2>\n

    user: password: salt: ecommerce2023 max-retry-count: 5 lock-duration: 30 # \u5206\u949f<\/p>\n

    \u65e5\u5fd7\u914d\u7f6e<\/h2>\n

    logging: level: com.ecommerce.user: DEBUG org.springframework.cloud: INFO pattern: console: \u201c%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} – %msg%n\u201d file: name: logs\/user-service.log max-size: 10MB max-history: 30<\/p>\n

    \u7ba1\u7406\u7aef\u70b9<\/h2>\n

    management: endpoints: web: exposure: include: \u201chealth,info,metrics,prometheus\u201d endpoint: health: show-details: always probes: enabled: true \u7528\u6237\u670d\u52a1\u6838\u5fc3\u4ee3\u7801：<\/p>\n

  • \u5b9e\u4f53\u7c7b：<\/li>\n

    java \/\/ \u7528\u6237\u5b9e\u4f53 package com.ecommerce.user.entity;<\/p>\n

    import com.baomidou.mybatisplus.annotation.*; import lombok.Data;<\/p>\n

    import java.time.LocalDateTime;<\/p>\n

    @Data @TableName(\u201ctb_user\u201d) public class User {<\/p>\n

    @TableId(type = IdType.AUTO)
    \nprivate Long id;<\/p>\n

    private String username;
    \nprivate String password;
    \nprivate String nickname;
    \nprivate String phone;
    \nprivate String email;
    \nprivate String avatar;
    \nprivate Integer gender;
    \nprivate LocalDateTime birthday;
    \nprivate Integer status;
    \nprivate Integer userType;
    \nprivate LocalDateTime lastLoginTime;<\/p>\n

    @TableField(fill = FieldFill.INSERT)
    \nprivate LocalDateTime createTime;<\/p>\n

    @TableField(fill = FieldFill.INSERT_UPDATE)
    \nprivate LocalDateTime updateTime;<\/p>\n

    @TableLogic
    \nprivate Integer deleted;<\/p>\n

    }<\/p>\n

    \/\/ \u7528\u6237\u5730\u5740\u5b9e\u4f53 package com.ecommerce.user.entity;<\/p>\n

    import com.baomidou.mybatisplus.annotation.*; import lombok.Data;<\/p>\n

    import java.time.LocalDateTime;<\/p>\n

    @Data @TableName(\u201ctb_user_address\u201d) public class UserAddress {<\/p>\n

    @TableId(type = IdType.AUTO)
    \nprivate Long id;<\/p>\n

    private Long userId;
    \nprivate String receiverName;
    \nprivate String receiverPhone;
    \nprivate String province;
    \nprivate String city;
    \nprivate String district;
    \nprivate String detail;
    \nprivate String postalCode;
    \nprivate Integer isDefault;
    \nprivate Integer status;<\/p>\n

    @TableField(fill = FieldFill.INSERT)
    \nprivate LocalDateTime createTime;<\/p>\n

    @TableField(fill = FieldFill.INSERT_UPDATE)
    \nprivate LocalDateTime updateTime;<\/p>\n

    } 2. Mapper\u63a5\u53e3：<\/p>\n

    java \/\/ \u7528\u6237Mapper package com.ecommerce.user.mapper;<\/p>\n

    import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.ecommerce.user.entity.User; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Select;<\/p>\n

    @Mapper public interface UserMapper extends BaseMapper {<\/p>\n

    @Select("SELECT * FROM tb_user WHERE username = #{username} AND deleted = 0")
    \nUser selectByUsername(String username);<\/p>\n

    @Select("SELECT * FROM tb_user WHERE phone = #{phone} AND deleted = 0")
    \nUser selectByPhone(String phone);<\/p>\n

    @Select("SELECT * FROM tb_user WHERE email = #{email} AND deleted = 0")
    \nUser selectByEmail(String email);<\/p>\n

    }<\/p>\n

    \/\/ \u7528\u6237\u5730\u5740Mapper package com.ecommerce.user.mapper;<\/p>\n

    import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.ecommerce.user.entity.UserAddress; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Select;<\/p>\n

    import java.util.List;<\/p>\n

    @Mapper public interface UserAddressMapper extends BaseMapper {<\/p>\n

    @Select("SELECT * FROM tb_user_address WHERE user_id = #{userId} AND status = 1 ORDER BY is_default DESC, create_time DESC")
    \nList<UserAddress> selectByUserId(Long userId);<\/p>\n

    @Select("SELECT * FROM tb_user_address WHERE user_id = #{userId} AND is_default = 1 AND status = 1")
    \nUserAddress selectDefaultByUserId(Long userId);<\/p>\n

    } 3. Service\u5c42：<\/p>\n

    java \/\/ \u7528\u6237\u670d\u52a1\u63a5\u53e3 package com.ecommerce.user.service;<\/p>\n

    import com.ecommerce.common.dto.PageRequest; import com.ecommerce.common.dto.PageResult; import com.ecommerce.user.dto.*;<\/p>\n

    public interface UserService {<\/p>\n

    \/\/ \u7528\u6237\u6ce8\u518c
    \nUserDTO register(UserRegisterDTO registerDTO);<\/p>\n

    \/\/ \u7528\u6237\u767b\u5f55
    \nUserLoginResult login(UserLoginDTO loginDTO);<\/p>\n

    \/\/ \u83b7\u53d6\u7528\u6237\u4fe1\u606f
    \nUserDTO getUserInfo(Long userId);<\/p>\n

    \/\/ \u66f4\u65b0\u7528\u6237\u4fe1\u606f
    \nUserDTO updateUserInfo(Long userId, UserUpdateDTO updateDTO);<\/p>\n

    \/\/ \u4fee\u6539\u5bc6\u7801
    \nvoid changePassword(Long userId, ChangePasswordDTO changePasswordDTO);<\/p>\n

    \/\/ \u5206\u9875\u67e5\u8be2\u7528\u6237
    \nPageResult<UserDTO> listUsers(PageRequest pageRequest, UserQueryDTO queryDTO);<\/p>\n

    \/\/ \u68c0\u67e5\u7528\u6237\u540d\u662f\u5426\u5b58\u5728
    \nboolean checkUsername(String username);<\/p>\n

    \/\/ \u68c0\u67e5\u624b\u673a\u53f7\u662f\u5426\u5b58\u5728
    \nboolean checkPhone(String phone);<\/p>\n

    \/\/ \u68c0\u67e5\u90ae\u7bb1\u662f\u5426\u5b58\u5728
    \nboolean checkEmail(String email);<\/p>\n

    }<\/p>\n

    \/\/ \u7528\u6237\u670d\u52a1\u5b9e\u73b0 package com.ecommerce.user.service.impl;<\/p>\n

    import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ecommerce.common.core.exception.BusinessException; import com.ecommerce.common.core.exception.ErrorCode; import com.ecommerce.common.dto.PageRequest; import com.ecommerce.common.dto.PageResult; import com.ecommerce.user.dto.*; import com.ecommerce.user.entity.User; import com.ecommerce.user.mapper.UserMapper; import com.ecommerce.user.service.UserService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.security.crypto.password.PasswordEncoder; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional;<\/p>\n

    import java.time.LocalDateTime; import java.util.List; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors;<\/p>\n

    @Slf4j @Service @RequiredArgsConstructor @Transactional(rollbackFor = Exception.class) public class UserServiceImpl implements UserService {<\/p>\n

    private final UserMapper userMapper;
    \nprivate final PasswordEncoder passwordEncoder;
    \nprivate final RedisTemplate<String, Object> redisTemplate;
    \nprivate final UserMapper userMapper;<\/p>\n

    @Override
    \npublic UserDTO register(UserRegisterDTO registerDTO) {
    \n log.info("\u7528\u6237\u6ce8\u518c: username={}, phone={}",
    \n registerDTO.getUsername(), registerDTO.getPhone());<\/p>\n

    \/\/ 1. \u9a8c\u8bc1\u53c2\u6570
    \n validateRegisterDTO(registerDTO);<\/p>\n

    \/\/ 2. \u68c0\u67e5\u7528\u6237\u540d\u3001\u624b\u673a\u53f7\u3001\u90ae\u7bb1\u662f\u5426\u5df2\u5b58\u5728
    \n if (checkUsername(registerDTO.getUsername())) {
    \n throw new BusinessException(ErrorCode.USER_EXISTS);
    \n }<\/p>\n

    if (StrUtil.isNotBlank(registerDTO.getPhone()) &&
    \n checkPhone(registerDTO.getPhone())) {
    \n throw new BusinessException("\u624b\u673a\u53f7\u5df2\u5b58\u5728");
    \n }<\/p>\n

    if (StrUtil.isNotBlank(registerDTO.getEmail()) &&
    \n checkEmail(registerDTO.getEmail())) {
    \n throw new BusinessException("\u90ae\u7bb1\u5df2\u5b58\u5728");
    \n }<\/p>\n

    \/\/ 3. \u521b\u5efa\u7528\u6237
    \n User user = new User();
    \n BeanUtil.copyProperties(registerDTO, user);<\/p>\n

    \/\/ \u5bc6\u7801\u52a0\u5bc6
    \n user.setPassword(passwordEncoder.encode(registerDTO.getPassword()));<\/p>\n

    \/\/ \u8bbe\u7f6e\u9ed8\u8ba4\u503c
    \n user.setStatus(1); \/\/ \u6b63\u5e38\u72b6\u6001
    \n user.setUserType(1); \/\/ \u666e\u901a\u7528\u6237
    \n user.setCreateTime(LocalDateTime.now());
    \n user.setUpdateTime(LocalDateTime.now());<\/p>\n

    \/\/ 4. \u4fdd\u5b58\u7528\u6237
    \n userMapper.insert(user);
    \n log.info("\u7528\u6237\u6ce8\u518c\u6210\u529f: userId={}, username={}", user.getId(), user.getUsername());<\/p>\n

    \/\/ 5. \u6e05\u9664\u76f8\u5173\u7f13\u5b58
    \n clearUserCache(user.getId(), user.getUsername());<\/p>\n

    return convertToDTO(user);
    \n}<\/p>\n

    @Override
    \npublic UserLoginResult login(UserLoginDTO loginDTO) {
    \n log.info("\u7528\u6237\u767b\u5f55: identifier={}", loginDTO.getIdentifier());<\/p>\n

    \/\/ 1. \u83b7\u53d6\u7528\u6237
    \n User user = getUserByIdentifier(loginDTO.getIdentifier());
    \n if (user == null) {
    \n throw new BusinessException(ErrorCode.USER_NOT_EXIST);
    \n }<\/p>\n

    \/\/ 2. \u68c0\u67e5\u7528\u6237\u72b6\u6001
    \n if (user.getStatus() != 1) {
    \n throw new BusinessException(ErrorCode.USER_DISABLED);
    \n }<\/p>\n

    \/\/ 3. \u9a8c\u8bc1\u5bc6\u7801
    \n if (!passwordEncoder.matches(loginDTO.getPassword(), user.getPassword())) {
    \n \/\/ \u8bb0\u5f55\u767b\u5f55\u5931\u8d25\u6b21\u6570
    \n recordLoginFailure(user.getId());
    \n throw new BusinessException(ErrorCode.USER_PASSWORD_ERROR);
    \n }<\/p>\n

    \/\/ 4. \u6e05\u9664\u767b\u5f55\u5931\u8d25\u8bb0\u5f55
    \n clearLoginFailure(user.getId());<\/p>\n

    \/\/ 5. \u66f4\u65b0\u6700\u540e\u767b\u5f55\u65f6\u95f4
    \n user.setLastLoginTime(LocalDateTime.now());
    \n userMapper.updateById(user);<\/p>\n

    \/\/ 6. \u751f\u6210token
    \n String token = generateToken(user);<\/p>\n

    \/\/ 7. \u8fd4\u56de\u7ed3\u679c
    \n UserLoginResult result = new UserLoginResult();
    \n result.setUser(convertToDTO(user));
    \n result.setToken(token);
    \n result.setExpireTime(System.currentTimeMillis() + 86400000); \/\/ 24\u5c0f\u65f6<\/p>\n

    log.info("\u7528\u6237\u767b\u5f55\u6210\u529f: userId={}, username={}", user.getId(), user.getUsername());
    \n return result;
    \n}<\/p>\n

    @Override
    \n@Transactional(readOnly = true)
    \npublic UserDTO getUserInfo(Long userId) {
    \n log.debug("\u83b7\u53d6\u7528\u6237\u4fe1\u606f: userId={}", userId);<\/p>\n

    \/\/ \u5148\u4ece\u7f13\u5b58\u83b7\u53d6
    \n String cacheKey = "user:info:" + userId;
    \n UserDTO cachedUser = (UserDTO) redisTemplate.opsForValue().get(cacheKey);
    \n if (cachedUser != null) {
    \n return cachedUser;
    \n }<\/p>\n

    \/\/ \u4ece\u6570\u636e\u5e93\u83b7\u53d6
    \n User user = userMapper.selectById(userId);
    \n if (user == null || user.getDeleted() == 1) {
    \n throw new BusinessException(ErrorCode.USER_NOT_EXIST);
    \n }<\/p>\n

    UserDTO userDTO = convertToDTO(user);<\/p>\n

    \/\/ \u5b58\u5165\u7f13\u5b58
    \n redisTemplate.opsForValue().set(cacheKey, userDTO, 30, TimeUnit.MINUTES);<\/p>\n

    return userDTO;
    \n}<\/p>\n

    @Override
    \npublic PageResult<UserDTO> listUsers(PageRequest pageRequest, UserQueryDTO queryDTO) {
    \n log.debug("\u5206\u9875\u67e5\u8be2\u7528\u6237: pageNum={}, pageSize={}",
    \n pageRequest.getPageNum(), pageRequest.getPageSize());<\/p>\n

    \/\/ \u6784\u5efa\u67e5\u8be2\u6761\u4ef6
    \n LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();
    \n wrapper.eq(User::getDeleted, 0);<\/p>\n

    if (StrUtil.isNotBlank(queryDTO.getUsername())) {
    \n wrapper.like(User::getUsername, queryDTO.getUsername());
    \n }<\/p>\n

    if (StrUtil.isNotBlank(queryDTO.getPhone())) {
    \n wrapper.like(User::getPhone, queryDTO.getPhone());
    \n }<\/p>\n

    if (queryDTO.getStatus() != null) {
    \n wrapper.eq(User::getStatus, queryDTO.getStatus());
    \n }<\/p>\n

    if (queryDTO.getUserType() != null) {
    \n wrapper.eq(User::getUserType, queryDTO.getUserType());
    \n }<\/p>\n

    \/\/ \u6392\u5e8f
    \n if (StrUtil.isNotBlank(pageRequest.getOrderBy())) {
    \n if (pageRequest.getAsc()) {
    \n wrapper.orderByAsc(User::getCreateTime);
    \n } else {
    \n wrapper.orderByDesc(User::getCreateTime);
    \n }
    \n } else {
    \n wrapper.orderByDesc(User::getCreateTime);
    \n }<\/p>\n

    \/\/ \u5206\u9875\u67e5\u8be2
    \n Page<User> page = new Page<>(pageRequest.getPageNum(), pageRequest.getPageSize());
    \n Page<User> userPage = userMapper.selectPage(page, wrapper);<\/p>\n

    \/\/ \u8f6c\u6362\u4e3aDTO
    \n List<UserDTO> userDTOs = userPage.getRecords().stream()
    \n .map(this::convertToDTO)
    \n .collect(Collectors.toList());<\/p>\n

    return PageResult.of(
    \n (int) userPage.getCurrent(),
    \n (int) userPage.getSize(),
    \n userPage.getTotal(),
    \n userDTOs
    \n );
    \n}<\/p>\n

    private User getUserByIdentifier(String identifier) {
    \n \/\/ \u6839\u636e\u7528\u6237\u540d\u3001\u624b\u673a\u53f7\u3001\u90ae\u7bb1\u83b7\u53d6\u7528\u6237
    \n User user = userMapper.selectByUsername(identifier);
    \n if (user == null) {
    \n user = userMapper.selectByPhone(identifier);
    \n }
    \n if (user == null) {
    \n user = userMapper.selectByEmail(identifier);
    \n }
    \n return user;
    \n}<\/p>\n

    private void validateRegisterDTO(UserRegisterDTO registerDTO) {
    \n if (StrUtil.isBlank(registerDTO.getUsername())) {
    \n throw new BusinessException("\u7528\u6237\u540d\u4e0d\u80fd\u4e3a\u7a7a");
    \n }<\/p>\n

    if (StrUtil.isBlank(registerDTO.getPassword())) {
    \n throw new BusinessException("\u5bc6\u7801\u4e0d\u80fd\u4e3a\u7a7a");
    \n }<\/p>\n

    if (StrUtil.isBlank(registerDTO.getPhone())) {
    \n throw new BusinessException("\u624b\u673a\u53f7\u4e0d\u80fd\u4e3a\u7a7a");
    \n }<\/p>\n

    \/\/ \u9a8c\u8bc1\u624b\u673a\u53f7\u683c\u5f0f
    \n if (!registerDTO.getPhone().matches("^1[3-9]\\\\\\\\d{9}$")) {
    \n throw new BusinessException("\u624b\u673a\u53f7\u683c\u5f0f\u4e0d\u6b63\u786e");
    \n }<\/p>\n

    \/\/ \u9a8c\u8bc1\u5bc6\u7801\u5f3a\u5ea6
    \n if (registerDTO.getPassword().length() < 6) {
    \n throw new BusinessException("\u5bc6\u7801\u957f\u5ea6\u4e0d\u80fd\u5c11\u4e8e6\u4f4d");
    \n }
    \n}<\/p>\n

    private void recordLoginFailure(Long userId) {
    \n String key = "user:login:fail:" + userId;
    \n Long failCount = redisTemplate.opsForValue().increment(key);
    \n redisTemplate.expire(key, 30, TimeUnit.MINUTES);<\/p>\n

    \/\/ \u5982\u679c\u5931\u8d25\u6b21\u6570\u8d85\u8fc75\u6b21，\u9501\u5b9a\u8d26\u623730\u5206\u949f
    \n if (failCount != null && failCount >= 5) {
    \n String lockKey = "user:lock:" + userId;
    \n redisTemplate.opsForValue().set(lockKey, "locked", 30, TimeUnit.MINUTES);
    \n log.warn("\u7528\u6237\u767b\u5f55\u5931\u8d25\u6b21\u6570\u8fc7\u591a，\u8d26\u6237\u9501\u5b9a: userId={}, failCount={}", userId, failCount);
    \n }
    \n}<\/p>\n

    private void clearLoginFailure(Long userId) {
    \n String key = "user:login:fail:" + userId;
    \n redisTemplate.delete(key);<\/p>\n

    String lockKey = "user:lock:" + userId;
    \n redisTemplate.delete(lockKey);
    \n}<\/p>\n

    private String generateToken(User user) {
    \n \/\/ \u4f7f\u7528JWT\u751f\u6210token
    \n Map<String, Object> claims = new HashMap<>();
    \n claims.put("userId", user.getId());
    \n claims.put("username", user.getUsername());
    \n claims.put("userType", user.getUserType());<\/p>\n

    return JwtUtil.generateToken(claims, user.getUsername());
    \n}<\/p>\n

    private UserDTO convertToDTO(User user) {
    \n UserDTO userDTO = new UserDTO();
    \n BeanUtil.copyProperties(user, userDTO);
    \n return userDTO;
    \n}<\/p>\n

    private void clearUserCache(Long userId, String username) {
    \n \/\/ \u6e05\u9664\u7528\u6237\u4fe1\u606f\u7f13\u5b58
    \n redisTemplate.delete("user:info:" + userId);
    \n redisTemplate.delete("user:info:username:" + username);
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u7528\u6237\u5730\u5740\u670d\u52a1 package com.ecommerce.user.service;<\/p>\n

    import com.ecommerce.user.dto.UserAddressDTO;<\/p>\n

    import java.util.List;<\/p>\n

    public interface UserAddressService {<\/p>\n

    \/\/ \u6dfb\u52a0\u5730\u5740
    \nUserAddressDTO addAddress(Long userId, UserAddressDTO addressDTO);<\/p>\n

    \/\/ \u66f4\u65b0\u5730\u5740
    \nUserAddressDTO updateAddress(Long userId, Long addressId, UserAddressDTO addressDTO);<\/p>\n

    \/\/ \u5220\u9664\u5730\u5740
    \nvoid deleteAddress(Long userId, Long addressId);<\/p>\n

    \/\/ \u83b7\u53d6\u5730\u5740\u5217\u8868
    \nList<UserAddressDTO> listAddresses(Long userId);<\/p>\n

    \/\/ \u83b7\u53d6\u9ed8\u8ba4\u5730\u5740
    \nUserAddressDTO getDefaultAddress(Long userId);<\/p>\n

    \/\/ \u8bbe\u7f6e\u9ed8\u8ba4\u5730\u5740
    \nvoid setDefaultAddress(Long userId, Long addressId);<\/p>\n

    } 4. \u63a7\u5236\u5668\u5c42：<\/p>\n

    java \/\/ \u7528\u6237\u63a7\u5236\u5668 package com.ecommerce.user.controller;<\/p>\n

    import com.ecommerce.common.core.response.ApiResponse; import com.ecommerce.common.dto.PageRequest; import com.ecommerce.common.dto.PageResult; import com.ecommerce.user.dto.; import com.ecommerce.user.service.UserService; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.validation.Valid; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.;<\/p>\n

    @Slf4j @RestController @RequestMapping(\u201c\/api\/user\u201d) @RequiredArgsConstructor @Tag(name = \u201c\u7528\u6237\u7ba1\u7406\u201d, description = \u201c\u7528\u6237\u7ba1\u7406\u76f8\u5173\u63a5\u53e3\u201d) public class UserController {<\/p>\n

    private final UserService userService;<\/p>\n

    @PostMapping("\/register")
    \n@Operation(summary = "\u7528\u6237\u6ce8\u518c", description = "\u65b0\u7528\u6237\u6ce8\u518c\u63a5\u53e3")
    \npublic ApiResponse<UserDTO> register(@Valid @RequestBody UserRegisterDTO registerDTO) {
    \n UserDTO userDTO = userService.register(registerDTO);
    \n return ApiResponse.success("\u6ce8\u518c\u6210\u529f", userDTO);
    \n}<\/p>\n

    @PostMapping("\/login")
    \n@Operation(summary = "\u7528\u6237\u767b\u5f55", description = "\u7528\u6237\u767b\u5f55\u63a5\u53e3")
    \npublic ApiResponse<UserLoginResult> login(@Valid @RequestBody UserLoginDTO loginDTO) {
    \n UserLoginResult result = userService.login(loginDTO);
    \n return ApiResponse.success("\u767b\u5f55\u6210\u529f", result);
    \n}<\/p>\n

    @GetMapping("\/info")
    \n@Operation(summary = "\u83b7\u53d6\u7528\u6237\u4fe1\u606f", description = "\u83b7\u53d6\u5f53\u524d\u767b\u5f55\u7528\u6237\u4fe1\u606f")
    \npublic ApiResponse<UserDTO> getUserInfo(@RequestHeader("X-User-Id") Long userId) {
    \n UserDTO userDTO = userService.getUserInfo(userId);
    \n return ApiResponse.success(userDTO);
    \n}<\/p>\n

    @PutMapping("\/info")
    \n@Operation(summary = "\u66f4\u65b0\u7528\u6237\u4fe1\u606f", description = "\u66f4\u65b0\u7528\u6237\u57fa\u672c\u4fe1\u606f")
    \npublic ApiResponse<UserDTO> updateUserInfo(
    \n @RequestHeader("X-User-Id") Long userId,
    \n @Valid @RequestBody UserUpdateDTO updateDTO) {
    \n UserDTO userDTO = userService.updateUserInfo(userId, updateDTO);
    \n return ApiResponse.success("\u66f4\u65b0\u6210\u529f", userDTO);
    \n}<\/p>\n

    @PutMapping("\/password")
    \n@Operation(summary = "\u4fee\u6539\u5bc6\u7801", description = "\u4fee\u6539\u767b\u5f55\u5bc6\u7801")
    \npublic ApiResponse<Void> changePassword(
    \n @RequestHeader("X-User-Id") Long userId,
    \n @Valid @RequestBody ChangePasswordDTO changePasswordDTO) {
    \n userService.changePassword(userId, changePasswordDTO);
    \n return ApiResponse.success("\u5bc6\u7801\u4fee\u6539\u6210\u529f");
    \n}<\/p>\n

    @GetMapping("\/list")
    \n@Operation(summary = "\u5206\u9875\u67e5\u8be2\u7528\u6237", description = "\u7ba1\u7406\u5458\u5206\u9875\u67e5\u8be2\u7528\u6237\u5217\u8868")
    \npublic ApiResponse<PageResult<UserDTO>> listUsers(
    \n @Valid PageRequest pageRequest,
    \n UserQueryDTO queryDTO) {
    \n PageResult<UserDTO> result = userService.listUsers(pageRequest, queryDTO);
    \n return ApiResponse.success(result);
    \n}<\/p>\n

    @GetMapping("\/check\/username")
    \n@Operation(summary = "\u68c0\u67e5\u7528\u6237\u540d", description = "\u68c0\u67e5\u7528\u6237\u540d\u662f\u5426\u5df2\u5b58\u5728")
    \npublic ApiResponse<Boolean> checkUsername(@RequestParam String username) {
    \n boolean exists = userService.checkUsername(username);
    \n return ApiResponse.success(!exists);
    \n}<\/p>\n

    @GetMapping("\/check\/phone")
    \n@Operation(summary = "\u68c0\u67e5\u624b\u673a\u53f7", description = "\u68c0\u67e5\u624b\u673a\u53f7\u662f\u5426\u5df2\u5b58\u5728")
    \npublic ApiResponse<Boolean> checkPhone(@RequestParam String phone) {
    \n boolean exists = userService.checkPhone(phone);
    \n return ApiResponse.success(!exists);
    \n}<\/p>\n

    } 5. JWT\u5de5\u5177\u7c7b：<\/p>\n

    java package com.ecommerce.user.util;<\/p>\n

    import io.jsonwebtoken.Claims; import io.jsonwebtoken.Jwts; import io.jsonwebtoken.SignatureAlgorithm; import io.jsonwebtoken.security.Keys; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component;<\/p>\n

    import java.security.Key; import java.util.Date; import java.util.Map;<\/p>\n

    @Slf4j @Component public class JwtUtil {<\/p>\n

    @Value("${jwt.secret}")
    \nprivate String secret;<\/p>\n

    @Value("${jwt.expiration}")
    \nprivate Long expiration;<\/p>\n

    private Key getSigningKey() {
    \n return Keys.hmacShaKeyFor(secret.getBytes());
    \n}<\/p>\n

    \/\/ \u751f\u6210token
    \npublic static String generateToken(Map<String, Object> claims, String subject) {
    \n return Jwts.builder()
    \n .setClaims(claims)
    \n .setSubject(subject)
    \n .setIssuedAt(new Date())
    \n .setExpiration(new Date(System.currentTimeMillis() + expiration))
    \n .signWith(getSigningKey(), SignatureAlgorithm.HS256)
    \n .compact();
    \n}<\/p>\n

    \/\/ \u4ecetoken\u4e2d\u83b7\u53d6\u7528\u6237\u540d
    \npublic String getUsernameFromToken(String token) {
    \n return getClaimFromToken(token, Claims::getSubject);
    \n}<\/p>\n

    \/\/ \u4ecetoken\u4e2d\u83b7\u53d6\u8fc7\u671f\u65f6\u95f4
    \npublic Date getExpirationDateFromToken(String token) {
    \n return getClaimFromToken(token, Claims::getExpiration);
    \n}<\/p>\n

    \/\/ \u4ecetoken\u4e2d\u83b7\u53d6\u6307\u5b9aclaim
    \npublic <T> T getClaimFromToken(String token, java.util.function.Function<Claims, T> claimsResolver) {
    \n final Claims claims = getAllClaimsFromToken(token);
    \n return claimsResolver.apply(claims);
    \n}<\/p>\n

    \/\/ \u4ecetoken\u4e2d\u83b7\u53d6\u6240\u6709claims
    \nprivate Claims getAllClaimsFromToken(String token) {
    \n return Jwts.parserBuilder()
    \n .setSigningKey(getSigningKey())
    \n .build()
    \n .parseClaimsJws(token)
    \n .getBody();
    \n}<\/p>\n

    \/\/ \u9a8c\u8bc1token\u662f\u5426\u8fc7\u671f
    \nprivate Boolean isTokenExpired(String token) {
    \n final Date expiration = getExpirationDateFromToken(token);
    \n return expiration.before(new Date());
    \n}<\/p>\n

    \/\/ \u9a8c\u8bc1token
    \npublic Boolean validateToken(String token, String username) {
    \n final String usernameFromToken = getUsernameFromToken(token);
    \n return (username.equals(usernameFromToken) && !isTokenExpired(token));
    \n}<\/p>\n

    }<\/p>\n

    \u7b2c\u56db\u7ae0：\u5546\u54c1\u670d\u52a1\u5b9e\u73b0<\/h3>\n

    4.1 \u5546\u54c1\u670d\u52a1\u6838\u5fc3\u529f\u80fd \u5546\u54c1\u670d\u52a1pom.xml：<\/p>\n

    xml<\/p>\n

    com.ecommerce common-core ${project.version}
    \n<!– Elasticsearch –>
    \n<dependency>
    \n <groupId>org.springframework.boot<\/groupId>
    \n <artifactId>spring-boot-starter-data-elasticsearch<\/artifactId>
    \n<\/dependency><\/p>\n

    <!– \u7f13\u5b58 –>
    \n<dependency>
    \n <groupId>org.redisson<\/groupId>
    \n <artifactId>redisson-spring-boot-starter<\/artifactId>
    \n<\/dependency><\/p>\n

    <!– \u6d88\u606f\u961f\u5217 –>
    \n<dependency>
    \n <groupId>org.apache.rocketmq<\/groupId>
    \n <artifactId>rocketmq-spring-boot-starter<\/artifactId>
    \n<\/dependency><\/p>\n

    <!– Seata\u5206\u5e03\u5f0f\u4e8b\u52a1 –>
    \n<dependency>
    \n <groupId>io.seata<\/groupId>
    \n <artifactId>seata-spring-boot-starter<\/artifactId>
    \n<\/dependency>
    \n \u5546\u54c1\u670d\u52a1\u6838\u5fc3\u4ee3\u7801： <\/p>\n

  • \u5546\u54c1\u5b9e\u4f53\u4e0eMapper：<\/li>\n

    java \/\/ \u5546\u54c1\u5b9e\u4f53 package com.ecommerce.product.entity;<\/p>\n

    import com.baomidou.mybatisplus.annotation.*; import lombok.Data;<\/p>\n

    import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.List;<\/p>\n

    @Data @TableName(\u201ctb_product\u201d) public class Product {<\/p>\n

    @TableId(type = IdType.AUTO)
    \nprivate Long id;<\/p>\n

    private String spuCode;
    \nprivate String name;
    \nprivate String subTitle;
    \nprivate Long categoryId;
    \nprivate Long brandId;
    \nprivate String mainImage;<\/p>\n

    @TableField(typeHandler = JsonTypeHandler.class)
    \nprivate List<String> images;<\/p>\n

    private String detail;<\/p>\n

    @TableField(typeHandler = JsonTypeHandler.class)
    \nprivate List<ProductSpec> specifications;<\/p>\n

    private BigDecimal price;
    \nprivate BigDecimal marketPrice;
    \nprivate BigDecimal costPrice;
    \nprivate Integer stock;
    \nprivate Integer sales;
    \nprivate Integer status;
    \nprivate BigDecimal weight;
    \nprivate BigDecimal volume;<\/p>\n

    @TableField(fill = FieldFill.INSERT)
    \nprivate LocalDateTime createTime;<\/p>\n

    @TableField(fill = FieldFill.INSERT_UPDATE)
    \nprivate LocalDateTime updateTime;<\/p>\n

    @TableLogic
    \nprivate Integer deleted;<\/p>\n

    }<\/p>\n

    \/\/ \u5546\u54c1\u89c4\u683c @Data public class ProductSpec { private String name; private String value; private String unit; }<\/p>\n

    \/\/ JSON\u7c7b\u578b\u5904\u7406\u5668 public class JsonTypeHandler extends BaseTypeHandler {<\/p>\n

    private final Class<T> type;
    \nprivate final ObjectMapper objectMapper;<\/p>\n

    public JsonTypeHandler(Class<T> type) {
    \n this.type = type;
    \n this.objectMapper = new ObjectMapper();
    \n this.objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
    \n}<\/p>\n

    @Override
    \npublic void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
    \n try {
    \n String json = objectMapper.writeValueAsString(parameter);
    \n ps.setString(i, json);
    \n } catch (JsonProcessingException e) {
    \n throw new RuntimeException("JSON\u5e8f\u5217\u5316\u5931\u8d25", e);
    \n }
    \n}<\/p>\n

    @Override
    \npublic T getNullableResult(ResultSet rs, String columnName) throws SQLException {
    \n String json = rs.getString(columnName);
    \n return parseJson(json);
    \n}<\/p>\n

    @Override
    \npublic T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
    \n String json = rs.getString(columnIndex);
    \n return parseJson(json);
    \n}<\/p>\n

    @Override
    \npublic T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
    \n String json = cs.getString(columnIndex);
    \n return parseJson(json);
    \n}<\/p>\n

    private T parseJson(String json) {
    \n if (StringUtils.isBlank(json)) {
    \n return null;
    \n }
    \n try {
    \n return objectMapper.readValue(json, type);
    \n } catch (IOException e) {
    \n throw new RuntimeException("JSON\u53cd\u5e8f\u5217\u5316\u5931\u8d25", e);
    \n }
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u5546\u54c1Mapper package com.ecommerce.product.mapper;<\/p>\n

    import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.ecommerce.product.entity.Product; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update;<\/p>\n

    @Mapper public interface ProductMapper extends BaseMapper {<\/p>\n

    @Select("SELECT * FROM tb_product WHERE id = #{id} AND status = 1 AND deleted = 0")
    \nProduct selectAvailableById(Long id);<\/p>\n

    @Update("UPDATE tb_product SET stock = stock – #{quantity}, sales = sales + #{quantity} WHERE id = #{productId} AND stock >= #{quantity}")
    \nint deductStock(@Param("productId") Long productId, @Param("quantity") Integer quantity);<\/p>\n

    @Update("UPDATE tb_product SET stock = stock + #{quantity} WHERE id = #{productId}")
    \nint addStock(@Param("productId") Long productId, @Param("quantity") Integer quantity);<\/p>\n

    } 2. \u5546\u54c1\u641c\u7d22（Elasticsearch\u96c6\u6210）：<\/p>\n

    java \/\/ Elasticsearch\u5546\u54c1\u6587\u6863 package com.ecommerce.product.document;<\/p>\n

    import lombok.Data; import org.springframework.data.annotation.Id; import org.springframework.data.elasticsearch.annotations.Document; import org.springframework.data.elasticsearch.annotations.Field; import org.springframework.data.elasticsearch.annotations.FieldType;<\/p>\n

    import java.math.BigDecimal; import java.util.List; import java.util.Map;<\/p>\n

    @Data @Document(indexName = \u201cproducts\u201d) public class ProductDocument {<\/p>\n

    @Id
    \nprivate Long id;<\/p>\n

    @Field(type = FieldType.Text, analyzer = "ik_max_word")
    \nprivate String name;<\/p>\n

    @Field(type = FieldType.Text, analyzer = "ik_smart")
    \nprivate String subTitle;<\/p>\n

    @Field(type = FieldType.Long)
    \nprivate Long categoryId;<\/p>\n

    @Field(type = FieldType.Long)
    \nprivate Long brandId;<\/p>\n

    @Field(type = FieldType.Keyword)
    \nprivate String spuCode;<\/p>\n

    @Field(type = FieldType.Text)
    \nprivate String mainImage;<\/p>\n

    @Field(type = FieldType.Double)
    \nprivate BigDecimal price;<\/p>\n

    @Field(type = FieldType.Integer)
    \nprivate Integer stock;<\/p>\n

    @Field(type = FieldType.Integer)
    \nprivate Integer sales;<\/p>\n

    @Field(type = FieldType.Integer)
    \nprivate Integer status;<\/p>\n

    @Field(type = FieldType.Nested)
    \nprivate List<ProductSpecDocument> specifications;<\/p>\n

    @Field(type = FieldType.Object)
    \nprivate Map<String, Object> attributes;<\/p>\n

    @Field(type = FieldType.Date)
    \nprivate Long createTime;<\/p>\n

    }<\/p>\n

    \/\/ \u5546\u54c1\u89c4\u683c\u6587\u6863 @Data public class ProductSpecDocument {<\/p>\n

    @Field(type = FieldType.Keyword)
    \nprivate String name;<\/p>\n

    @Field(type = FieldType.Text, analyzer = "ik_smart")
    \nprivate String value;<\/p>\n

    @Field(type = FieldType.Keyword)
    \nprivate String unit;<\/p>\n

    }<\/p>\n

    \/\/ \u5546\u54c1\u641c\u7d22Repository package com.ecommerce.product.repository;<\/p>\n

    import com.ecommerce.product.document.ProductDocument; import org.springframework.data.domain.Page; import org.springframework.data.domain.Pageable; import org.springframework.data.elasticsearch.annotations.Query; import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;<\/p>\n

    public interface ProductSearchRepository extends ElasticsearchRepository<ProductDocument, Long> {<\/p>\n

    \/\/ \u6839\u636e\u540d\u79f0\u641c\u7d22
    \nPage<ProductDocument> findByName(String name, Pageable pageable);<\/p>\n

    \/\/ \u6839\u636e\u5206\u7c7bID\u641c\u7d22
    \nPage<ProductDocument> findByCategoryId(Long categoryId, Pageable pageable);<\/p>\n

    \/\/ \u4ef7\u683c\u8303\u56f4\u641c\u7d22
    \nPage<ProductDocument> findByPriceBetween(BigDecimal minPrice, BigDecimal maxPrice, Pageable pageable);<\/p>\n

    \/\/ \u590d\u5408\u6761\u4ef6\u641c\u7d22
    \n@Query("{\\\\"bool\\\\": {\\\\"must\\\\": [" +
    \n "{\\\\"match\\\\": {\\\\"name\\\\": \\\\"?0\\\\"}}," +
    \n "{\\\\"range\\\\": {\\\\"price\\\\": {\\\\"gte\\\\": ?1, \\\\"lte\\\\": ?2}}}" +
    \n "]}}")
    \nPage<ProductDocument> searchByNameAndPriceRange(String name, BigDecimal minPrice, BigDecimal maxPrice, Pageable pageable);<\/p>\n

    }<\/p>\n

    \/\/ \u5546\u54c1\u641c\u7d22\u670d\u52a1 package com.ecommerce.product.service;<\/p>\n

    import com.ecommerce.common.dto.PageRequest; import com.ecommerce.common.dto.PageResult; import com.ecommerce.product.dto.ProductSearchDTO; import com.ecommerce.product.document.ProductDocument;<\/p>\n

    public interface ProductSearchService {<\/p>\n

    \/\/ \u521b\u5efa\u7d22\u5f15
    \nboolean createIndex();<\/p>\n

    \/\/ \u6dfb\u52a0\u5546\u54c1\u5230\u7d22\u5f15
    \nvoid addProductToIndex(ProductDocument product);<\/p>\n

    \/\/ \u4ece\u7d22\u5f15\u4e2d\u5220\u9664\u5546\u54c1
    \nvoid removeProductFromIndex(Long productId);<\/p>\n

    \/\/ \u641c\u7d22\u5546\u54c1
    \nPageResult<ProductDocument> searchProducts(ProductSearchDTO searchDTO, PageRequest pageRequest);<\/p>\n

    \/\/ \u6839\u636eID\u6279\u91cf\u67e5\u8be2
    \nList<ProductDocument> findByIds(List<Long> ids);<\/p>\n

    \/\/ \u66f4\u65b0\u5546\u54c1\u7d22\u5f15
    \nvoid updateProductIndex(ProductDocument product);<\/p>\n

    } 3. \u5546\u54c1\u7f13\u5b58\u7b56\u7565（Redisson\u5206\u5e03\u5f0f\u9501）：<\/p>\n

    java \/\/ \u5546\u54c1\u7f13\u5b58\u670d\u52a1 package com.ecommerce.product.service;<\/p>\n

    import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service;<\/p>\n

    import java.util.concurrent.TimeUnit;<\/p>\n

    @Slf4j @Service @RequiredArgsConstructor public class ProductCacheService {<\/p>\n

    private final RedisTemplate<String, Object> redisTemplate;
    \nprivate final RedissonClient redissonClient;<\/p>\n

    \/\/ \u5546\u54c1\u7f13\u5b58key
    \nprivate static final String PRODUCT_KEY_PREFIX = "product:";
    \nprivate static final String PRODUCT_STOCK_KEY_PREFIX = "product:stock:";
    \nprivate static final String PRODUCT_LOCK_KEY_PREFIX = "product:lock:";<\/p>\n

    \/\/ \u83b7\u53d6\u5546\u54c1\u4fe1\u606f（\u5e26\u7f13\u5b58）
    \npublic ProductDTO getProductWithCache(Long productId) {
    \n String cacheKey = PRODUCT_KEY_PREFIX + productId;<\/p>\n

    \/\/ 1. \u4ece\u7f13\u5b58\u83b7\u53d6
    \n ProductDTO product = (ProductDTO) redisTemplate.opsForValue().get(cacheKey);
    \n if (product != null) {
    \n return product;
    \n }<\/p>\n

    \/\/ 2. \u83b7\u53d6\u5206\u5e03\u5f0f\u9501
    \n String lockKey = PRODUCT_LOCK_KEY_PREFIX + productId;
    \n RLock lock = redissonClient.getLock(lockKey);<\/p>\n

    try {
    \n \/\/ \u5c1d\u8bd5\u52a0\u9501，\u6700\u591a\u7b49\u5f855\u79d2，\u9501\u8d85\u65f6\u65f6\u95f410\u79d2
    \n boolean locked = lock.tryLock(5, 10, TimeUnit.SECONDS);
    \n if (!locked) {
    \n throw new RuntimeException("\u83b7\u53d6\u5546\u54c1\u4fe1\u606f\u8d85\u65f6");
    \n }<\/p>\n

    \/\/ 3. \u53cc\u91cd\u68c0\u67e5\u7f13\u5b58
    \n product = (ProductDTO) redisTemplate.opsForValue().get(cacheKey);
    \n if (product != null) {
    \n return product;
    \n }<\/p>\n

    \/\/ 4. \u4ece\u6570\u636e\u5e93\u83b7\u53d6
    \n product = productService.getProductById(productId);
    \n if (product == null) {
    \n \/\/ \u7f13\u5b58\u7a7a\u503c，\u9632\u6b62\u7f13\u5b58\u7a7f\u900f
    \n redisTemplate.opsForValue().set(cacheKey, "", 5, TimeUnit.MINUTES);
    \n return null;
    \n }<\/p>\n

    \/\/ 5. \u653e\u5165\u7f13\u5b58
    \n redisTemplate.opsForValue().set(cacheKey, product, 30, TimeUnit.MINUTES);<\/p>\n

    \/\/ 6. \u7f13\u5b58\u5e93\u5b58\u5230Redis（\u7528\u4e8e\u79d2\u6740\u7b49\u573a\u666f）
    \n cacheStock(productId, product.getStock());<\/p>\n

    return product;<\/p>\n

    } catch (InterruptedException e) {
    \n Thread.currentThread().interrupt();
    \n throw new RuntimeException("\u83b7\u53d6\u5546\u54c1\u4fe1\u606f\u4e2d\u65ad", e);
    \n } finally {
    \n \/\/ \u91ca\u653e\u9501
    \n if (lock.isHeldByCurrentThread()) {
    \n lock.unlock();
    \n }
    \n }
    \n}<\/p>\n

    \/\/ \u7f13\u5b58\u5e93\u5b58
    \nprivate void cacheStock(Long productId, Integer stock) {
    \n String stockKey = PRODUCT_STOCK_KEY_PREFIX + productId;
    \n redisTemplate.opsForValue().set(stockKey, stock, 1, TimeUnit.HOURS);
    \n}<\/p>\n

    \/\/ \u6263\u51cf\u5e93\u5b58（Redis\u9884\u51cf\u5e93\u5b58）
    \npublic boolean deductStock(Long productId, Integer quantity) {
    \n String stockKey = PRODUCT_STOCK_KEY_PREFIX + productId;
    \n String lockKey = PRODUCT_LOCK_KEY_PREFIX + productId + ":stock";<\/p>\n

    RLock lock = redissonClient.getLock(lockKey);<\/p>\n

    try {
    \n \/\/ \u52a0\u9501
    \n boolean locked = lock.tryLock(3, 5, TimeUnit.SECONDS);
    \n if (!locked) {
    \n return false;
    \n }<\/p>\n

    \/\/ \u83b7\u53d6\u5f53\u524d\u5e93\u5b58
    \n Object stockObj = redisTemplate.opsForValue().get(stockKey);
    \n if (stockObj == null) {
    \n \/\/ \u5e93\u5b58\u672a\u7f13\u5b58，\u4ece\u6570\u636e\u5e93\u83b7\u53d6
    \n Integer dbStock = productService.getProductStock(productId);
    \n redisTemplate.opsForValue().set(stockKey, dbStock, 1, TimeUnit.HOURS);
    \n stockObj = dbStock;
    \n }<\/p>\n

    Integer currentStock = (Integer) stockObj;
    \n if (currentStock < quantity) {
    \n return false; \/\/ \u5e93\u5b58\u4e0d\u8db3
    \n }<\/p>\n

    \/\/ \u9884\u51cf\u5e93\u5b58
    \n Long newStock = redisTemplate.opsForValue().decrement(stockKey, quantity);<\/p>\n

    \/\/ \u5f02\u6b65\u66f4\u65b0\u6570\u636e\u5e93
    \n asyncUpdateDbStock(productId, quantity);<\/p>\n

    return newStock != null && newStock >= 0;<\/p>\n

    } catch (InterruptedException e) {
    \n Thread.currentThread().interrupt();
    \n return false;
    \n } finally {
    \n if (lock.isHeldByCurrentThread()) {
    \n lock.unlock();
    \n }
    \n }
    \n}<\/p>\n

    \/\/ \u5f02\u6b65\u66f4\u65b0\u6570\u636e\u5e93\u5e93\u5b58
    \nprivate void asyncUpdateDbStock(Long productId, Integer quantity) {
    \n CompletableFuture.runAsync(() -> {
    \n try {
    \n productMapper.deductStock(productId, quantity);
    \n } catch (Exception e) {
    \n log.error("\u5f02\u6b65\u66f4\u65b0\u5e93\u5b58\u5931\u8d25: productId={}, quantity={}", productId, quantity, e);
    \n \/\/ \u5931\u8d25\u65f6\u56de\u6edaRedis\u5e93\u5b58
    \n rollbackStock(productId, quantity);
    \n }
    \n });
    \n}<\/p>\n

    \/\/ \u56de\u6eda\u5e93\u5b58
    \nprivate void rollbackStock(Long productId, Integer quantity) {
    \n String stockKey = PRODUCT_STOCK_KEY_PREFIX + productId;
    \n redisTemplate.opsForValue().increment(stockKey, quantity);
    \n}<\/p>\n

    }<\/p>\n

    \u7b2c\u4e94\u7ae0：\u8ba2\u5355\u670d\u52a1\u4e0e\u5206\u5e03\u5f0f\u4e8b\u52a1<\/h3>\n

    5.1 \u8ba2\u5355\u670d\u52a1\u6838\u5fc3\u529f\u80fd \u8ba2\u5355\u72b6\u6001\u673a\u8bbe\u8ba1：<\/p>\n

    java \/\/ \u8ba2\u5355\u72b6\u6001\u679a\u4e3e package com.ecommerce.order.enums;<\/p>\n

    import lombok.Getter;<\/p>\n

    @Getter public enum OrderStatus {<\/p>\n

    PENDING_PAYMENT(1, "\u5f85\u4ed8\u6b3e") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return targetStatus == PAID || targetStatus == CANCELLED;
    \n }
    \n},<\/p>\n

    PAID(2, "\u5df2\u4ed8\u6b3e") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return targetStatus == SHIPPED || targetStatus == REFUNDING;
    \n }
    \n},<\/p>\n

    SHIPPED(3, "\u5df2\u53d1\u8d27") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return targetStatus == RECEIVED || targetStatus == REFUNDING;
    \n }
    \n},<\/p>\n

    RECEIVED(4, "\u5df2\u5b8c\u6210") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return targetStatus == REFUNDED;
    \n }
    \n},<\/p>\n

    CANCELLED(5, "\u5df2\u53d6\u6d88") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return false;
    \n }
    \n},<\/p>\n

    REFUNDING(6, "\u9000\u6b3e\u4e2d") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return targetStatus == REFUNDED || targetStatus == PAID;
    \n }
    \n},<\/p>\n

    REFUNDED(7, "\u5df2\u9000\u6b3e") {
    \n @Override
    \n public boolean canChangeTo(OrderStatus targetStatus) {
    \n return false;
    \n }
    \n};<\/p>\n

    private final Integer code;
    \nprivate final String description;<\/p>\n

    OrderStatus(Integer code, String description) {
    \n this.code = code;
    \n this.description = description;
    \n}<\/p>\n

    \/\/ \u68c0\u67e5\u662f\u5426\u53ef\u4ee5\u8f6c\u6362\u5230\u76ee\u6807\u72b6\u6001
    \npublic abstract boolean canChangeTo(OrderStatus targetStatus);<\/p>\n

    \/\/ \u6839\u636ecode\u83b7\u53d6\u679a\u4e3e
    \npublic static OrderStatus getByCode(Integer code) {
    \n for (OrderStatus status : values()) {
    \n if (status.getCode().equals(code)) {
    \n return status;
    \n }
    \n }
    \n throw new IllegalArgumentException("\u65e0\u6548\u7684\u8ba2\u5355\u72b6\u6001\u7801: " + code);
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u8ba2\u5355\u72b6\u6001\u673a package com.ecommerce.order.service.state;<\/p>\n

    import com.ecommerce.order.enums.OrderStatus; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component;<\/p>\n

    @Slf4j @Component public class OrderStateMachine {<\/p>\n

    \/**
    \n * \u68c0\u67e5\u8ba2\u5355\u72b6\u6001\u662f\u5426\u53ef\u4ee5\u8f6c\u6362
    \n *\/
    \npublic boolean canChangeStatus(OrderStatus currentStatus, OrderStatus targetStatus) {
    \n if (currentStatus == null || targetStatus == null) {
    \n return false;
    \n }<\/p>\n

    return currentStatus.canChangeTo(targetStatus);
    \n}<\/p>\n

    \/**
    \n * \u6267\u884c\u72b6\u6001\u8f6c\u6362
    \n *\/
    \npublic void changeStatus(Order order, OrderStatus targetStatus, String operator, String remark) {
    \n OrderStatus currentStatus = OrderStatus.getByCode(order.getStatus());<\/p>\n

    if (!canChangeStatus(currentStatus, targetStatus)) {
    \n throw new BusinessException(
    \n String.format("\u8ba2\u5355\u72b6\u6001\u4e0d\u80fd\u4ece[%s]\u8f6c\u6362\u5230[%s]",
    \n currentStatus.getDescription(),
    \n targetStatus.getDescription()));
    \n }<\/p>\n

    \/\/ \u66f4\u65b0\u8ba2\u5355\u72b6\u6001
    \n order.setStatus(targetStatus.getCode());<\/p>\n

    \/\/ \u8bb0\u5f55\u72b6\u6001\u53d8\u66f4\u65e5\u5fd7
    \n OrderStatusLog statusLog = new OrderStatusLog();
    \n statusLog.setOrderId(order.getId());
    \n statusLog.setFromStatus(currentStatus.getCode());
    \n statusLog.setToStatus(targetStatus.getCode());
    \n statusLog.setOperator(operator);
    \n statusLog.setRemark(remark);
    \n statusLog.setCreateTime(LocalDateTime.now());<\/p>\n

    orderStatusLogMapper.insert(statusLog);<\/p>\n

    log.info("\u8ba2\u5355\u72b6\u6001\u53d8\u66f4: orderId={}, from={}, to={}, operator={}",
    \n order.getId(),
    \n currentStatus.getDescription(),
    \n targetStatus.getDescription(),
    \n operator);<\/p>\n

    \/\/ \u53d1\u5e03\u72b6\u6001\u53d8\u66f4\u4e8b\u4ef6
    \n publishStatusChangeEvent(order, currentStatus, targetStatus);
    \n}<\/p>\n

    \/**
    \n * \u53d1\u5e03\u72b6\u6001\u53d8\u66f4\u4e8b\u4ef6
    \n *\/
    \nprivate void publishStatusChangeEvent(Order order, OrderStatus fromStatus, OrderStatus toStatus) {
    \n OrderStatusChangeEvent event = new OrderStatusChangeEvent();
    \n event.setOrderId(order.getId());
    \n event.setOrderNo(order.getOrderNo());
    \n event.setUserId(order.getUserId());
    \n event.setFromStatus(fromStatus);
    \n event.setToStatus(toStatus);
    \n event.setChangeTime(LocalDateTime.now());<\/p>\n

    applicationEventPublisher.publishEvent(event);
    \n}<\/p>\n

    } 5.2 Seata\u5206\u5e03\u5f0f\u4e8b\u52a1\u96c6\u6210 Seata\u914d\u7f6e：<\/p>\n

    yaml<\/p>\n

    seata\u914d\u7f6e<\/h2>\n

    seata: enabled: true application-id: ${spring.application.name} tx-service-group: default_tx_group enable-auto-data-source-proxy: true config: type: nacos nacos: server-addr: ${spring.cloud.nacos.discovery.server-addr} namespace: ${spring.cloud.nacos.discovery.namespace} group: SEATA_GROUP username: nacos password: nacos registry: type: nacos nacos: server-addr: ${spring.cloud.nacos.discovery.server-addr} namespace: ${spring.cloud.nacos.discovery.namespace} group: SEATA_GROUP username: nacos password: nacos service: vgroup-mapping: default_tx_group: default disable-global-transaction: false \u521b\u5efa\u8ba2\u5355（\u5206\u5e03\u5f0f\u4e8b\u52a1）：<\/p>\n

    java \/\/ \u8ba2\u5355\u670d\u52a1 package com.ecommerce.order.service;<\/p>\n

    import com.ecommerce.order.dto.CreateOrderDTO; import io.seata.spring.annotation.GlobalTransactional; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service;<\/p>\n

    @Slf4j @Service @RequiredArgsConstructor public class OrderService {<\/p>\n

    private final OrderMapper orderMapper;
    \nprivate final OrderItemMapper orderItemMapper;
    \nprivate final InventoryService inventoryService;
    \nprivate final CouponService couponService;
    \nprivate final ProductService productService;<\/p>\n

    \/**
    \n * \u521b\u5efa\u8ba2\u5355（\u5206\u5e03\u5f0f\u4e8b\u52a1）
    \n *\/
    \n@GlobalTransactional(name = "createOrder", rollbackFor = Exception.class)
    \npublic OrderDTO createOrder(CreateOrderDTO createOrderDTO) {
    \n log.info("\u5f00\u59cb\u521b\u5efa\u8ba2\u5355: userId={}, items={}",
    \n createOrderDTO.getUserId(),
    \n createOrderDTO.getItems().size());<\/p>\n

    \/\/ 1. \u9a8c\u8bc1\u5546\u54c1\u4fe1\u606f
    \n validateProducts(createOrderDTO.getItems());<\/p>\n

    \/\/ 2. \u751f\u6210\u8ba2\u5355\u53f7
    \n String orderNo = generateOrderNo();<\/p>\n

    \/\/ 3. \u8ba1\u7b97\u8ba2\u5355\u91d1\u989d
    \n OrderAmount orderAmount = calculateOrderAmount(createOrderDTO);<\/p>\n

    \/\/ 4. \u521b\u5efa\u8ba2\u5355
    \n Order order = createOrderEntity(createOrderDTO, orderNo, orderAmount);
    \n orderMapper.insert(order);<\/p>\n

    \/\/ 5. \u521b\u5efa\u8ba2\u5355\u5546\u54c1
    \n List<OrderItem> orderItems = createOrderItems(order.getId(), createOrderDTO.getItems());
    \n orderItemMapper.insertBatch(orderItems);<\/p>\n

    \/\/ 6. \u6263\u51cf\u5e93\u5b58（\u8c03\u7528\u5e93\u5b58\u670d\u52a1）
    \n inventoryService.deductStock(createOrderDTO.getItems());<\/p>\n

    \/\/ 7. \u4f7f\u7528\u4f18\u60e0\u5238（\u8c03\u7528\u4f18\u60e0\u5238\u670d\u52a1）
    \n if (createOrderDTO.getCouponId() != null) {
    \n couponService.useCoupon(createOrderDTO.getUserId(), createOrderDTO.getCouponId());
    \n }<\/p>\n

    \/\/ 8. \u53d1\u9001\u521b\u5efa\u8ba2\u5355\u6d88\u606f
    \n sendOrderCreatedMessage(order);<\/p>\n

    log.info("\u8ba2\u5355\u521b\u5efa\u6210\u529f: orderId={}, orderNo={}", order.getId(), order.getOrderNo());<\/p>\n

    return convertToDTO(order);
    \n}<\/p>\n

    \/**
    \n * \u9a8c\u8bc1\u5546\u54c1\u4fe1\u606f
    \n *\/
    \nprivate void validateProducts(List<CreateOrderItemDTO> items) {
    \n for (CreateOrderItemDTO item : items) {
    \n ProductDTO product = productService.getProductById(item.getProductId());
    \n if (product == null) {
    \n throw new BusinessException("\u5546\u54c1\u4e0d\u5b58\u5728: " + item.getProductId());
    \n }
    \n if (product.getStatus() != 1) {
    \n throw new BusinessException("\u5546\u54c1\u5df2\u4e0b\u67b6: " + product.getName());
    \n }
    \n if (product.getStock() < item.getQuantity()) {
    \n throw new BusinessException("\u5546\u54c1\u5e93\u5b58\u4e0d\u8db3: " + product.getName());
    \n }
    \n }
    \n}<\/p>\n

    \/**
    \n * \u751f\u6210\u8ba2\u5355\u53f7
    \n *\/
    \nprivate String generateOrderNo() {
    \n \/\/ \u65f6\u95f4\u6233 + \u968f\u673a\u6570
    \n return "O" + System.currentTimeMillis() +
    \n RandomUtil.randomNumbers(6);
    \n}<\/p>\n

    \/**
    \n * \u8ba1\u7b97\u8ba2\u5355\u91d1\u989d
    \n *\/
    \nprivate OrderAmount calculateOrderAmount(CreateOrderDTO createOrderDTO) {
    \n BigDecimal totalAmount = BigDecimal.ZERO;<\/p>\n

    for (CreateOrderItemDTO item : createOrderDTO.getItems()) {
    \n ProductDTO product = productService.getProductById(item.getProductId());
    \n BigDecimal itemAmount = product.getPrice().multiply(
    \n BigDecimal.valueOf(item.getQuantity()));
    \n totalAmount = totalAmount.add(itemAmount);
    \n }<\/p>\n

    \/\/ \u8ba1\u7b97\u8fd0\u8d39
    \n BigDecimal shippingAmount = calculateShipping(createOrderDTO);<\/p>\n

    \/\/ \u8ba1\u7b97\u4f18\u60e0\u91d1\u989d
    \n BigDecimal discountAmount = calculateDiscount(createOrderDTO);<\/p>\n

    \/\/ \u5b9e\u4ed8\u91d1\u989d = \u5546\u54c1\u603b\u989d + \u8fd0\u8d39 – \u4f18\u60e0
    \n BigDecimal payAmount = totalAmount.add(shippingAmount).subtract(discountAmount);<\/p>\n

    OrderAmount orderAmount = new OrderAmount();
    \n orderAmount.setTotalAmount(totalAmount);
    \n orderAmount.setShippingAmount(shippingAmount);
    \n orderAmount.setDiscountAmount(discountAmount);
    \n orderAmount.setPayAmount(payAmount);<\/p>\n

    return orderAmount;
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u5e93\u5b58\u670d\u52a1（\u6263\u51cf\u5e93\u5b58） package com.ecommerce.inventory.service;<\/p>\n

    import io.seata.rm.tcc.api.BusinessActionContext; import io.seata.rm.tcc.api.BusinessActionContextParameter; import io.seata.rm.tcc.api.LocalTCC; import io.seata.rm.tcc.api.TwoPhaseBusinessAction; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service;<\/p>\n

    @Slf4j @Service @LocalTCC public class InventoryService {<\/p>\n

    \/**
    \n * TCC\u6a21\u5f0f\u6263\u51cf\u5e93\u5b58
    \n *\/
    \n@TwoPhaseBusinessAction(name = "deductStock", commitMethod = "commitDeductStock",
    \n rollbackMethod = "rollbackDeductStock")
    \npublic boolean deductStockPrepare(BusinessActionContext actionContext,
    \n @BusinessActionContextParameter(paramName = "items")
    \n List<CreateOrderItemDTO> items) {
    \n log.info("TCC\u7b2c\u4e00\u9636\u6bb5：\u9884\u6263\u5e93\u5b58, xid={}", actionContext.getXid());<\/p>\n

    Map<Long, Integer> lockMap = new HashMap<>();<\/p>\n

    try {
    \n for (CreateOrderItemDTO item : items) {
    \n \/\/ \u83b7\u53d6\u5206\u5e03\u5f0f\u9501
    \n String lockKey = "inventory:lock:" + item.getProductId();
    \n RLock lock = redissonClient.getLock(lockKey);
    \n boolean locked = lock.tryLock(5, 10, TimeUnit.SECONDS);<\/p>\n

    if (!locked) {
    \n throw new BusinessException("\u9501\u5b9a\u5e93\u5b58\u5931\u8d25");
    \n }<\/p>\n

    \/\/ \u9884\u6263\u5e93\u5b58
    \n int affected = inventoryMapper.lockStock(
    \n item.getProductId(),
    \n item.getQuantity(),
    \n actionContext.getXid());<\/p>\n

    if (affected == 0) {
    \n throw new BusinessException("\u5e93\u5b58\u4e0d\u8db3");
    \n }<\/p>\n

    lockMap.put(item.getProductId(), item.getQuantity());<\/p>\n

    \/\/ \u8bb0\u5f55\u5e93\u5b58\u9501\u5b9a\u65e5\u5fd7
    \n InventoryLockLog lockLog = new InventoryLockLog();
    \n lockLog.setProductId(item.getProductId());
    \n lockLog.setOrderXid(actionContext.getXid());
    \n lockLog.setQuantity(item.getQuantity());
    \n lockLog.setStatus(0); \/\/ \u9501\u5b9a\u72b6\u6001
    \n lockLog.setCreateTime(LocalDateTime.now());
    \n inventoryLockLogMapper.insert(lockLog);
    \n }<\/p>\n

    \/\/ \u5c06\u9501\u5b9a\u4fe1\u606f\u4fdd\u5b58\u5230\u4e0a\u4e0b\u6587
    \n actionContext.setActionContext("lockMap", lockMap);<\/p>\n

    return true;<\/p>\n

    } catch (InterruptedException e) {
    \n Thread.currentThread().interrupt();
    \n throw new BusinessException("\u9501\u5b9a\u5e93\u5b58\u4e2d\u65ad", e);
    \n }
    \n}<\/p>\n

    \/**
    \n * TCC\u7b2c\u4e8c\u9636\u6bb5\u63d0\u4ea4
    \n *\/
    \npublic boolean commitDeductStock(BusinessActionContext actionContext) {
    \n log.info("TCC\u7b2c\u4e8c\u9636\u6bb5\u63d0\u4ea4：\u786e\u8ba4\u6263\u51cf\u5e93\u5b58, xid={}", actionContext.getXid());<\/p>\n

    \/\/ \u66f4\u65b0\u5e93\u5b58\u9501\u5b9a\u72b6\u6001\u4e3a\u5df2\u786e\u8ba4
    \n inventoryLockLogMapper.updateStatusByXid(actionContext.getXid(), 1);<\/p>\n

    \/\/ \u5b9e\u9645\u6263\u51cf\u5e93\u5b58
    \n Map<Long, Integer> lockMap = (Map<Long, Integer>)
    \n actionContext.getActionContext("lockMap");<\/p>\n

    for (Map.Entry<Long, Integer> entry : lockMap.entrySet()) {
    \n inventoryMapper.confirmDeductStock(entry.getKey(), entry.getValue());
    \n }<\/p>\n

    return true;
    \n}<\/p>\n

    \/**
    \n * TCC\u7b2c\u4e8c\u9636\u6bb5\u56de\u6eda
    \n *\/
    \npublic boolean rollbackDeductStock(BusinessActionContext actionContext) {
    \n log.info("TCC\u7b2c\u4e8c\u9636\u6bb5\u56de\u6eda：\u91ca\u653e\u5e93\u5b58, xid={}", actionContext.getXid());<\/p>\n

    \/\/ \u66f4\u65b0\u5e93\u5b58\u9501\u5b9a\u72b6\u6001\u4e3a\u5df2\u56de\u6eda
    \n inventoryLockLogMapper.updateStatusByXid(actionContext.getXid(), 2);<\/p>\n

    \/\/ \u91ca\u653e\u9501\u5b9a\u7684\u5e93\u5b58
    \n Map<Long, Integer> lockMap = (Map<Long, Integer>)
    \n actionContext.getActionContext("lockMap");<\/p>\n

    for (Map.Entry<Long, Integer> entry : lockMap.entrySet()) {
    \n inventoryMapper.releaseLockedStock(entry.getKey(), entry.getValue());
    \n }<\/p>\n

    return true;
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u5e93\u5b58Mapper @Mapper public interface InventoryMapper {<\/p>\n

    \/\/ \u9501\u5b9a\u5e93\u5b58
    \n@Update("UPDATE tb_inventory SET locked_stock = locked_stock + #{quantity}, " +
    \n "available_stock = available_stock – #{quantity} " +
    \n "WHERE product_id = #{productId} AND available_stock >= #{quantity}")
    \nint lockStock(@Param("productId") Long productId,
    \n @Param("quantity") Integer quantity,
    \n @Param("xid") String xid);<\/p>\n

    \/\/ \u786e\u8ba4\u6263\u51cf\u5e93\u5b58
    \n@Update("UPDATE tb_inventory SET locked_stock = locked_stock – #{quantity}, " +
    \n "total_stock = total_stock – #{quantity} " +
    \n "WHERE product_id = #{productId} AND locked_stock >= #{quantity}")
    \nint confirmDeductStock(@Param("productId") Long productId,
    \n @Param("quantity") Integer quantity);<\/p>\n

    \/\/ \u91ca\u653e\u9501\u5b9a\u7684\u5e93\u5b58
    \n@Update("UPDATE tb_inventory SET locked_stock = locked_stock – #{quantity}, " +
    \n "available_stock = available_stock + #{quantity} " +
    \n "WHERE product_id = #{productId} AND locked_stock >= #{quantity}")
    \nint releaseLockedStock(@Param("productId") Long productId,
    \n @Param("quantity") Integer quantity);<\/p>\n

    } 5.3 \u8ba2\u5355\u8d85\u65f6\u53d6\u6d88（RocketMQ\u5ef6\u8fdf\u6d88\u606f） \u8ba2\u5355\u8d85\u65f6\u53d6\u6d88\u5b9e\u73b0：<\/p>\n

    java \/\/ \u8ba2\u5355\u8d85\u65f6\u670d\u52a1 package com.ecommerce.order.service;<\/p>\n

    import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.stereotype.Service;<\/p>\n

    import java.time.LocalDateTime; import java.util.concurrent.DelayQueue; import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit;<\/p>\n

    @Slf4j @Service @RequiredArgsConstructor public class OrderTimeoutService {<\/p>\n

    private final RocketMQTemplate rocketMQTemplate;
    \nprivate final OrderMapper orderMapper;
    \nprivate final DelayQueue<OrderTimeoutTask> timeoutQueue = new DelayQueue<>();<\/p>\n

    \/**
    \n * \u542f\u52a8\u8ba2\u5355\u8d85\u65f6\u68c0\u67e5
    \n *\/
    \n@PostConstruct
    \npublic void init() {
    \n \/\/ \u542f\u52a8\u540e\u53f0\u7ebf\u7a0b\u5904\u7406\u8d85\u65f6\u8ba2\u5355
    \n new Thread(this::processTimeoutOrders).start();<\/p>\n

    \/\/ \u4ece\u6570\u636e\u5e93\u52a0\u8f7d\u5f85\u652f\u4ed8\u7684\u8d85\u65f6\u8ba2\u5355
    \n loadPendingOrders();
    \n}<\/p>\n

    \/**
    \n * \u6dfb\u52a0\u8ba2\u5355\u8d85\u65f6\u4efb\u52a1
    \n *\/
    \npublic void addOrderTimeoutTask(Long orderId, LocalDateTime createTime) {
    \n \/\/ \u8ba1\u7b97\u5ef6\u8fdf\u65f6\u95f4（30\u5206\u949f）
    \n long delay = TimeUnit.MINUTES.toMillis(30) –
    \n System.currentTimeMillis() –
    \n createTime.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli();<\/p>\n

    if (delay > 0) {
    \n OrderTimeoutTask task = new OrderTimeoutTask(orderId, delay);
    \n timeoutQueue.put(task);
    \n log.info("\u6dfb\u52a0\u8ba2\u5355\u8d85\u65f6\u4efb\u52a1: orderId={}, delay={}ms", orderId, delay);
    \n }
    \n}<\/p>\n

    \/**
    \n * \u5904\u7406\u8d85\u65f6\u8ba2\u5355
    \n *\/
    \nprivate void processTimeoutOrders() {
    \n while (!Thread.currentThread().isInterrupted()) {
    \n try {
    \n OrderTimeoutTask task = timeoutQueue.take();
    \n cancelTimeoutOrder(task.getOrderId());
    \n } catch (InterruptedException e) {
    \n Thread.currentThread().interrupt();
    \n log.error("\u8ba2\u5355\u8d85\u65f6\u5904\u7406\u7ebf\u7a0b\u4e2d\u65ad", e);
    \n }
    \n }
    \n}<\/p>\n

    \/**
    \n * \u53d6\u6d88\u8d85\u65f6\u8ba2\u5355
    \n *\/
    \nprivate void cancelTimeoutOrder(Long orderId) {
    \n try {
    \n Order order = orderMapper.selectById(orderId);
    \n if (order == null || order.getStatus() != OrderStatus.PENDING_PAYMENT.getCode()) {
    \n return;
    \n }<\/p>\n

    \/\/ \u68c0\u67e5\u662f\u5426\u771f\u7684\u8d85\u65f6（\u9632\u6b62\u91cd\u590d\u5904\u7406）
    \n LocalDateTime now = LocalDateTime.now();
    \n LocalDateTime createTime = order.getCreateTime();
    \n long minutes = Duration.between(createTime, now).toMinutes();<\/p>\n

    if (minutes >= 30) {
    \n log.info("\u53d6\u6d88\u8d85\u65f6\u8ba2\u5355: orderId={}, createTime={}", orderId, createTime);<\/p>\n

    \/\/ \u66f4\u65b0\u8ba2\u5355\u72b6\u6001\u4e3a\u5df2\u53d6\u6d88
    \n order.setStatus(OrderStatus.CANCELLED.getCode());
    \n order.setCancelTime(now);
    \n order.setCancelReason("\u8d85\u65f6\u672a\u652f\u4ed8");
    \n orderMapper.updateById(order);<\/p>\n

    \/\/ \u91ca\u653e\u5e93\u5b58
    \n releaseOrderStock(orderId);<\/p>\n

    \/\/ \u53d1\u9001\u8ba2\u5355\u53d6\u6d88\u6d88\u606f
    \n sendOrderCanceledMessage(order);
    \n }<\/p>\n

    } catch (Exception e) {
    \n log.error("\u53d6\u6d88\u8d85\u65f6\u8ba2\u5355\u5931\u8d25: orderId={}", orderId, e);
    \n }
    \n}<\/p>\n

    \/**
    \n * \u53d1\u9001\u5ef6\u8fdf\u6d88\u606f（RocketMQ\u65b9\u5f0f）
    \n *\/
    \npublic void sendOrderTimeoutMessage(Long orderId) {
    \n \/\/ \u53d1\u900130\u5206\u949f\u540e\u7684\u5ef6\u8fdf\u6d88\u606f
    \n rocketMQTemplate.syncSend("ORDER_TIMEOUT_TOPIC",
    \n MessageBuilder.withPayload(orderId).build(),
    \n TimeUnit.MINUTES.toMillis(30),
    \n TimeUnit.MILLISECONDS);<\/p>\n

    log.info("\u53d1\u9001\u8ba2\u5355\u8d85\u65f6\u5ef6\u8fdf\u6d88\u606f: orderId={}", orderId);
    \n}<\/p>\n

    \/**
    \n * \u76d1\u542c\u8ba2\u5355\u8d85\u65f6\u6d88\u606f
    \n *\/
    \n@RocketMQMessageListener(
    \n topic = "ORDER_TIMEOUT_TOPIC",
    \n consumerGroup = "order-timeout-consumer"
    \n)
    \n@Slf4j
    \n@Component
    \npublic class OrderTimeoutConsumer implements RocketMQListener<Long> {<\/p>\n

    @Override
    \n public void onMessage(Long orderId) {
    \n log.info("\u6536\u5230\u8ba2\u5355\u8d85\u65f6\u6d88\u606f: orderId={}", orderId);
    \n cancelTimeoutOrder(orderId);
    \n }
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u8ba2\u5355\u8d85\u65f6\u4efb\u52a1 @Data class OrderTimeoutTask implements Delayed {<\/p>\n

    private final Long orderId;
    \nprivate final long expireTime;<\/p>\n

    public OrderTimeoutTask(Long orderId, long delay) {
    \n this.orderId = orderId;
    \n this.expireTime = System.currentTimeMillis() + delay;
    \n}<\/p>\n

    @Override
    \npublic long getDelay(TimeUnit unit) {
    \n return unit.convert(expireTime – System.currentTimeMillis(), TimeUnit.MILLISECONDS);
    \n}<\/p>\n

    @Override
    \npublic int compareTo(Delayed o) {
    \n return Long.compare(this.expireTime, ((OrderTimeoutTask) o).expireTime);
    \n}<\/p>\n

    }<\/p>\n

    \u7b2c\u516d\u7ae0：\u652f\u4ed8\u670d\u52a1\u4e0e\u6d88\u606f\u961f\u5217<\/h3>\n

    6.1 \u652f\u4ed8\u670d\u52a1\u96c6\u6210 \u652f\u4ed8\u670d\u52a1\u914d\u7f6e：<\/p>\n

    java \/\/ \u652f\u4ed8\u670d\u52a1\u63a5\u53e3 package com.ecommerce.payment.service;<\/p>\n

    import com.ecommerce.payment.dto.*;<\/p>\n

    public interface PaymentService {<\/p>\n

    \/\/ \u521b\u5efa\u652f\u4ed8
    \nPaymentDTO createPayment(CreatePaymentDTO createPaymentDTO);<\/p>\n

    \/\/ \u67e5\u8be2\u652f\u4ed8\u72b6\u6001
    \nPaymentDTO queryPayment(String paymentNo);<\/p>\n

    \/\/ \u652f\u4ed8\u56de\u8c03\u5904\u7406
    \nPaymentCallbackResult handlePaymentCallback(PaymentCallbackDTO callbackDTO);<\/p>\n

    \/\/ \u9000\u6b3e
    \nRefundDTO refund(RefundRequest refundRequest);<\/p>\n

    \/\/ \u67e5\u8be2\u9000\u6b3e\u72b6\u6001
    \nRefundDTO queryRefund(String refundNo);<\/p>\n

    }<\/p>\n

    \/\/ \u652f\u4ed8\u7b56\u7565\u63a5\u53e3 package com.ecommerce.payment.strategy;<\/p>\n

    public interface PaymentStrategy {<\/p>\n

    \/\/ \u652f\u4ed8\u7c7b\u578b
    \nPaymentType getPaymentType();<\/p>\n

    \/\/ \u521b\u5efa\u652f\u4ed8
    \nPaymentDTO createPayment(CreatePaymentDTO createPaymentDTO);<\/p>\n

    \/\/ \u67e5\u8be2\u652f\u4ed8
    \nPaymentDTO queryPayment(String paymentNo);<\/p>\n

    \/\/ \u5904\u7406\u56de\u8c03
    \nPaymentCallbackResult handleCallback(PaymentCallbackDTO callbackDTO);<\/p>\n

    \/\/ \u9000\u6b3e
    \nRefundDTO refund(RefundRequest refundRequest);<\/p>\n

    }<\/p>\n

    \/\/ \u5fae\u4fe1\u652f\u4ed8\u5b9e\u73b0 @Service @Slf4j public class WechatPaymentStrategy implements PaymentStrategy {<\/p>\n

    @Override
    \npublic PaymentType getPaymentType() {
    \n return PaymentType.WECHAT;
    \n}<\/p>\n

    @Override
    \npublic PaymentDTO createPayment(CreatePaymentDTO createPaymentDTO) {
    \n log.info("\u5fae\u4fe1\u652f\u4ed8\u521b\u5efa: orderNo={}, amount={}",
    \n createPaymentDTO.getOrderNo(),
    \n createPaymentDTO.getAmount());<\/p>\n

    \/\/ \u8c03\u7528\u5fae\u4fe1\u652f\u4ed8API
    \n WechatPaymentRequest request = buildWechatRequest(createPaymentDTO);
    \n WechatPaymentResponse response = wechatClient.createPayment(request);<\/p>\n

    \/\/ \u4fdd\u5b58\u652f\u4ed8\u8bb0\u5f55
    \n Payment payment = savePaymentRecord(createPaymentDTO, response);<\/p>\n

    PaymentDTO paymentDTO = convertToDTO(payment);
    \n paymentDTO.setPayData(response.getPayData()); \/\/ \u652f\u4ed8\u53c2\u6570（\u7528\u4e8e\u524d\u7aef\u8c03\u8d77\u652f\u4ed8）<\/p>\n

    return paymentDTO;
    \n}<\/p>\n

    @Override
    \npublic PaymentCallbackResult handleCallback(PaymentCallbackDTO callbackDTO) {
    \n log.info("\u5904\u7406\u5fae\u4fe1\u652f\u4ed8\u56de\u8c03: {}", callbackDTO);<\/p>\n

    \/\/ \u9a8c\u8bc1\u7b7e\u540d
    \n if (!verifySignature(callbackDTO)) {
    \n throw new BusinessException("\u7b7e\u540d\u9a8c\u8bc1\u5931\u8d25");
    \n }<\/p>\n

    \/\/ \u89e3\u6790\u56de\u8c03\u6570\u636e
    \n WechatCallbackData callbackData = parseCallbackData(callbackDTO);<\/p>\n

    \/\/ \u66f4\u65b0\u652f\u4ed8\u72b6\u6001
    \n Payment payment = updatePaymentStatus(callbackData);<\/p>\n

    \/\/ \u53d1\u9001\u652f\u4ed8\u6210\u529f\u6d88\u606f
    \n if (payment.getStatus() == PaymentStatus.SUCCESS.getCode()) {
    \n sendPaymentSuccessMessage(payment);
    \n }<\/p>\n

    return buildCallbackResult(callbackData);
    \n}<\/p>\n

    private WechatPaymentRequest buildWechatRequest(CreatePaymentDTO createPaymentDTO) {
    \n WechatPaymentRequest request = new WechatPaymentRequest();
    \n request.setAppId(wechatConfig.getAppId());
    \n request.setMchId(wechatConfig.getMchId());
    \n request.setNonceStr(RandomUtil.randomString(32));
    \n request.setBody("\u5546\u54c1\u8d2d\u4e70-" + createPaymentDTO.getOrderNo());
    \n request.setOutTradeNo(createPaymentDTO.getPaymentNo());
    \n request.setTotalFee(createPaymentDTO.getAmount().multiply(new BigDecimal(100)).intValue());
    \n request.setSpbillCreateIp(createPaymentDTO.getClientIp());
    \n request.setNotifyUrl(wechatConfig.getNotifyUrl());
    \n request.setTradeType("JSAPI");
    \n request.setOpenid(createPaymentDTO.getOpenId());<\/p>\n

    \/\/ \u751f\u6210\u7b7e\u540d
    \n String sign = generateSignature(request);
    \n request.setSign(sign);<\/p>\n

    return request;
    \n}<\/p>\n

    } \u652f\u4ed8\u72b6\u6001\u540c\u6b65（\u6d88\u606f\u961f\u5217）：<\/p>\n

    java \/\/ \u652f\u4ed8\u6210\u529f\u6d88\u606f\u751f\u4ea7\u8005 @Service @Slf4j @RequiredArgsConstructor public class PaymentMessageProducer {<\/p>\n

    private final RocketMQTemplate rocketMQTemplate;<\/p>\n

    \/**
    \n * \u53d1\u9001\u652f\u4ed8\u6210\u529f\u6d88\u606f
    \n *\/
    \npublic void sendPaymentSuccessMessage(Payment payment) {
    \n PaymentSuccessMessage message = new PaymentSuccessMessage();
    \n message.setPaymentId(payment.getId());
    \n message.setOrderNo(payment.getOrderNo());
    \n message.setPaymentNo(payment.getPaymentNo());
    \n message.setAmount(payment.getAmount());
    \n message.setPaymentTime(payment.getPaymentTime());
    \n message.setPaymentType(payment.getPaymentType());<\/p>\n

    \/\/ \u53d1\u9001\u987a\u5e8f\u6d88\u606f，\u786e\u4fdd\u540c\u4e00\u4e2a\u8ba2\u5355\u7684\u6d88\u606f\u6709\u5e8f\u5904\u7406
    \n rocketMQTemplate.syncSendOrderly(
    \n "PAYMENT_SUCCESS_TOPIC",
    \n message,
    \n payment.getOrderNo()
    \n );<\/p>\n

    log.info("\u53d1\u9001\u652f\u4ed8\u6210\u529f\u6d88\u606f: paymentId={}, orderNo={}",
    \n payment.getId(), payment.getOrderNo());
    \n}<\/p>\n

    \/**
    \n * \u53d1\u9001\u652f\u4ed8\u5931\u8d25\u6d88\u606f
    \n *\/
    \npublic void sendPaymentFailedMessage(Payment payment, String failReason) {
    \n PaymentFailedMessage message = new PaymentFailedMessage();
    \n message.setPaymentId(payment.getId());
    \n message.setOrderNo(payment.getOrderNo());
    \n message.setPaymentNo(payment.getPaymentNo());
    \n message.setAmount(payment.getAmount());
    \n message.setFailReason(failReason);
    \n message.setFailTime(LocalDateTime.now());<\/p>\n

    rocketMQTemplate.syncSend("PAYMENT_FAILED_TOPIC", message);<\/p>\n

    log.info("\u53d1\u9001\u652f\u4ed8\u5931\u8d25\u6d88\u606f: paymentId={}, orderNo={}, reason={}",
    \n payment.getId(), payment.getOrderNo(), failReason);
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u8ba2\u5355\u670d\u52a1\u6d88\u8d39\u8005 @Slf4j @Component @RocketMQMessageListener( topic = \u201cPAYMENT_SUCCESS_TOPIC\u201d, consumerGroup = \u201corder-payment-consumer\u201d, consumeMode = ConsumeMode.ORDERLY, \/\/ \u987a\u5e8f\u6d88\u8d39 messageModel = MessageModel.CLUSTERING ) public class PaymentSuccessConsumer implements RocketMQListener {<\/p>\n

    private final OrderService orderService;<\/p>\n

    @Override
    \npublic void onMessage(PaymentSuccessMessage message) {
    \n log.info("\u6536\u5230\u652f\u4ed8\u6210\u529f\u6d88\u606f: orderNo={}, paymentNo={}",
    \n message.getOrderNo(), message.getPaymentNo());<\/p>\n

    try {
    \n \/\/ \u66f4\u65b0\u8ba2\u5355\u72b6\u6001\u4e3a\u5df2\u652f\u4ed8
    \n orderService.updateOrderStatus(
    \n message.getOrderNo(),
    \n OrderStatus.PAID,
    \n "\u7cfb\u7edf",
    \n "\u652f\u4ed8\u6210\u529f"
    \n );<\/p>\n

    \/\/ \u53d1\u9001\u8ba2\u5355\u652f\u4ed8\u6210\u529f\u901a\u77e5
    \n sendOrderPaidNotification(message);<\/p>\n

    } catch (Exception e) {
    \n log.error("\u5904\u7406\u652f\u4ed8\u6210\u529f\u6d88\u606f\u5931\u8d25: orderNo={}", message.getOrderNo(), e);
    \n \/\/ \u8bb0\u5f55\u5931\u8d25，\u4eba\u5de5\u5e72\u9884\u6216\u91cd\u8bd5
    \n }
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u5e93\u5b58\u670d\u52a1\u6d88\u8d39\u8005 @Slf4j @Component @RocketMQMessageListener( topic = \u201cPAYMENT_SUCCESS_TOPIC\u201d, consumerGroup = \u201cinventory-payment-consumer\u201d, consumeMode = ConsumeMode.ORDERLY, messageModel = MessageModel.CLUSTERING ) public class InventoryPaymentConsumer implements RocketMQListener {<\/p>\n

    private final InventoryService inventoryService;<\/p>\n

    @Override
    \npublic void onMessage(PaymentSuccessMessage message) {
    \n log.info("\u5e93\u5b58\u670d\u52a1\u6536\u5230\u652f\u4ed8\u6210\u529f\u6d88\u606f: orderNo={}", message.getOrderNo());<\/p>\n

    try {
    \n \/\/ \u786e\u8ba4\u6263\u51cf\u5e93\u5b58（\u4ece\u9501\u5b9a\u72b6\u6001\u8f6c\u4e3a\u5df2\u552e\u51fa）
    \n inventoryService.confirmStock(message.getOrderNo());<\/p>\n

    } catch (Exception e) {
    \n log.error("\u5e93\u5b58\u670d\u52a1\u5904\u7406\u652f\u4ed8\u6d88\u606f\u5931\u8d25: orderNo={}", message.getOrderNo(), e);
    \n \/\/ \u53d1\u9001\u5e93\u5b58\u5904\u7406\u5931\u8d25\u6d88\u606f，\u89e6\u53d1\u8865\u507f\u673a\u5236
    \n sendInventoryProcessFailedMessage(message, e.getMessage());
    \n }
    \n}<\/p>\n

    }<\/p>\n

    \u7b2c\u4e03\u7ae0：\u7f51\u5173\u4e0e\u5b89\u5168\u8ba4\u8bc1<\/h3>\n

    7.1 Spring Cloud Gateway\u7f51\u5173\u914d\u7f6e \u7f51\u5173\u8def\u7531\u914d\u7f6e：<\/p>\n

    yaml spring: cloud: gateway: discovery: locator: enabled: true lower-case-service-id: true<\/p>\n

    routes:
    \n # \u7528\u6237\u670d\u52a1
    \n – id: user-service
    \n uri: lb:\/\/user-service
    \n predicates:
    \n – Path=\/api\/user\/**
    \n filters:
    \n – StripPrefix=1
    \n – name: RequestRateLimiter
    \n args:
    \n redis-rate-limiter.replenishRate: 10
    \n redis-rate-limiter.burstCapacity: 20
    \n key-resolver: "#{@userKeyResolver}"<\/p>\n

    # \u5546\u54c1\u670d\u52a1
    \n – id: product-service
    \n uri: lb:\/\/product-service
    \n predicates:
    \n – Path=\/api\/product\/**
    \n filters:
    \n – StripPrefix=1
    \n – name: CircuitBreaker
    \n args:
    \n name: productService
    \n fallbackUri: forward:\/fallback\/product<\/p>\n

    # \u8ba2\u5355\u670d\u52a1
    \n – id: order-service
    \n uri: lb:\/\/order-service
    \n predicates:
    \n – Path=\/api\/order\/**
    \n – Method=POST,PUT,GET
    \n filters:
    \n – StripPrefix=1
    \n – name: AuthFilter<\/p>\n

    # \u652f\u4ed8\u670d\u52a1
    \n – id: payment-service
    \n uri: lb:\/\/payment-service
    \n predicates:
    \n – Path=\/api\/payment\/**
    \n filters:
    \n – StripPrefix=1
    \n – name: AuthFilter<\/p>\n

    # \u8ba4\u8bc1\u670d\u52a1
    \n – id: auth-service
    \n uri: lb:\/\/auth-service
    \n predicates:
    \n – Path=\/api\/auth\/**
    \n filters:
    \n – StripPrefix=1<\/p>\n

    # \u9759\u6001\u8d44\u6e90
    \n – id: static-resource
    \n uri: lb:\/\/user-service
    \n predicates:
    \n – Path=\/static\/**<\/p>\n

    # \u7ba1\u7406\u7aef\u70b9
    \n – id: actuator
    \n uri: lb:\/\/${spring.application.name}
    \n predicates:
    \n – Path=\/actuator\/**
    \n filters:
    \n – name: AuthFilter
    \n args:
    \n require-role: ADMIN<\/p>\n

    \u7f51\u5173\u9650\u6d41\u914d\u7f6e<\/h2>\n

    redis: rate-limiter: enabled: true replenish-rate: 10 # \u6bcf\u79d2\u4ee4\u724c\u6570 burst-capacity: 20 # \u4ee4\u724c\u6876\u5bb9\u91cf<\/p>\n

    \u7f51\u5173\u65ad\u8def\u5668\u914d\u7f6e<\/h2>\n

    resilience4j: circuitbreaker: instances: productService: sliding-window-size: 10 minimum-number-of-calls: 5 permitted-number-of-calls-in-half-open-state: 3 wait-duration-in-open-state: 5s failure-rate-threshold: 50 \u7f51\u5173\u8fc7\u6ee4\u5668：<\/p>\n

    java \/\/ \u8ba4\u8bc1\u8fc7\u6ee4\u5668 @Component @Slf4j public class AuthFilter implements GlobalFilter, Ordered {<\/p>\n

    private final JwtUtil jwtUtil;
    \nprivate final RedisTemplate<String, Object> redisTemplate;<\/p>\n

    \/\/ \u767d\u540d\u5355\u8def\u5f84
    \nprivate static final List<String> WHITE_LIST = Arrays.asList(
    \n "\/api\/auth\/login",
    \n "\/api\/auth\/register",
    \n "\/api\/product\/list",
    \n "\/api\/product\/detail",
    \n "\/static\/",
    \n "\/actuator\/health"
    \n);<\/p>\n

    @Override
    \npublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    \n ServerHttpRequest request = exchange.getRequest();
    \n String path = request.getPath().value();
    \n String method = request.getMethod().name();<\/p>\n

    \/\/ \u68c0\u67e5\u662f\u5426\u5728\u767d\u540d\u5355
    \n if (isWhiteList(path, method)) {
    \n return chain.filter(exchange);
    \n }<\/p>\n

    \/\/ \u83b7\u53d6token
    \n String token = getToken(request);
    \n if (StringUtils.isBlank(token)) {
    \n return unauthorized(exchange, "\u7f3a\u5c11\u8ba4\u8bc1\u4ee4\u724c");
    \n }<\/p>\n

    \/\/ \u9a8c\u8bc1token
    \n if (!jwtUtil.validateToken(token)) {
    \n return unauthorized(exchange, "\u4ee4\u724c\u65e0\u6548\u6216\u5df2\u8fc7\u671f");
    \n }<\/p>\n

    \/\/ \u68c0\u67e5token\u662f\u5426\u5728\u9ed1\u540d\u5355\u4e2d
    \n if (isTokenBlacklisted(token)) {
    \n return unauthorized(exchange, "\u4ee4\u724c\u5df2\u5931\u6548");
    \n }<\/p>\n

    \/\/ \u83b7\u53d6\u7528\u6237\u4fe1\u606f
    \n UserInfo userInfo = jwtUtil.getUserInfo(token);<\/p>\n

    \/\/ \u68c0\u67e5\u6743\u9650
    \n if (!hasPermission(userInfo, path, method)) {
    \n return forbidden(exchange, "\u6ca1\u6709\u8bbf\u95ee\u6743\u9650");
    \n }<\/p>\n

    \/\/ \u5c06\u7528\u6237\u4fe1\u606f\u6dfb\u52a0\u5230\u8bf7\u6c42\u5934
    \n ServerHttpRequest mutatedRequest = request.mutate()
    \n .header("X-User-Id", String.valueOf(userInfo.getUserId()))
    \n .header("X-User-Name", userInfo.getUsername())
    \n .header("X-User-Roles", String.join(",", userInfo.getRoles()))
    \n .build();<\/p>\n

    \/\/ \u8bb0\u5f55\u8bbf\u95ee\u65e5\u5fd7
    \n logAccess(request, userInfo);<\/p>\n

    return chain.filter(exchange.mutate().request(mutatedRequest).build());
    \n}<\/p>\n

    private boolean isWhiteList(String path, String method) {
    \n return WHITE_LIST.stream().anyMatch(path::startsWith) ||
    \n (path.startsWith("\/api\/product\/") && "GET".equals(method));
    \n}<\/p>\n

    private String getToken(ServerHttpRequest request) {
    \n String bearerToken = request.getHeaders().getFirst("Authorization");
    \n if (StringUtils.hasText(bearerToken) && bearerToken.startsWith("Bearer ")) {
    \n return bearerToken.substring(7);
    \n }
    \n return request.getQueryParams().getFirst("token");
    \n}<\/p>\n

    private boolean isTokenBlacklisted(String token) {
    \n String key = "blacklist:token:" + DigestUtils.md5Hex(token);
    \n return Boolean.TRUE.equals(redisTemplate.hasKey(key));
    \n}<\/p>\n

    private boolean hasPermission(UserInfo userInfo, String path, String method) {
    \n \/\/ \u7b80\u5355\u7684\u6743\u9650\u68c0\u67e5，\u5b9e\u9645\u9879\u76ee\u4e2d\u53ef\u4ee5\u4f7f\u7528RBAC\u6a21\u578b
    \n if (path.startsWith("\/api\/admin\/") && !userInfo.getRoles().contains("ADMIN")) {
    \n return false;
    \n }<\/p>\n

    if (path.startsWith("\/api\/order\/") && method.equals("POST") &&
    \n !userInfo.getRoles().contains("USER")) {
    \n return false;
    \n }<\/p>\n

    return true;
    \n}<\/p>\n

    private void logAccess(ServerHttpRequest request, UserInfo userInfo) {
    \n String logMsg = String.format("\u7f51\u5173\u8bbf\u95ee: user=%s, method=%s, path=%s, ip=%s",
    \n userInfo.getUsername(),
    \n request.getMethod(),
    \n request.getPath(),
    \n request.getRemoteAddress());<\/p>\n

    if (log.isDebugEnabled()) {
    \n log.debug(logMsg);
    \n }
    \n}<\/p>\n

    private Mono<Void> unauthorized(ServerWebExchange exchange, String message) {
    \n ServerHttpResponse response = exchange.getResponse();
    \n response.setStatusCode(HttpStatus.UNAUTHORIZED);
    \n response.getHeaders().setContentType(MediaType.APPLICATION_JSON);<\/p>\n

    ApiResponse<?> apiResponse = ApiResponse.error(401, message);
    \n byte[] bytes = JsonUtil.toJson(apiResponse).getBytes(StandardCharsets.UTF_8);<\/p>\n

    DataBuffer buffer = response.bufferFactory().wrap(bytes);
    \n return response.writeWith(Mono.just(buffer));
    \n}<\/p>\n

    private Mono<Void> forbidden(ServerWebExchange exchange, String message) {
    \n ServerHttpResponse response = exchange.getResponse();
    \n response.setStatusCode(HttpStatus.FORBIDDEN);
    \n response.getHeaders().setContentType(MediaType.APPLICATION_JSON);<\/p>\n

    ApiResponse<?> apiResponse = ApiResponse.error(403, message);
    \n byte[] bytes = JsonUtil.toJson(apiResponse).getBytes(StandardCharsets.UTF_8);<\/p>\n

    DataBuffer buffer = response.bufferFactory().wrap(bytes);
    \n return response.writeWith(Mono.just(buffer));
    \n}<\/p>\n

    @Override
    \npublic int getOrder() {
    \n return -100;
    \n}<\/p>\n

    }<\/p>\n

    \/\/ \u9650\u6d41Key\u89e3\u6790\u5668 @Component public class UserKeyResolver implements KeyResolver {<\/p>\n

    @Override
    \npublic Mono<String> resolve(ServerWebExchange exchange) {
    \n \/\/ \u6839\u636e\u7528\u6237ID\u9650\u6d41
    \n String userId = exchange.getRequest().getHeaders().getFirst("X-User-Id");
    \n if (StringUtils.isNotBlank(userId)) {
    \n return Mono.just(userId);
    \n }<\/p>\n

    \/\/ \u6839\u636eIP\u9650\u6d41
    \n String ip = Objects.requireNonNull(exchange.getRequest().getRemoteAddress())
    \n .getAddress().getHostAddress();
    \n return Mono.just(ip);
    \n}<\/p>\n

    }<\/p>\n

    \u7b2c\u516b\u7ae0：\u76d1\u63a7\u4e0e\u90e8\u7f72<\/h3>\n

    8.1 \u5b8c\u6574\u7684\u76d1\u63a7\u4f53\u7cfb Prometheus\u914d\u7f6e：<\/p>\n

    yaml<\/p>\n

    prometheus.yml<\/h2>\n

    global: scrape_interval: 15s evaluation_interval: 15s<\/p>\n

    alerting: alertmanagers: – static_configs: – targets: [\u2018alertmanager:9093\u2019]<\/p>\n

    rule_files:<\/p>\n

      \n
    • \u201calert_rules.yml\u201d<\/li>\n<\/ul>\n

      scrape_configs:<\/p>\n

        \n
      • \n

        job_name: \u2018spring-boot-apps\u2019 metrics_path: \u2018\/actuator\/prometheus\u2019 scrape_interval: 10s static_configs:<\/p>\n

          \n
        • targets:\n
            \n
          • \u2018gateway-service:8080\u2019<\/li>\n
          • \u2018user-service:8082\u2019<\/li>\n
          • \u2018product-service:8083\u2019<\/li>\n
          • \u2018order-service:8085\u2019<\/li>\n
          • \u2018payment-service:8086\u2019 labels: group: \u2018e-commerce-services\u2019<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n<\/li>\n
          • \n

            job_name: \u2018nacos\u2019 static_configs:<\/p>\n

              \n
            • targets: [\u2018nacos:8848\u2019]<\/li>\n<\/ul>\n<\/li>\n
            • \n

              job_name: \u2018redis\u2019 static_configs:<\/p>\n

                \n
              • targets: [\u2018redis-exporter:9121\u2019]<\/li>\n<\/ul>\n<\/li>\n
              • \n

                job_name: \u2018mysql\u2019 static_configs:<\/p>\n

                  \n
                • targets: [\u2018mysqld-exporter:9104\u2019]<\/li>\n<\/ul>\n<\/li>\n
                • \n

                  job_name: \u2018rocketmq\u2019 static_configs:<\/p>\n

                    \n
                  • targets: [\u2018rocketmq-exporter:5557\u2019]<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n

                    \u544a\u8b66\u89c4\u5219<\/h2>\n

                    alert_rules.yml<\/h2>\n

                    groups:<\/p>\n

                      \n
                    • name: e-commerce-alerts rules:\n
                        \n
                      • \n

                        alert: HighErrorRate expr: rate(http_server_requests_seconds_count{status!~\u201c2\u2026\u201d}[5m]) > 0.1 for: 1m labels: severity: warning annotations: summary: \u201c\u9ad8\u9519\u8bef\u7387\u62a5\u8b66\u201d description: \u201c{{ $labels.instance }} \u9519\u8bef\u7387\u8d85\u8fc710%\u201d<\/p>\n<\/li>\n

                      • \n

                        alert: HighLatency expr: histogram_quantile(0.95, rate(http_server_requests_seconds_bucket[5m])) > 1 for: 2m labels: severity: warning annotations: summary: \u201c\u9ad8\u5ef6\u8fdf\u62a5\u8b66\u201d description: \u201c{{ $labels.instance }} 95\u5206\u4f4d\u5ef6\u8fdf\u8d85\u8fc71\u79d2\u201d<\/p>\n<\/li>\n

                      • \n

                        alert: ServiceDown expr: up == 0 for: 1m labels: severity: critical annotations: summary: \u201c\u670d\u52a1\u4e0b\u7ebf\u62a5\u8b66\u201d description: \u201c{{ $labels.instance }} \u670d\u52a1\u5df2\u4e0b\u7ebf\u201d<\/p>\n<\/li>\n

                      • \n

                        alert: HighMemoryUsage expr: (sum(jvm_memory_used_bytes) by (instance) \/ sum(jvm_memory_max_bytes) by (instance)) * 100 > 80 for: 5m labels: severity: warning annotations: summary: \u201c\u9ad8\u5185\u5b58\u4f7f\u7528\u7387\u201d description: \u201c{{ $labels.instance }} \u5185\u5b58\u4f7f\u7528\u7387\u8d85\u8fc780%\u201d<\/p>\n<\/li>\n

                      • \n

                        alert: HighCPUUsage expr: process_cpu_usage * 100 > 80 for: 5m labels: severity: warning annotations: summary: \u201c\u9ad8CPU\u4f7f\u7528\u7387\u201d description: \u201c{{ $labels.instance }} CPU\u4f7f\u7528\u7387\u8d85\u8fc780%\u201d Spring Boot Actuator\u6307\u6807：<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n

                        java \/\/ \u81ea\u5b9a\u4e49\u4e1a\u52a1\u6307\u6807 @Component public class BusinessMetrics {<\/p>\n

                        private final MeterRegistry meterRegistry;<\/p>\n

                        \/\/ \u8ba2\u5355\u76f8\u5173\u6307\u6807
                        \nprivate final Counter orderCreatedCounter;
                        \nprivate final Counter orderPaidCounter;
                        \nprivate final Counter orderCanceledCounter;
                        \nprivate final Timer orderProcessTimer;<\/p>\n

                        \/\/ \u652f\u4ed8\u76f8\u5173\u6307\u6807
                        \nprivate final Counter paymentSuccessCounter;
                        \nprivate final Counter paymentFailedCounter;
                        \nprivate final DistributionSummary paymentAmountSummary;<\/p>\n

                        \/\/ \u7528\u6237\u76f8\u5173\u6307\u6807
                        \nprivate final Gauge activeUsersGauge;
                        \nprivate final AtomicInteger activeUsers = new AtomicInteger(0);<\/p>\n

                        public BusinessMetrics(MeterRegistry meterRegistry) {
                        \n this.meterRegistry = meterRegistry;<\/p>\n

                        \/\/ \u521d\u59cb\u5316\u8ba1\u6570\u5668
                        \n this.orderCreatedCounter = Counter.builder("ecommerce.orders.created")
                        \n .description("\u521b\u5efa\u8ba2\u5355\u603b\u6570")
                        \n .tag("application", "order-service")
                        \n .register(meterRegistry);<\/p>\n

                        this.orderPaidCounter = Counter.builder("ecommerce.orders.paid")
                        \n .description("\u652f\u4ed8\u6210\u529f\u8ba2\u5355\u6570")
                        \n .tag("application", "order-service")
                        \n .register(meterRegistry);<\/p>\n

                        this.orderCanceledCounter = Counter.builder("ecommerce.orders.canceled")
                        \n .description("\u53d6\u6d88\u8ba2\u5355\u6570")
                        \n .tag("application", "order-service")
                        \n .register(meterRegistry);<\/p>\n

                        \/\/ \u521d\u59cb\u5316\u8ba1\u65f6\u5668
                        \n this.orderProcessTimer = Timer.builder("ecommerce.orders.process.time")
                        \n .description("\u8ba2\u5355\u5904\u7406\u65f6\u95f4")
                        \n .publishPercentiles(0.5, 0.95, 0.99)
                        \n .register(meterRegistry);<\/p>\n

                        \/\/ \u521d\u59cb\u5316\u652f\u4ed8\u6307\u6807
                        \n this.paymentSuccessCounter = Counter.builder("ecommerce.payments.success")
                        \n .description("\u652f\u4ed8\u6210\u529f\u6570")
                        \n .tag("application", "payment-service")
                        \n .register(meterRegistry);<\/p>\n

                        this.paymentFailedCounter = Counter.builder("ecommerce.payments.failed")
                        \n .description("\u652f\u4ed8\u5931\u8d25\u6570")
                        \n .tag("application", "payment-service")
                        \n .register(meterRegistry);<\/p>\n

                        this.paymentAmountSummary = DistributionSummary.builder("ecommerce.payments.amount")
                        \n .description("\u652f\u4ed8\u91d1\u989d\u5206\u5e03")
                        \n .baseUnit("CNY")
                        \n .register(meterRegistry);<\/p>\n

                        \/\/ \u521d\u59cb\u5316\u8ba1\u91cf\u5668
                        \n this.activeUsersGauge = Gauge.builder("ecommerce.users.active", activeUsers, AtomicInteger::get)
                        \n .description("\u6d3b\u8dc3\u7528\u6237\u6570")
                        \n .register(meterRegistry);
                        \n}<\/p>\n

                        public void recordOrderCreated(OrderDTO order) {
                        \n orderCreatedCounter.increment();<\/p>\n

                        \/\/ \u8bb0\u5f55\u8ba2\u5355\u91d1\u989d
                        \n meterRegistry.summary("ecommerce.orders.amount")
                        \n .tag("status", "created")
                        \n .record(order.getPayAmount().doubleValue());
                        \n}<\/p>\n

                        public void recordOrderPaid(OrderDTO order, long processTime) {
                        \n orderPaidCounter.increment();
                        \n orderProcessTimer.record(processTime, TimeUnit.MILLISECONDS);<\/p>\n

                        meterRegistry.summary("ecommerce.orders.amount")
                        \n .tag("status", "paid")
                        \n .record(order.getPayAmount().doubleValue());
                        \n}<\/p>\n

                        public void recordPaymentSuccess(PaymentDTO payment) {
                        \n paymentSuccessCounter.increment();
                        \n paymentAmountSummary.record(payment.getAmount().doubleValue());
                        \n}<\/p>\n

                        public void recordPaymentFailed(PaymentDTO payment, String reason) {
                        \n paymentFailedCounter.increment();<\/p>\n

                        meterRegistry.counter("ecommerce.payments.failed.reason",
                        \n "reason", reason).increment();
                        \n}<\/p>\n

                        public void incrementActiveUsers() {
                        \n activeUsers.incrementAndGet();
                        \n}<\/p>\n

                        public void decrementActiveUsers() {
                        \n activeUsers.decrementAndGet();
                        \n}<\/p>\n

                        }<\/p>\n

                        \/\/ \u5728\u4e1a\u52a1\u4ee3\u7801\u4e2d\u4f7f\u7528 @Service @RequiredArgsConstructor public class OrderService {<\/p>\n

                        private final BusinessMetrics businessMetrics;<\/p>\n

                        public OrderDTO createOrder(CreateOrderDTO createOrderDTO) {
                        \n long startTime = System.currentTimeMillis();<\/p>\n

                        try {
                        \n \/\/ \u521b\u5efa\u8ba2\u5355\u903b\u8f91…
                        \n OrderDTO order = createOrderInternal(createOrderDTO);<\/p>\n

                        \/\/ \u8bb0\u5f55\u6307\u6807
                        \n businessMetrics.recordOrderCreated(order);<\/p>\n

                        return order;
                        \n } finally {
                        \n long processTime = System.currentTimeMillis() – startTime;
                        \n businessMetrics.recordOrderProcessTime(processTime);
                        \n }
                        \n}<\/p>\n

                        } 8.2 Docker\u4e0eKubernetes\u90e8\u7f72 Docker Compose\u5b8c\u6574\u90e8\u7f72：<\/p>\n

                        yaml version: \u20183.8\u2019<\/p>\n

                        services:<\/p>\n

                        \u57fa\u7840\u670d\u52a1<\/h2>\n

                        mysql: image: mysql:8.0 container_name: ecommerce-mysql environment: MYSQL_ROOT_PASSWORD: ecommerce123 MYSQL_DATABASE: ecommerce ports: – \u201c3306:3306\u201d volumes: – mysql_data:\/var\/lib\/mysql – .\/sql\/init.sql:\/docker-entrypoint-initdb.d\/init.sql networks: – ecommerce-network healthcheck: test: [\u201cCMD\u201d, \u201cmysqladmin\u201d, \u201cping\u201d, \u201c-h\u201d, \u201clocalhost\u201d] timeout: 20s retries: 10<\/p>\n

                        redis: image: redis:7-alpine container_name: ecommerce-redis ports: – \u201c6379:6379\u201d volumes: – redis_data:\/data command: redis-server –appendonly yes networks: – ecommerce-network healthcheck: test: [\u201cCMD\u201d, \u201credis-cli\u201d, \u201cping\u201d] interval: 10s timeout: 5s retries: 5<\/p>\n

                        nacos: image: nacos\/nacos-server:v2.2.0 container_name: ecommerce-nacos environment: – MODE=standalone – SPRING_DATASOURCE_PLATFORM=mysql – MYSQL_SERVICE_HOST=mysql – MYSQL_SERVICE_DB_NAME=nacos – MYSQL_SERVICE_PORT=3306 – MYSQL_SERVICE_USER=root – MYSQL_SERVICE_PASSWORD=ecommerce123 – NACOS_AUTH_ENABLE=true ports: – \u201c8848:8848\u201d – \u201c9848:9848\u201d – \u201c9849:9849\u201d volumes: – nacos_logs:\/home\/nacos\/logs depends_on: mysql: condition: service_healthy networks: – ecommerce-network<\/p>\n

                        seata: image: seataio\/seata-server:1.7.1 container_name: ecommerce-seata environment: – SEATA_PORT=8091 – STORE_MODE=db – SEATA_IP=seata ports: – \u201c8091:8091\u201d volumes: – .\/config\/seata\/registry.conf:\/seata-server\/resources\/registry.conf depends_on: – mysql – nacos networks: – ecommerce-network<\/p>\n

                        rocketmq: image: apache\/rocketmq:5.1.0 container_name: ecommerce-rocketmq ports: – \u201c9876:9876\u201d – \u201c10909:10909\u201d – \u201c10911:10911\u201d volumes: – rocketmq_logs:\/home\/rocketmq\/logs – rocketmq_store:\/home\/rocketmq\/store networks: – ecommerce-network<\/p>\n

                        \u76d1\u63a7\u670d\u52a1<\/h2>\n

                        prometheus: image: prom\/prometheus:v2.44.0 container_name: ecommerce-prometheus ports: – \u201c9090:9090\u201d volumes: – .\/config\/prometheus\/prometheus.yml:\/etc\/prometheus\/prometheus.yml – prometheus_data:\/prometheus command: – \u2018\u2013config.file=\/etc\/prometheus\/prometheus.yml\u2019 – \u2018\u2013storage.tsdb.path=\/prometheus\u2019 – \u2018\u2013web.console.libraries=\/etc\/prometheus\/console_libraries\u2019 – \u2018\u2013web.console.templates=\/etc\/prometheus\/consoles\u2019 – \u2018\u2013storage.tsdb.retention.time=200h\u2019 – \u2018\u2013web.enable-lifecycle\u2019 networks: – ecommerce-network<\/p>\n

                        grafana: image: grafana\/grafana:9.5.2 container_name: ecommerce-grafana ports: – \u201c3000:3000\u201d environment: – GF_SECURITY_ADMIN_PASSWORD=admin123 volumes: – grafana_data:\/var\/lib\/grafana – .\/config\/grafana\/dashboards:\/etc\/grafana\/provisioning\/dashboards – .\/config\/grafana\/datasources:\/etc\/grafana\/provisioning\/datasources depends_on: – prometheus networks: – ecommerce-network<\/p>\n

                        \u5e94\u7528\u670d\u52a1<\/h2>\n

                        gateway: build: context: .\/e-commerce-parent\/e-commerce-gateway dockerfile: Dockerfile container_name: ecommerce-gateway ports: – \u201c8080:8080\u201d environment: – SPRING_PROFILES_ACTIVE=docker – SPRING_CLOUD_NACOS_SERVER_ADDR=nacos:8848 – SPRING_CLOUD_NACOS_USERNAME=nacos – SPRING_CLOUD_NACOS_PASSWORD=nacos – SPRING_REDIS_HOST=redis – SPRING_REDIS_PORT=6379 depends_on: nacos: condition: service_healthy redis: condition: service_healthy networks: – ecommerce-network deploy: replicas: 2<\/p>\n

                        user-service: build: context: .\/e-commerce-parent\/e-commerce-user dockerfile: Dockerfile container_name: ecommerce-user ports: – \u201c8082:8082\u201d environment: – SPRING_PROFILES_ACTIVE=docker – SPRING_CLOUD_NACOS_SERVER_ADDR=nacos:8848 – SPRING_DATASOURCE_URL=jdbc:mysql:\/\/mysql:3306\/user_db – SPRING_DATASOURCE_USERNAME=root – SPRING_DATASOURCE_PASSWORD=ecommerce123 – SPRING_REDIS_HOST=redis – SPRING_REDIS_PORT=6379 depends_on: – nacos – mysql – redis networks: – ecommerce-network deploy: replicas: 3<\/p>\n

                        product-service: build: context: .\/e-commerce-parent\/e-commerce-product dockerfile: Dockerfile container_name: ecommerce-product ports: – \u201c8083:8083\u201d environment: – SPRING_PROFILES_ACTIVE=docker – SPRING_CLOUD_NACOS_SERVER_ADDR=nacos:8848 – SPRING_DATASOURCE_URL=jdbc:mysql:\/\/mysql:3306\/product_db – SPRING_DATASOURCE_USERNAME=root – SPRING_DATASOURCE_PASSWORD=ecommerce123 – SPRING_REDIS_HOST=redis – SPRING_REDIS_PORT=6379 – SPRING_ELASTICSEARCH_HOST=elasticsearch – SPRING_ELASTICSEARCH_PORT=9200 depends_on: – nacos – mysql – redis networks: – ecommerce-network deploy: replicas: 3<\/p>\n

                        order-service: build: context: .\/e-commerce-parent\/e-commerce-order dockerfile: Dockerfile container_name: ecommerce-order ports: – \u201c8085:8085\u201d environment: – SPRING_PROFILES_ACTIVE=docker – SPRING_CLOUD_NACOS_SERVER_ADDR=nacos:8848 – SPRING_DATASOURCE_URL=jdbc:mysql:\/\/mysql:3306\/order_db – SPRING_DATASOURCE_USERNAME=root – SPRING_DATASOURCE_PASSWORD=ecommerce123 – SPRING_REDIS_HOST=redis – SPRING_REDIS_PORT=6379 – SEATA_SERVER_HOST=seata – ROCKETMQ_NAME_SERVER=rocketmq:9876 depends_on: – nacos – mysql – redis – seata – rocketmq networks: – ecommerce-network deploy: replicas: 3<\/p>\n

                        networks: ecommerce-network: driver: bridge<\/p>\n

                        volumes: mysql_data: redis_data: nacos_logs: rocketmq_logs: rocketmq_store: prometheus_data: grafana_data: Kubernetes\u90e8\u7f72\u6587\u4ef6：<\/p>\n

                        yaml<\/p>\n

                        namespace.yaml<\/h2>\n

                        apiVersion: v1 kind: Namespace metadata: name: ecommerce<\/h3>\n

                        configmap.yaml<\/h2>\n

                        apiVersion: v1 kind: ConfigMap metadata: name: ecommerce-config namespace: ecommerce data: application.yml: | spring: cloud: nacos: discovery: server-addr: nacos:8848 config: server-addr: nacos:8848 redis: host: redis port: 6379<\/h3>\n

                        secret.yaml<\/h2>\n

                        apiVersion: v1 kind: Secret metadata: name: ecommerce-secrets namespace: ecommerce type: Opaque data: mysql-password: ZWNvbW1lcmNlMTIz # ecommerce123 base64\u7f16\u7801 nacos-password: bmFjb3M= # nacos base64\u7f16\u7801<\/h3>\n

                        deployment.yaml<\/h2>\n

                        apiVersion: apps\/v1 kind: Deployment metadata: name: user-service namespace: ecommerce labels: app: user-service spec: replicas: 3 selector: matchLabels: app: user-service template: metadata: labels: app: user-service spec: containers: – name: user-service image: ecommerce\/user-service:1.0.0 ports: – containerPort: 8082 env: – name: SPRING_PROFILES_ACTIVE value: \u201ck8s\u201d – name: SPRING_DATASOURCE_URL value: \u201cjdbc:mysql:\/\/mysql:3306\/user_db\u201d – name: SPRING_DATASOURCE_USERNAME value: \u201croot\u201d – name: SPRING_DATASOURCE_PASSWORD valueFrom: secretKeyRef: name: ecommerce-secrets key: mysql-password resources: requests: memory: \u201c512Mi\u201d cpu: \u201c250m\u201d limits: memory: \u201c1Gi\u201d cpu: \u201c500m\u201d livenessProbe: httpGet: path: \/actuator\/health\/liveness port: 8082 initialDelaySeconds: 60 periodSeconds: 10 readinessProbe: httpGet: path: \/actuator\/health\/readiness port: 8082 initialDelaySeconds: 30 periodSeconds: 5<\/h3>\n

                        service.yaml<\/h2>\n

                        apiVersion: v1 kind: Service metadata: name: user-service namespace: ecommerce spec: selector: app: user-service ports:<\/p>\n

                          \n
                        • port: 8082 targetPort: 8082 type: ClusterIP<\/li>\n<\/ul>\n
                          \n

                          ingress.yaml<\/h2>\n

                          apiVersion: networking.k8s.io\/v1 kind: Ingress metadata: name: ecommerce-ingress namespace: ecommerce annotations: nginx.ingress.kubernetes.io\/rewrite-target: \/ nginx.ingress.kubernetes.io\/ssl-redirect: \u201cfalse\u201d spec: rules:<\/p>\n

                            \n
                          • host: api.ecommerce.com http: paths:\n
                              \n
                            • path: \/user pathType: Prefix backend: service: name: user-service port: number: 8082<\/li>\n
                            • path: \/product pathType: Prefix backend: service: name: product-service port: number: 8083<\/li>\n
                            • path: \/order pathType: Prefix backend: service: name: order-service port: number: 8085<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
                              \n

                              hpa.yaml<\/h2>\n

                              apiVersion: autoscaling\/v2 kind: HorizontalPodAutoscaler metadata: name: user-service-hpa namespace: ecommerce spec: scaleTargetRef: apiVersion: apps\/v1 kind: Deployment name: user-service minReplicas: 2 maxReplicas: 10 metrics:<\/p>\n

                                \n
                              • type: Resource resource: name: cpu target: type: Utilization averageUtilization: 70<\/li>\n
                              • type: Resource resource: name: memory target: type: Utilization averageUtilization: 80<\/li>\n<\/ul>\n

                                \u7b2c\u4e5d\u7ae0：\u9879\u76ee\u603b\u7ed3\u4e0e\u6269\u5c55<\/h3>\n

                                9.1 \u9879\u76ee\u67b6\u6784\u603b\u7ed3 \u5df2\u5b9e\u73b0\u7684\u6838\u5fc3\u529f\u80fd：<\/p>\n

                                text \u2705 \u7528\u6237\u670d\u52a1：\u6ce8\u518c\u3001\u767b\u5f55\u3001\u7528\u6237\u7ba1\u7406 \u2705 \u5546\u54c1\u670d\u52a1：\u5546\u54c1\u7ba1\u7406\u3001\u641c\u7d22\u3001\u7f13\u5b58 \u2705 \u8ba2\u5355\u670d\u52a1：\u521b\u5efa\u8ba2\u5355\u3001\u72b6\u6001\u7ba1\u7406\u3001\u5206\u5e03\u5f0f\u4e8b\u52a1 \u2705 \u652f\u4ed8\u670d\u52a1：\u652f\u4ed8\u96c6\u6210\u3001\u56de\u8c03\u5904\u7406 \u2705 \u5e93\u5b58\u670d\u52a1：\u5e93\u5b58\u7ba1\u7406\u3001\u5206\u5e03\u5f0f\u9501 \u2705 \u4f18\u60e0\u5238\u670d\u52a1：\u4f18\u60e0\u5238\u7ba1\u7406\u3001\u4f7f\u7528 \u2705 \u7f51\u5173\u670d\u52a1：\u8def\u7531\u3001\u8ba4\u8bc1\u3001\u9650\u6d41\u3001\u7194\u65ad \u2705 \u914d\u7f6e\u4e2d\u5fc3：\u7edf\u4e00\u914d\u7f6e\u7ba1\u7406 \u2705 \u670d\u52a1\u6ce8\u518c\u53d1\u73b0：Nacos\u670d\u52a1\u6cbb\u7406 \u2705 \u76d1\u63a7\u544a\u8b66：Prometheus + Grafana \u2705 \u94fe\u8def\u8ffd\u8e2a：Sleuth + Zipkin \u2705 \u6d88\u606f\u961f\u5217：RocketMQ\u5f02\u6b65\u5904\u7406 \u2705 \u5206\u5e03\u5f0f\u4e8b\u52a1：Seata TCC\u6a21\u5f0f \u2705 \u5bb9\u5668\u5316\u90e8\u7f72：Docker + Kubernetes \u6027\u80fd\u4f18\u5316\u70b9：<\/p>\n

                                text<\/p>\n

                              • \u7f13\u5b58\u7b56\u7565：\u591a\u7ea7\u7f13\u5b58（Redis + \u672c\u5730\u7f13\u5b58）<\/li>\n
                              • \u6570\u636e\u5e93\u4f18\u5316：\u8bfb\u5199\u5206\u79bb\u3001\u5206\u5e93\u5206\u8868<\/li>\n
                              • \u5f02\u6b65\u5904\u7406：\u6d88\u606f\u961f\u5217\u89e3\u8026<\/li>\n
                              • \u9650\u6d41\u7194\u65ad：\u4fdd\u62a4\u6838\u5fc3\u670d\u52a1<\/li>\n
                              • \u5206\u5e03\u5f0f\u9501：\u4fdd\u8bc1\u6570\u636e\u4e00\u81f4\u6027<\/li>\n
                              • \u8fde\u63a5\u6c60\u4f18\u5316：\u6570\u636e\u5e93\u3001Redis\u8fde\u63a5\u6c60<\/li>\n
                              • JVM\u4f18\u5316：GC\u8c03\u4f18\u3001\u5185\u5b58\u914d\u7f6e<\/li>\n
                              • \u9759\u6001\u8d44\u6e90：CDN\u52a0\u901f 9.2 \u6269\u5c55\u529f\u80fd\u5efa\u8bae<\/li>\n
                              • \u79d2\u6740\u7cfb\u7edf：<\/li>\n

                                java \/\/ \u79d2\u6740\u670d\u52a1\u8bbe\u8ba1 @Service public class SeckillService {<\/p>\n

                                \/\/ 1. \u5e93\u5b58\u9884\u70ed\u5230Redis
                                \npublic void preheatStock(Long productId, Integer stock) {
                                \n redisTemplate.opsForValue().set("seckill:stock:" + productId, stock);
                                \n}<\/p>\n

                                \/\/ 2. \u7528\u6237\u8bf7\u6c42\u6392\u961f
                                \npublic SeckillResult seckill(Long userId, Long productId) {
                                \n \/\/ \u9a8c\u8bc1\u7528\u6237\u8d44\u683c
                                \n if (!checkUserQualification(userId)) {
                                \n return SeckillResult.fail("\u7528\u6237\u8d44\u683c\u4e0d\u7b26");
                                \n }<\/p>\n

                                \/\/ \u9a8c\u8bc1\u79d2\u6740\u65f6\u95f4
                                \n if (!checkSeckillTime(productId)) {
                                \n return SeckillResult.fail("\u79d2\u6740\u672a\u5f00\u59cb\u6216\u5df2\u7ed3\u675f");
                                \n }<\/p>\n

                                \/\/ \u83b7\u53d6Redis\u5206\u5e03\u5f0f\u9501
                                \n RLock lock = redissonClient.getLock("seckill:lock:" + productId);<\/p>\n

                                try {
                                \n boolean acquired = lock.tryLock(100, 10, TimeUnit.MILLISECONDS);
                                \n if (!acquired) {
                                \n return SeckillResult.fail("\u7cfb\u7edf\u7e41\u5fd9");
                                \n }<\/p>\n

                                \/\/ \u9884\u51cf\u5e93\u5b58
                                \n Long stock = redisTemplate.opsForValue().decrement("seckill:stock:" + productId);
                                \n if (stock == null || stock < 0) {
                                \n \/\/ \u5e93\u5b58\u4e0d\u8db3，\u6062\u590d\u5e93\u5b58
                                \n redisTemplate.opsForValue().increment("seckill:stock:" + productId);
                                \n return SeckillResult.fail("\u5e93\u5b58\u4e0d\u8db3");
                                \n }<\/p>\n

                                \/\/ \u751f\u6210\u79d2\u6740\u8ba2\u5355\u53f7
                                \n String seckillOrderNo = generateSeckillOrderNo();<\/p>\n

                                \/\/ \u53d1\u9001\u6d88\u606f\u5230MQ，\u5f02\u6b65\u521b\u5efa\u8ba2\u5355
                                \n sendSeckillOrderMessage(userId, productId, seckillOrderNo);<\/p>\n

                                return SeckillResult.success(seckillOrderNo);<\/p>\n

                                } catch (InterruptedException e) {
                                \n Thread.currentThread().interrupt();
                                \n return SeckillResult.fail("\u7cfb\u7edf\u5f02\u5e38");
                                \n } finally {
                                \n if (lock.isHeldByCurrentThread()) {
                                \n lock.unlock();
                                \n }
                                \n }
                                \n}<\/p>\n

                                } 2. \u63a8\u8350\u7cfb\u7edf：<\/p>\n

                                java \/\/ \u57fa\u4e8e\u7528\u6237\u884c\u4e3a\u7684\u63a8\u8350 @Service public class RecommendationService {<\/p>\n

                                \/\/ \u534f\u540c\u8fc7\u6ee4\u63a8\u8350
                                \npublic List<ProductDTO> recommendByCF(Long userId) {
                                \n \/\/ 1. \u83b7\u53d6\u7528\u6237\u5386\u53f2\u884c\u4e3a
                                \n List<UserBehavior> behaviors = getUserBehaviors(userId);<\/p>\n

                                \/\/ 2. \u8ba1\u7b97\u7528\u6237\u76f8\u4f3c\u5ea6
                                \n Map<Long, Double> userSimilarities = calculateUserSimilarities(userId);<\/p>\n

                                \/\/ 3. \u83b7\u53d6\u76f8\u4f3c\u7528\u6237\u559c\u6b22\u7684\u5546\u54c1
                                \n Set<Long> recommendedProductIds = getProductsFromSimilarUsers(userSimilarities);<\/p>\n

                                \/\/ 4. \u8fc7\u6ee4\u5df2\u8d2d\u4e70\u5546\u54c1
                                \n recommendedProductIds.removeAll(getPurchasedProducts(userId));<\/p>\n

                                \/\/ 5. \u83b7\u53d6\u5546\u54c1\u8be6\u60c5
                                \n return productService.getProductsByIds(new ArrayList<>(recommendedProductIds));
                                \n}<\/p>\n

                                \/\/ \u5b9e\u65f6\u63a8\u8350（\u57fa\u4e8eRedis）
                                \npublic List<ProductDTO> getRealTimeRecommendations(Long userId) {
                                \n String key = "recommend:realtime:" + userId;<\/p>\n

                                \/\/ \u4eceRedis\u83b7\u53d6\u5b9e\u65f6\u63a8\u8350
                                \n List<Long> productIds = (List<Long>) redisTemplate.opsForValue().get(key);<\/p>\n

                                if (productIds == null || productIds.isEmpty()) {
                                \n \/\/ \u91cd\u65b0\u8ba1\u7b97\u63a8\u8350
                                \n productIds = calculateRealTimeRecommendations(userId);
                                \n redisTemplate.opsForValue().set(key, productIds, 10, TimeUnit.MINUTES);
                                \n }<\/p>\n

                                return productService.getProductsByIds(productIds);
                                \n}<\/p>\n

                                } 3. \u6570\u636e\u7edf\u8ba1\u5206\u6790：<\/p>\n

                                java \/\/ \u5b9e\u65f6\u6570\u636e\u7edf\u8ba1 @Service public class DataAnalysisService {<\/p>\n

                                \/\/ \u4f7f\u7528Flink\u8fdb\u884c\u5b9e\u65f6\u6570\u636e\u5206\u6790
                                \npublic void realTimeAnalysis() {
                                \n StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();<\/p>\n

                                \/\/ \u4eceKafka\u8bfb\u53d6\u8ba2\u5355\u6570\u636e
                                \n DataStream<OrderEvent> orderStream = env
                                \n .addSource(new FlinkKafkaConsumer<>(
                                \n "order-topic",
                                \n new OrderEventSchema(),
                                \n properties))
                                \n .name("\u8ba2\u5355\u6570\u636e\u6e90");<\/p>\n

                                \/\/ \u5b9e\u65f6\u7edf\u8ba1
                                \n orderStream
                                \n .keyBy(OrderEvent::getProductId)
                                \n .timeWindow(Time.minutes(5))
                                \n .aggregate(new ProductSalesAggregator())
                                \n .addSink(new RedisSink<>());<\/p>\n

                                env.execute("\u5b9e\u65f6\u6570\u636e\u5206\u6790");
                                \n}<\/p>\n

                                \/\/ \u5546\u54c1\u9500\u552e\u805a\u5408\u5668
                                \npublic static class ProductSalesAggregator
                                \n implements AggregateFunction<OrderEvent, ProductSales, ProductSales> {<\/p>\n

                                @Override
                                \n public ProductSales createAccumulator() {
                                \n return new ProductSales();
                                \n }<\/p>\n

                                @Override
                                \n public ProductSales add(OrderEvent event, ProductSales accumulator) {
                                \n accumulator.setProductId(event.getProductId());
                                \n accumulator.setSalesCount(accumulator.getSalesCount() + event.getQuantity());
                                \n accumulator.setSalesAmount(accumulator.getSalesAmount() +
                                \n event.getPrice() * event.getQuantity());
                                \n return accumulator;
                                \n }<\/p>\n

                                @Override
                                \n public ProductSales getResult(ProductSales accumulator) {
                                \n return accumulator;
                                \n }<\/p>\n

                                @Override
                                \n public ProductSales merge(ProductSales a, ProductSales b) {
                                \n a.setSalesCount(a.getSalesCount() + b.getSalesCount());
                                \n a.setSalesAmount(a.getSalesAmount() + b.getSalesAmount());
                                \n return a;
                                \n }
                                \n}<\/p>\n

                                } 9.3 \u5b66\u4e60\u6536\u83b7\u4e0e\u804c\u4e1a\u53d1\u5c55 \u901a\u8fc7\u672c\u9879\u76ee\u4f60\u5b66\u4f1a\u4e86：<\/p>\n

                                \u2705 \u5fae\u670d\u52a1\u67b6\u6784\u8bbe\u8ba1\u4e0e\u62c6\u5206<\/p>\n

                                \u2705 Spring Cloud\u5168\u5bb6\u6876\u5b9e\u6218<\/p>\n

                                \u2705 \u5206\u5e03\u5f0f\u7cfb\u7edf\u6838\u5fc3\u95ee\u9898\u89e3\u51b3\u65b9\u6848<\/p>\n

                                \u2705 \u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u7684\u6027\u80fd\u4f18\u5316<\/p>\n

                                \u2705 \u5bb9\u5668\u5316\u4e0e\u4e91\u539f\u751f\u90e8\u7f72<\/p>\n

                                \u2705 \u5168\u94fe\u8def\u76d1\u63a7\u4e0e\u6545\u969c\u6392\u67e5<\/p>\n

                                \u2705 \u56e2\u961f\u534f\u4f5c\u4e0e\u9879\u76ee\u7ba1\u7406<\/p>\n

                                \u9762\u8bd5\u52a0\u5206\u9879：<\/p>\n

                                text<\/p>\n

                              • \u9879\u76ee\u7ecf\u9a8c：\u5b8c\u6574\u7535\u5546\u5fae\u670d\u52a1\u9879\u76ee<\/li>\n
                              • \u6280\u672f\u6df1\u5ea6：Spring Cloud\u6e90\u7801\u7406\u89e3<\/li>\n
                              • \u67b6\u6784\u80fd\u529b：\u7cfb\u7edf\u8bbe\u8ba1\u3001\u6027\u80fd\u4f18\u5316<\/li>\n
                              • \u89e3\u51b3\u95ee\u9898：\u5206\u5e03\u5f0f\u4e8b\u52a1\u3001\u7f13\u5b58\u4e00\u81f4\u6027\u95ee\u9898<\/li>\n
                              • \u8fd0\u7ef4\u80fd\u529b：Docker\u3001Kubernetes\u3001\u76d1\u63a7 \u804c\u4e1a\u53d1\u5c55\u5efa\u8bae：<\/li>\n

                                text \u521d\u7ea7 \u2192 \u4e2d\u7ea7 \u2192 \u9ad8\u7ea7 \u2192 \u67b6\u6784\u5e08 \u2192 \u6280\u672f\u4e13\u5bb6<\/p>\n

                                \u5b66\u4e60\u8def\u7ebf：<\/p>\n

                              • \u592f\u5b9e\u57fa\u7840：Java\u3001Spring\u3001\u6570\u636e\u5e93\u3001\u7f51\u7edc<\/li>\n
                              • \u638c\u63e1\u6846\u67b6：Spring Cloud\u3001MyBatis\u3001Redis<\/li>\n
                              • \u5b66\u4e60\u67b6\u6784：\u5fae\u670d\u52a1\u3001DDD\u3001\u4e91\u539f\u751f<\/li>\n
                              • \u6df1\u5165\u539f\u7406：JVM\u3001\u64cd\u4f5c\u7cfb\u7edf\u3001\u7f51\u7edc\u539f\u7406<\/li>\n
                              • \u62d3\u5c55\u89c6\u91ce：\u5927\u6570\u636e\u3001AI\u3001\u533a\u5757\u94fe \u7b2c\u5341\u7ae0：\u8d44\u6e90\u4e0e\u540e\u7eed\u5b66\u4e60 10.1 \u9879\u76ee\u8d44\u6e90\u4e0b\u8f7d GitHub\u4ed3\u5e93\u5730\u5740：<\/li>\n

                                text https:\/\/github.com\/yourusername\/e-commerce-microservices<\/p>\n

                                \u5305\u542b\u5185\u5bb9： \u251c\u2500\u2500 \u5b8c\u6574\u6e90\u4ee3\u7801 \u251c\u2500\u2500 \u6570\u636e\u5e93\u811a\u672c \u251c\u2500\u2500 Docker\u914d\u7f6e\u6587\u4ef6 \u251c\u2500\u2500 Kubernetes\u90e8\u7f72\u6587\u4ef6 \u251c\u2500\u2500 \u63a5\u53e3\u6587\u6863 \u251c\u2500\u2500 \u67b6\u6784\u8bbe\u8ba1\u6587\u6863 \u2514\u2500\u2500 \u5b66\u4e60\u8def\u7ebf\u56fe \u5feb\u901f\u542f\u52a8\u547d\u4ee4：<\/p>\n

                                bash<\/p>\n

                                1. \u514b\u9686\u9879\u76ee<\/h2>\n

                                git clone https:\/\/github.com\/yourusername\/e-commerce-microservices.git<\/p>\n

                                2. \u542f\u52a8\u57fa\u7840\u8bbe\u65bd<\/h2>\n

                                cd e-commerce-microservices docker-compose up -d mysql redis nacos seata rocketmq<\/p>\n

                                3. \u5bfc\u5165\u6570\u636e\u5e93<\/h2>\n

                                mysql -uroot -p < sql\/init.sql<\/p>\n

                                4. \u542f\u52a8\u670d\u52a1<\/h2>\n

                                \u65b9\u5f0f1：IDEA\u4e2d\u9010\u4e2a\u542f\u52a8<\/h2>\n

                                \u65b9\u5f0f2：\u4f7f\u7528Maven<\/h2>\n

                                mvn spring-boot:run -pl e-commerce-parent\/e-commerce-user mvn spring-boot:run -pl e-commerce-parent\/e-commerce-product<\/p>\n

                                \u2026<\/h2>\n

                                5. \u8bbf\u95ee\u7cfb\u7edf<\/h2>\n

                                \u7f51\u5173：http:\/\/localhost:8080<\/h2>\n

                                Nacos：http:\/\/localhost:8848\/nacos (nacos\/nacos)<\/h2>\n

                                Grafana：http:\/\/localhost:3000 (admin\/admin123)<\/h2>\n

                                10.2 \u5b66\u4e60\u8def\u7ebf\u56fe 30\u5929\u5b66\u4e60\u8ba1\u5212：<\/p>\n

                                text \u7b2c1\u5468：Spring Cloud\u57fa\u7840 Day1-2：Nacos\u670d\u52a1\u6ce8\u518c\u4e0e\u53d1\u73b0 Day3-4：OpenFeign\u670d\u52a1\u8c03\u7528 Day5-6：Spring Cloud Gateway Day7：\u9879\u76ee\u642d\u5efa\u4e0e\u8c03\u8bd5<\/p>\n

                                \u7b2c2\u5468：\u6838\u5fc3\u4e1a\u52a1\u5f00\u53d1 Day8-9：\u7528\u6237\u670d\u52a1\u5b9e\u73b0 Day10-11：\u5546\u54c1\u670d\u52a1\u5b9e\u73b0 Day12-13：\u8ba2\u5355\u670d\u52a1\u5b9e\u73b0 Day14：\u652f\u4ed8\u670d\u52a1\u5b9e\u73b0<\/p>\n

                                \u7b2c3\u5468：\u9ad8\u7ea7\u7279\u6027 Day15：\u5206\u5e03\u5f0f\u4e8b\u52a1Seata Day16：\u6d88\u606f\u961f\u5217RocketMQ Day17：\u7f13\u5b58\u4e0e\u5206\u5e03\u5f0f\u9501 Day18：\u76d1\u63a7\u4e0e\u94fe\u8def\u8ffd\u8e2a Day19：\u5b89\u5168\u4e0e\u8ba4\u8bc1 Day20：\u6027\u80fd\u4f18\u5316<\/p>\n

                                \u7b2c4\u5468：\u90e8\u7f72\u4e0e\u8fd0\u7ef4 Day21-22：Docker\u5bb9\u5668\u5316 Day23-24：Kubernetes\u90e8\u7f72 Day25-26：CI\/CD\u6d41\u6c34\u7ebf Day27-28：\u538b\u529b\u6d4b\u8bd5\u4e0e\u8c03\u4f18 Day29-30：\u9879\u76ee\u603b\u7ed3\u4e0e\u9762\u8bd5\u51c6\u5907 10.3 \u5e38\u89c1\u95ee\u9898\u89e3\u7b54 Q1：\u9879\u76ee\u542f\u52a8\u62a5\u9519\u600e\u4e48\u529e？<\/p>\n

                                text A：\u5e38\u89c1\u95ee\u9898\u6392\u67e5：<\/p>\n

                              • \u68c0\u67e5Java\u7248\u672c（\u9700\u8981Java 17+）<\/li>\n
                              • \u68c0\u67e5MySQL\u3001Redis\u3001Nacos\u662f\u5426\u542f\u52a8<\/li>\n
                              • \u68c0\u67e5\u6570\u636e\u5e93\u8fde\u63a5\u914d\u7f6e<\/li>\n
                              • \u68c0\u67e5\u4f9d\u8d56\u662f\u5426\u4e0b\u8f7d\u5b8c\u6574<\/li>\n
                              • \u67e5\u770b\u65e5\u5fd7\u6587\u4ef6\u5b9a\u4f4d\u95ee\u9898 Q2：\u5982\u4f55\u4fee\u6539\u914d\u7f6e？<\/li>\n

                                text A：\u914d\u7f6e\u4fee\u6539\u4f4d\u7f6e：<\/p>\n

                              • \u516c\u5171\u914d\u7f6e：config\/\u76ee\u5f55\u4e0b<\/li>\n
                              • \u670d\u52a1\u914d\u7f6e：bootstrap.yml + application.yml<\/li>\n
                              • \u73af\u5883\u914d\u7f6e：\u901a\u8fc7profile\u5207\u6362<\/li>\n
                              • \u8fd0\u884c\u65f6\u914d\u7f6e：\u901a\u8fc7Nacos\u52a8\u6001\u914d\u7f6e Q3：\u5982\u4f55\u6269\u5c55\u65b0\u529f\u80fd？<\/li>\n

                                text A：\u6269\u5c55\u6b65\u9aa4：<\/p>\n

                              • \u5728\u7236\u5de5\u7a0b\u4e2d\u521b\u5efa\u65b0\u6a21\u5757<\/li>\n
                              • \u7ee7\u627f\u516c\u5171\u6a21\u5757\u4f9d\u8d56<\/li>\n
                              • \u5b9e\u73b0\u4e1a\u52a1\u903b\u8f91<\/li>\n
                              • \u6ce8\u518c\u5230Nacos<\/li>\n
                              • \u5728\u7f51\u5173\u914d\u7f6e\u8def\u7531<\/li>\n
                              • \u66f4\u65b0\u90e8\u7f72\u914d\u7f6e \u7ed3\u8bed：\u4ece\u5b66\u4e60\u8005\u5230\u67b6\u6784\u5e08\u7684\u8715\u53d8 \u606d\u559c\u4f60\u5b8c\u6210\u4e86\u8fd9\u4e2a\u5b8c\u6574\u7684\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u9879\u76ee！\u8fd9\u4e0d\u4ec5\u4ec5\u662f\u4e00\u4e2a\u6280\u672f\u9879\u76ee，\u66f4\u662f\u4f60\u6280\u672f\u6210\u957f\u7684\u91cd\u8981\u91cc\u7a0b\u7891\u3002<\/li>\n

                                \u5173\u952e\u6536\u83b7：<\/p>\n

                                \u2705 \u638c\u63e1\u4e86\u4f01\u4e1a\u7ea7\u5fae\u670d\u52a1\u67b6\u6784\u8bbe\u8ba1<\/p>\n

                                \u2705 \u7406\u89e3\u4e86\u5206\u5e03\u5f0f\u7cfb\u7edf\u6838\u5fc3\u6982\u5ff5<\/p>\n

                                \u2705 \u79ef\u7d2f\u4e86\u5b8c\u6574\u7684\u9879\u76ee\u5f00\u53d1\u7ecf\u9a8c<\/p>\n

                                \u2705 \u5177\u5907\u4e86\u89e3\u51b3\u590d\u6742\u95ee\u9898\u7684\u80fd\u529b<\/p>\n

                                \u2705 \u5efa\u7acb\u4e86\u6280\u672f\u81ea\u4fe1\u548c\u5b66\u4e60\u65b9\u6cd5<\/p>\n

                                \u8bb0\u4f4f：<\/p>\n

                                \u6280\u672f\u7684\u5b66\u4e60\u6c38\u65e0\u6b62\u5883，\u4f46\u6bcf\u4e2a\u5b8c\u6574\u7684\u9879\u76ee\u90fd\u662f\u4f60\u804c\u4e1a\u751f\u6daf\u7684\u575a\u5b9e\u57fa\u77f3\u3002 \u4ece\u4eca\u5929\u8d77，\u4f60\u4e0d\u518d\u53ea\u662f\u6280\u672f\u7684\u4f7f\u7528\u8005，\u800c\u662f\u67b6\u6784\u7684\u8bbe\u8ba1\u8005\u3002<\/p>\n

                                \u4e0b\u4e00\u6b65\u884c\u52a8：<\/p>\n

                                \u8fd0\u884c\u9879\u76ee：\u786e\u4fdd\u6240\u6709\u670d\u52a1\u6b63\u5e38\u8fd0\u884c<\/p>\n

                                \u6df1\u5165\u7814\u7a76：\u9009\u62e9\u611f\u5174\u8da3\u7684\u90e8\u5206\u6df1\u5165\u6e90\u7801<\/p>\n

                                \u5206\u4eab\u7ecf\u9a8c：\u5199\u535a\u5ba2\u3001\u505a\u5206\u4eab\u3001\u5e2e\u52a9\u4ed6\u4eba<\/p>\n

                                \u53c2\u4e0e\u5f00\u6e90：\u8d21\u732e\u4ee3\u7801，\u52a0\u5165\u6280\u672f\u793e\u533a<\/p>\n

                                \u6301\u7eed\u5b66\u4e60：\u5173\u6ce8\u65b0\u6280\u672f，\u4e0d\u65ad\u66f4\u65b0\u77e5\u8bc6\u4f53\u7cfb<\/p>\n

                                \u7279\u522b\u798f\u5229： \u5173\u6ce8\u6211\u5e76\u79c1\u4fe1"\u7535\u5546\u5fae\u670d\u52a1"，\u83b7\u53d6：<\/p>\n

                                \u672c\u6587\u5b8c\u6574Markdown\u7248\u672c<\/p>\n

                                \u9879\u76eePPT\u6f14\u793a\u6587\u7a3f<\/p>\n

                                \u9762\u8bd5\u5e38\u89c1\u95ee\u9898\u53ca\u7b54\u6848<\/p>\n

                                \u6269\u5c55\u529f\u80fd\u5b9e\u73b0\u4ee3\u7801<\/p>\n

                                \u5b66\u4e60\u793e\u7fa4\u9080\u8bf7<\/p>\n

                                \u4eca\u65e5\u6253\u5361\u4efb\u52a1：<\/p>\n

                                👍 \u70b9\u8d5e\u672c\u6587，\u652f\u6301\u539f\u521b<\/p>\n

                                💾 \u6536\u85cf\u672c\u6587，\u65b9\u4fbf\u67e5\u9605<\/p>\n

                                🚀 \u8fd0\u884c\u9879\u76ee，\u5728\u8bc4\u8bba\u533a\u5206\u4eab\u622a\u56fe<\/p>\n

                                👨\u200d💻 \u5173\u6ce8\u6211，\u83b7\u53d6\u66f4\u591a\u5b9e\u6218\u6559\u7a0b<\/p>\n

                                \u5728\u8bc4\u8bba\u533a\u544a\u8bc9\u6211：<\/p>\n

                                \u4f60\u5728\u5b9e\u73b0\u8fc7\u7a0b\u4e2d\u6700\u5927\u7684\u6536\u83b7\u662f\u4ec0\u4e48？<\/p>\n

                                \u8fd8\u5e0c\u671b\u5b66\u4e60\u4ec0\u4e48\u7c7b\u578b\u7684\u9879\u76ee？<\/p>\n

                                \u5bf9\u7535\u5546\u7cfb\u7edf\u6709\u4ec0\u4e48\u6539\u8fdb\u5efa\u8bae？<\/p>\n

                                \u8ba9\u6211\u4eec\u4e00\u8d77\u5728\u6280\u672f\u7684\u9053\u8def\u4e0a\u4e0d\u65ad\u524d\u884c！ 🚀🔥<\/p>\n

                                \u4e0b\u671f\u9884\u544a： \u300a\u4ebf\u7ea7\u6d41\u91cf\u7535\u5546\u7cfb\u7edf\u67b6\u6784\u8bbe\u8ba1\u4e0e\u5b9e\u8df5\u300b<\/p>\n

                                \u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u7684\u67b6\u6784\u4f18\u5316<\/p>\n

                                \u6570\u636e\u5e93\u5206\u5e93\u5206\u8868\u5b9e\u6218<\/p>\n

                                \u7f13\u5b58\u7a7f\u900f\u3001\u96ea\u5d29\u3001\u51fb\u7a7f\u89e3\u51b3\u65b9\u6848<\/p>\n

                                \u5168\u94fe\u8def\u538b\u6d4b\u4e0e\u6027\u80fd\u4f18\u5316<\/p>\n

                                \u5bb9\u707e\u4e0e\u591a\u6d3b\u67b6\u6784\u8bbe\u8ba1<\/p>\n

                                \u5173\u6ce8\u6211，\u4e0d\u9519\u8fc7\u6bcf\u4e00\u7bc7\u7cbe\u54c1\u6559\u7a0b！ 💪<\/p>\n","protected":false},"excerpt":{"rendered":"

                                \u7b2c\u4e00\u7ae0：\u9879\u76ee\u67b6\u6784\u8bbe\u8ba1\u4e0e\u6280\u672f\u9009\u578b
                                \n1.1 \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u5206\u6790 \u4f20\u7edf\u5355\u4f53\u7535\u5546\u7cfb\u7edf\u7684\u75db\u70b9：
                                \njava \/\/ \u4f20\u7edf\u5355\u4f53\u7535\u5546\u67b6\u6784\u7684\u95ee\u9898 \u5355\u70b9\u6545\u969c：\u5546\u54c1\u670d\u52a1\u5d29\u6e83 \u2192 \u6574\u4e2a\u7f51\u7ad9\u4e0d\u53ef\u7528 \u6280\u672f\u6808\u56fa\u5316：\u6240\u6709\u6a21\u5757\u5fc5\u987b\u4f7f\u7528\u76f8\u540c\u6280\u672f \u6269\u5c55\u56f0\u96be：\u4fc3\u9500\u65f6\u53ea\u80fd\u6574\u4f53\u6269\u5bb9 \u53d1\u5e03\u98ce\u9669：\u5c0f\u6539\u52a8\u9700\u8981\u5168\u7ad9\u53d1\u5e03 \u56e2\u961f\u534f\u4f5c：\u4ee3\u7801\u51b2\u7a81\u3001\u6c9f\u901a\u6210\u672c\u9ad8
                                \n\/\/ \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b： \u7528\u6237\u6d4f\u89c8 \u2192 \u52a0\u5165\u8d2d\u7269\u8f66 \u2192 <\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[101,963,1348],"topic":[],"class_list":["post-64307","post","type-post","status-publish","format-standard","hentry","category-server","tag-spring","tag-spring-cloud","tag-1348"],"yoast_head":"\nSpring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/64307.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u7b2c\u4e00\u7ae0：\u9879\u76ee\u67b6\u6784\u8bbe\u8ba1\u4e0e\u6280\u672f\u9009\u578b 1.1 \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u5206\u6790 \u4f20\u7edf\u5355\u4f53\u7535\u5546\u7cfb\u7edf\u7684\u75db\u70b9： java \/\/ \u4f20\u7edf\u5355\u4f53\u7535\u5546\u67b6\u6784\u7684\u95ee\u9898 \u5355\u70b9\u6545\u969c：\u5546\u54c1\u670d\u52a1\u5d29\u6e83 \u2192 \u6574\u4e2a\u7f51\u7ad9\u4e0d\u53ef\u7528 \u6280\u672f\u6808\u56fa\u5316：\u6240\u6709\u6a21\u5757\u5fc5\u987b\u4f7f\u7528\u76f8\u540c\u6280\u672f \u6269\u5c55\u56f0\u96be：\u4fc3\u9500\u65f6\u53ea\u80fd\u6574\u4f53\u6269\u5bb9 \u53d1\u5e03\u98ce\u9669：\u5c0f\u6539\u52a8\u9700\u8981\u5168\u7ad9\u53d1\u5e03 \u56e2\u961f\u534f\u4f5c：\u4ee3\u7801\u51b2\u7a81\u3001\u6c9f\u901a\u6210\u672c\u9ad8 \/\/ \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b： \u7528\u6237\u6d4f\u89c8 \u2192 \u52a0\u5165\u8d2d\u7269\u8f66 \u2192\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/64307.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-01-23T02:24:26+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"59 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/64307.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/64307.html\",\"name\":\"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-01-23T02:24:26+00:00\",\"dateModified\":\"2026-01-23T02:24:26+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/64307.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/64307.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/64307.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/64307.html","og_locale":"zh_CN","og_type":"article","og_title":"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u7b2c\u4e00\u7ae0：\u9879\u76ee\u67b6\u6784\u8bbe\u8ba1\u4e0e\u6280\u672f\u9009\u578b 1.1 \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u5206\u6790 \u4f20\u7edf\u5355\u4f53\u7535\u5546\u7cfb\u7edf\u7684\u75db\u70b9： java \/\/ \u4f20\u7edf\u5355\u4f53\u7535\u5546\u67b6\u6784\u7684\u95ee\u9898 \u5355\u70b9\u6545\u969c：\u5546\u54c1\u670d\u52a1\u5d29\u6e83 \u2192 \u6574\u4e2a\u7f51\u7ad9\u4e0d\u53ef\u7528 \u6280\u672f\u6808\u56fa\u5316：\u6240\u6709\u6a21\u5757\u5fc5\u987b\u4f7f\u7528\u76f8\u540c\u6280\u672f \u6269\u5c55\u56f0\u96be：\u4fc3\u9500\u65f6\u53ea\u80fd\u6574\u4f53\u6269\u5bb9 \u53d1\u5e03\u98ce\u9669：\u5c0f\u6539\u52a8\u9700\u8981\u5168\u7ad9\u53d1\u5e03 \u56e2\u961f\u534f\u4f5c：\u4ee3\u7801\u51b2\u7a81\u3001\u6c9f\u901a\u6210\u672c\u9ad8 \/\/ \u7535\u5546\u7cfb\u7edf\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b： \u7528\u6237\u6d4f\u89c8 \u2192 \u52a0\u5165\u8d2d\u7269\u8f66 \u2192","og_url":"https:\/\/www.wsisp.com\/helps\/64307.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-01-23T02:24:26+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"59 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/64307.html","url":"https:\/\/www.wsisp.com\/helps\/64307.html","name":"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-01-23T02:24:26+00:00","dateModified":"2026-01-23T02:24:26+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/64307.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/64307.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/64307.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"Spring Cloud\u5b9e\u6218\uff1a\u7535\u5546\u5fae\u670d\u52a1\u7cfb\u7edf\u4ece0\u52301\uff0825000\u5b57\u7ec8\u6781\u5b9e\u6218\u6307\u5357\uff09"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/64307","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=64307"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/64307\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=64307"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=64307"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=64307"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=64307"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}