zy123/hmall
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

5.27 分布式事务

Browse Source
This commit is contained in:
zhangsan 2025-05-27 20:43:25 +08:00
parent 08e52ae9c8
commit 8fe67b5ebd
13 changed files with 31 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cart-service/pom.xml
View File

@ -70,6 +70,11 @@
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!--seata-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>

2
cart-service/src/main/java/com/hmall/cart/service/impl/CartServiceImpl.java
View File

@ -18,6 +18,7 @@ import com.hmall.common.utils.CollUtils;
import com.hmall.common.utils.UserContext;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.Collection;
import java.util.List;
@ -105,6 +106,7 @@ public class CartServiceImpl extends ServiceImpl<CartMapper, Cart> implements IC
}
@Override
@Transactional
public void removeByItemIds(Collection<Long> itemIds) {
// 1.构建删除条件，userId和itemId
QueryWrapper<Cart> queryWrapper = new QueryWrapper<Cart>();

6
cart-service/src/main/resources/application.yaml
View File

@ -1,10 +1,6 @@
server:
port: 8082
tomcat:
threads:
max: 50
accept-count: 50
max-connections: 100
feign:
httpclient:
enabled: true # 使用 Apache HttpClient（默认关闭）

1
cart-service/src/main/resources/bootstrap.yaml
View File

@ -13,3 +13,4 @@ spring:
- dataId: shared_log.yaml # 共享日志配置
- dataId: shared_swagger.yaml # 共享日志配置
- dataId: shared_sentinel.yaml #共享sentinel控制台
- dataId: shared_seeta.yaml

2
hm-api/src/main/java/com/hmall/api/client/ItemClient.java
View File

@ -12,7 +12,7 @@ import org.springframework.web.bind.annotation.RequestParam;
import java.util.Collection;
import java.util.List;
@FeignClient(value = "item-service",fallbackFactory = ItemClientFallbackFactory.class)
@FeignClient(value = "item-service",fallbackFactory = ItemClientFallbackFactory.class)
public interface ItemClient {
@GetMapping("/items")

1
hm-api/src/main/java/com/hmall/api/client/fallback/ItemClientFallbackFactory.java
View File

@ -26,6 +26,7 @@ public class ItemClientFallbackFactory implements FallbackFactory<ItemClient> {
@Override
public void deductStock(List<OrderDetailDTO> items) {
// 库存扣减业务需要触发事务回滚，查询失败，抛出异常
log.error("[ITEM-FALLBACK] deductStock 降级，原因：", cause);
throw new BizIllegalException(cause);
}
};

5
item-service/pom.xml
View File

@ -68,6 +68,11 @@
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!--seata-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>

2
item-service/src/main/java/com/hmall/item/controller/ItemController.java
View File

@ -36,7 +36,7 @@ public class ItemController {
@GetMapping
public List<ItemDTO> queryItemByIds(@RequestParam("ids") List<Long> ids){
//模拟线程延迟
ThreadUtil.sleep(500);
// ThreadUtil.sleep(500);
return itemService.queryItemByIds(ids);
}

2
item-service/src/main/java/com/hmall/item/service/impl/ItemServiceImpl.java
View File

@ -11,6 +11,7 @@ import com.hmall.item.domain.po.Item;
import com.hmall.item.mapper.ItemMapper;
import com.hmall.item.service.IItemService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.Collection;
import java.util.Collections;
@ -27,6 +28,7 @@ import java.util.List;
public class ItemServiceImpl extends ServiceImpl<ItemMapper, Item> implements IItemService {
@Override
@Transactional
public void deductStock(List<OrderDetailDTO> items) {
String sqlStatement = "com.hmall.item.mapper.ItemMapper.updateStock";
boolean r = false;

1
item-service/src/main/resources/bootstrap.yaml
View File

@ -13,3 +13,4 @@ spring:
- dataId: shared_log.yaml # 共享日志配置
- dataId: shared_swagger.yaml # 共享日志配置
- dataId: shared_sentinel.yaml #共享sentinel控制台
- dataId: shared_seeta.yaml

5
trade-service/pom.xml
View File

@ -68,6 +68,11 @@
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!--seata-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>

3
trade-service/src/main/java/com/hmall/trade/service/impl/OrderServiceImpl.java
View File

@ -15,6 +15,7 @@ import com.hmall.trade.domain.po.OrderDetail;
import com.hmall.trade.mapper.OrderMapper;
import com.hmall.trade.service.IOrderDetailService;
import com.hmall.trade.service.IOrderService;
import io.seata.spring.annotation.GlobalTransactional;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@ -43,7 +44,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
private final CartClient cartClient;
@Override
@Transactional
@GlobalTransactional
public Long createOrder(OrderFormDTO orderFormDTO) {
// 1.订单数据
Order order = new Order();

1
trade-service/src/main/resources/bootstrap.yaml
View File

@ -13,3 +13,4 @@ spring:
- dataId: shared_log.yaml # 共享日志配置
- dataId: shared_swagger.yaml # 共享日志配置
- dataId: shared_sentinel.yaml #共享sentinel控制台
- dataId: shared_seeta.yaml