完成学习事务

javamemories-gateway/pom.xml

@@ -43,5 +43,16 @@
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
+        </dependency>
+
+        <!-- Sentinel 网关适配依赖（关键） -->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
+        </dependency>
     </dependencies>
 </project>

javamemories-gateway/src/main/java/cn/mayiming/Config/SentinelDegradeConfig.java

@@ -0,0 +1,40 @@
+package cn.mayiming.Config;
+
+import com.alibaba.csp.sentinel.slots.block.RuleConstant;
+import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
+import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
+import com.alibaba.csp.sentinel.slots.block.degrade.circuitbreaker.CircuitBreakerStrategy;
+import jakarta.annotation.PostConstruct;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Sentinel 熔断规则配置
+ * 为下游服务配置熔断策略
+ */
+@Configuration
+public class SentinelDegradeConfig {
+
+    /**
+     * 初始化熔断规则
+     * @PostConstruct：Spring 容器启动后执行
+     */
+    @PostConstruct
+    public void initDegradeRules() {
+        List<DegradeRule> rules = new ArrayList<>();
+
+        DegradeRule orderServiceRule = new DegradeRule();
+        orderServiceRule.setResource("order-service"); // 网关路由ID/服务名
+        // 关键：改为慢请求比例触发熔断
+
+        orderServiceRule.setCount(3000); // 慢请求阈值：3000毫秒（3秒），超过3秒即为慢请求
+        orderServiceRule.setSlowRatioThreshold(0.5); // 慢请求比例阈值：50%（超过50%的请求是慢请求则触发熔断）
+        orderServiceRule.setTimeWindow(10); // 熔断后保持打开状态10秒
+        orderServiceRule.setMinRequestAmount(5); // 最小请求数：累计5次请求后才计算慢请求比例
+
+        rules.add(orderServiceRule);
+        DegradeRuleManager.loadRules(rules);
+    }
+}

javamemories-gateway/src/main/resources/application.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8080
+  port: 8081
 
 spring:
   application:
@@ -44,6 +44,21 @@ spring:
                 # 按 IP 限流（默认）
                 key-resolver: "#{@ipKeyResolver}"
 
+    sentinel:
+      # Sentinel 控制台地址（如果启动了控制台，用于可视化配置）
+      transport:
+        dashboard: localhost:8080  # Sentinel 控制台端口，默认8080
+        port: 8719                 # 客户端和控制台通信的端口
+      # 网关熔断配置
+      gateway:
+        enabled: true              # 开启 Sentinel 网关适配
+        # 熔断后默认的降级响应
+        fallback:
+          mode: response           # 降级方式：返回自定义响应
+          response-status: 503     # 降级响应状态码
+          response-body: "{\"code\":503,\"msg\":\"服务暂时不可用，请稍后重试\",\"data\":null}"  # 降级响应体
+          response-content-type: application/json
+
     # Nacos 注册
     nacos:
       discovery:

order-service/pom.xml

@@ -42,5 +42,41 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-loadbalancer</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.alibaba.csp</groupId>
+            <artifactId>sentinel-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis</artifactId>
+            <version>3.5.19</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis-spring</artifactId>
+            <version>4.0.0</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+
+        </dependency>
+
+        <dependency>
+            <groupId>com.mysql</groupId>
+            <artifactId>mysql-connector-j</artifactId>
+            <scope>runtime</scope>
+        </dependency>
     </dependencies>
 </project>

order-service/src/main/java/cn/mayiming/App.java

@@ -1,5 +1,6 @@
 package cn.mayiming;
 
+import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.openfeign.EnableFeignClients;
@@ -10,6 +11,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
  */
 @SpringBootApplication
 @EnableFeignClients
+@MapperScan("cn.mayiming.Mapper")
 public class App 
 {
     public static void main( String[] args )

order-service/src/main/java/cn/mayiming/Controller/OrderController.java

@@ -2,11 +2,13 @@ package cn.mayiming.Controller;
 
 
 import cn.mayiming.Service.OrderService;
+import cn.mayiming.entity.Order;
 import cn.mayiming.entity.User;
+import com.alibaba.csp.sentinel.annotation.SentinelResource;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestBody;
+
-import org.springframework.web.bind.annotation.RestController;
+import java.util.List;
 
 @RestController
 public class OrderController {
@@ -15,7 +17,13 @@ public class OrderController {
     private OrderService orderService;
 
     @PostMapping("/order")
-    public User getOrder(@RequestBody User user){
+    public User getUserOrder(@RequestBody User user){
+        //throw new RuntimeException("Cuowu ");
         return orderService.SearchUserbyname(user);
     }
+
+    @GetMapping("/order")
+    public List<Order> getUserOrder(@RequestParam Integer id){
+        return orderService.OrderListById(id);
+    }
 }

order-service/src/main/java/cn/mayiming/Mapper/OrderMapper.java

@@ -0,0 +1,33 @@
+package cn.mayiming.Mapper;
+
+
+import cn.mayiming.entity.Order;
+import feign.Param;
+import org.apache.ibatis.annotations.Select;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface OrderMapper {
+
+    /**
+     * 根据用户ID查询所有订单
+     * @param userId 用户ID（@Param 注解解决参数名绑定问题）
+     * @return 该用户的所有订单列表（按创建时间倒序）
+     */
+    @Select("SELECT id, " +
+            "order_no AS orderNo, " +
+            "user_id AS userId, " +
+            "product_name AS productName, " +
+            "product_price AS productPrice, " +
+            "count, " +
+            "total_amount AS totalAmount, " +
+            "status, " +
+            "create_time AS createTime, " +
+            "update_time AS updateTime " +
+            "FROM t_order " +
+            "WHERE user_id = #{userId} " +
+            "ORDER BY create_time DESC")
+    List<Order> selectByUserId(@Param("userId") Integer userId);
+}

order-service/src/main/java/cn/mayiming/Service/OrderService.java

@@ -1,17 +1,34 @@
 package cn.mayiming.Service;
 
+import cn.mayiming.Mapper.OrderMapper;
+import cn.mayiming.entity.Order;
 import cn.mayiming.entity.User;
 import cn.mayiming.feign.UserFeignClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 @Service
 public class OrderService {
     @Autowired
     private UserFeignClient userFeignClient;
 
+    @Autowired
+    private OrderMapper orderMapper;
+
     public User SearchUserbyname (User user) {
         return userFeignClient.selectByUsername(user);
     }
 
+    public List<Order> OrderListById(Integer id) {
+        User user = userFeignClient.GetUserByid(id);
+
+        if(user == null) {
+            throw new RuntimeException("错误！");
+        }
+        return orderMapper.selectByUserId(id);
+
+    }
+
 }

order-service/src/main/java/cn/mayiming/entity/Order.java

@@ -0,0 +1,54 @@
+package cn.mayiming.entity;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Data // Lombok 注解，自动生成get/set/toString
+public class Order {
+    /** 订单ID */
+    private Long id;
+    /** 订单编号 */
+    private String orderNo;
+    /** 关联用户ID */
+    private Integer userId;
+    /** 商品名称 */
+    private String productName;
+    /** 商品单价 */
+    private BigDecimal productPrice;
+    /** 购买数量 */
+    private Integer count;
+    /** 订单总金额 */
+    private BigDecimal totalAmount;
+    /** 订单状态：0-待支付 1-已支付 2-已取消 3-已完成 */
+    private Integer status;
+    /** 创建时间 */
+    private Date createTime;
+    /** 更新时间 */
+    private Date updateTime;
+
+    // 可选：添加状态枚举，避免硬编码数字
+    public enum OrderStatus {
+        PENDING_PAYMENT(0, "待支付"),
+        PAID(1, "已支付"),
+        CANCELLED(2, "已取消"),
+        COMPLETED(3, "已完成");
+
+        private final int code;
+        private final String desc;
+
+        OrderStatus(int code, String desc) {
+            this.code = code;
+            this.desc = desc;
+        }
+
+        public int getCode() {
+            return code;
+        }
+
+        public String getDesc() {
+            return desc;
+        }
+    }
+}

order-service/src/main/java/cn/mayiming/feign/UserFeignClient.java

@@ -3,10 +3,16 @@ package cn.mayiming.feign;
 import cn.mayiming.entity.User;
 import feign.Param;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 
 @FeignClient(name = "user-service")
 public interface UserFeignClient {
     @PostMapping("/user")
     User selectByUsername(User user);
+
+    @GetMapping("/user")
+    User GetUserByid(@RequestParam("id") Integer id);
+
 }

order-service/src/main/resources/application.yml

@@ -19,3 +19,23 @@ spring:
         group: DEFAULT_GROUP
   config:
     import: nacos:${spring.application.name}.${spring.cloud.nacos.config.file-extension}?server-addr=${spring.cloud.nacos.config.server-addr}
+
+  datasource:
+    # 数据库驱动类（MySQL 8.x 用 com.mysql.cj.jdbc.Driver，5.x 用 com.mysql.jdbc.Driver）
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    # 数据库连接 URL（替换为你的数据库地址、端口、库名，如 user_db）
+    url: jdbc:mysql://rm-f8z6oc5a03331500p8o.mysql.rds.aliyuncs.com:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
+    # 数据库用户名（默认 root，根据实际情况修改）
+    username: root
+    # 数据库密码（替换为你的 MySQL 密码）
+    password: Root123456
+    # 可选：连接池配置（推荐使用 HikariCP，Spring Boot 2.x 默认）
+    hikari:
+      # 连接池最大连接数
+      maximum-pool-size: 10
+      # 连接池最小空闲连接数
+      minimum-idle: 2
+      # 连接超时时间（毫秒）
+      connection-timeout: 30000
+      # 连接最大存活时间（毫秒）
+      max-lifetime: 1800000

request-test/src/main/java/cn/mayiming/App.java

@@ -20,7 +20,7 @@ public class App
     // 请求体JSON数据
     private static final String REQUEST_BODY = "{\"username\":\"admin\"}";
     // 总请求次数
-    private static final int TOTAL_REQUESTS = 30;
+    private static final int TOTAL_REQUESTS = 50;
 
     public static void main(String[] args) {
         // 1. 创建HttpClient实例（设置超时时间10秒）

user-service/src/main/java/cn/mayiming/App.java

@@ -4,6 +4,7 @@ package cn.mayiming;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 /**
  * Hello world!
@@ -12,6 +13,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
 @MapperScan("cn.mayiming.Mapper")
+@EnableTransactionManagement
 public class App 
 {
     public static void main( String[] args )

user-service/src/main/java/cn/mayiming/Controller/UserController.java

@@ -4,18 +4,26 @@ import cn.mayiming.Mapper.UserMapper;
 import cn.mayiming.Service.UserService;
 import cn.mayiming.entity.User;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 public class UserController {
 
     @Autowired
-    private UserMapper userMapper;
+    private UserService userService;
 
     @PostMapping("/user")
     public User getUser(@RequestBody User user) {
-        return userMapper.selectByUsername(user.getUsername());
+        return userService.getUserByUsername(user.getUsername());
+    }
+
+    @PutMapping("/user")
+    public int updateUser(@RequestBody User user) {
+        return userService.updateUser(user);
+    }
+
+    @GetMapping("/user")
+    public User GetUserByid(@RequestParam Integer id) {
+        return userService.getUserById(id);
     }
 }

user-service/src/main/java/cn/mayiming/Mapper/UserMapper.java

@@ -40,11 +40,17 @@ public interface UserMapper {
      * @param user 用户对象（含要更新的字段）
      * @return 影响行数
      */
-    @Update("UPDATE user SET " +
+    @Update({
-            "username = #{username}, " +
+            "<script>",
-            "password = #{password}, " +
+            "UPDATE user",
-            "nickname = #{nickname} " +
+            "<set>",
-            "WHERE id = #{id}")
+            "   <if test='username != null'>username = #{username},</if>",
+            "   <if test='password != null'>password = #{password},</if>",
+            "   <if test='nickname != null'>nickname = #{nickname}</if>",
+            "</set>",
+            "WHERE id = #{id}",
+            "</script>"
+    })
     int updateById(User user);
 
     /**

user-service/src/main/java/cn/mayiming/Service/UserService.java

@@ -2,8 +2,10 @@ package cn.mayiming.Service;
 
 import cn.mayiming.Mapper.UserMapper;
 import cn.mayiming.entity.User;
+import org.apache.ibatis.jdbc.Null;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 
@@ -21,6 +23,7 @@ public class UserService {
         return rows;
     }
 
+
     // 根据用户名查询
     public User getUserByUsername(String username) {
         return userMapper.selectByUsername(username);
@@ -30,4 +33,16 @@ public class UserService {
     public List<User> getAllUsers() {
         return userMapper.selectAll();
     }
+
+    public User getUserById(Integer id) {
+        return userMapper.selectById(id);
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public int updateUser(User user) {
+        if (user.getId() == null){
+            throw new IllegalArgumentException("更新失败：用户ID不能为空");
+        }
+        return userMapper.updateById(user);
+    }
 }

user-service/src/main/java/cn/mayiming/entity/User.java

@@ -19,4 +19,24 @@ public class User {
 
     String username;
     String password;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    Integer id;
+
+    public String getNickname() {
+        return nickname;
+    }
+
+    public void setNickname(String nickname) {
+        this.nickname = nickname;
+    }
+
+    String nickname;
 }