【基础架构】刚果商城(congomall)

**基础架构**

**一、项目背景**

Congomall是基于Spring Boot开发的电商平台，旨在为用户提供一个安全、便捷的购物体验。该系统将包含商品展示、订单管理、支付处理等功能。

**二、技术选型**

1. **框架**: Spring Boot2. **数据库**: MySQL3. **缓存**: Redis4. **消息队列**: RabbitMQ5. **安全**: OAuth2**三、系统设计**

###3.1 模块划分* **商品模块**: 负责商品的展示和管理。
* **订单模块**: 负责订单的创建、支付处理和状态更新。
* **用户模块**: 负责用户的注册、登录和信息管理。

###3.2 系统流程1. **用户注册**:
* 用户填写注册信息并提交。
* 系统验证注册信息，若正确则创建新用户。
2. **商品展示**:
* 系统从数据库中获取商品信息。
* 将商品信息渲染到页面上。
3. **订单创建**:
* 用户选择商品并添加到购物车中。
* 用户点击结算按钮，系统创建新订单。
4. **支付处理**:
* 系统将订单信息传递给支付平台。
* 支付平台处理支付请求，并返回结果。

###3.3 数据库设计####3.3.1 商品表| 字段名 | 类型 | 描述 |
| --- | --- | --- |
| id | int | 主键 |
| name | varchar(255) | 商品名称 |
| price | decimal(10,2) | 商品价格 |

####3.3.2 订单表| 字段名 | 类型 | 描述 |
| --- | --- | --- |
| id | int | 主键 |
| user_id | int | 用户ID |
| order_date | datetime | 订单创建时间 |
| total_price | decimal(10,2) | 订单总金额 |

####3.3.3 支付表| 字段名 | 类型 | 描述 |
| --- | --- | --- |
| id | int | 主键 |
| order_id | int | 订单ID |
| payment_date | datetime | 支付时间 |
| status | varchar(255) | 支付状态 |

###3.4 缓存设计* **商品缓存**: 将商品信息缓存到Redis中，key为商品id。
* **订单缓存**: 将订单信息缓存到Redis中，key为订单id。

###3.5 消息队列设计* **支付消息队列**: 将支付请求传递给RabbitMQ消息队列。
* **支付结果回调**: 将支付结果回调给系统。

## 四、代码示例###4.1 商品模块

java// GoodsController.java@RestController@RequestMapping("/goods")
public class GoodsController {
 @Autowired private GoodsService goodsService;

 @GetMapping("/{id}")
 public Result getGoods(@PathVariable Long id) {
 Goods goods = goodsService.getGoods(id);
 return Result.success(goods);
 }
}

// GoodsService.java@Servicepublic class GoodsService {
 @Autowired private GoodsDao goodsDao;

 public Goods getGoods(Long id) {
 return goodsDao.selectById(id);
 }
}

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

 @PostMapping public Result createOrder(@RequestBody CreateOrderRequest request) {
 Order order = orderService.createOrder(request);
 return Result.success(order);
 }
}

// OrderService.java@Servicepublic class OrderService {
 @Autowired private OrderDao orderDao;
 @Autowired private PaymentService paymentService;

 public Order createOrder(CreateOrderRequest request) {
 // ...
 paymentService.pay(request.getPayment());
 return orderDao.insert(order);
 }
}

java// RedisCache.java@Componentpublic class RedisCache {
 @Autowired private RedisTemplate redisTemplate;

 public void cacheGoods(Goods goods) {
 redisTemplate.opsForValue().set(goods.getId(), goods);
 }

 public Goods getGoods(Long id) {
 return (Goods) redisTemplate.opsForValue().get(id);
 }
}

java// PaymentController.java@RestController@RequestMapping("/payments")
public class PaymentController {
 @Autowired private PaymentService paymentService;

 @PostMapping public Result pay(@RequestBody PayRequest request) {
 Payment payment = paymentService.pay(request);
 return Result.success(payment);
 }
}

// PaymentService.java@Servicepublic class PaymentService {
 @Autowired private RabbitTemplate rabbitTemplate;

 public Payment pay(PayRequest request) {
 // ...
 rabbitTemplate.convertAndSend("payment_exchange", "payment_routing_key", payment);
 return payment;
 }
}

java// UserController.java@RestController@RequestMapping("/users")
public class UserController {
 @Autowired private UserService userService;

 @PostMapping public Result register(@RequestBody RegisterRequest request) {
 User user = userService.register(request);
 return Result.success(user);
 }

 @GetMapping public Result login(@RequestParam String username, @RequestParam String password) {
 User user = userService.login(username, password);
 return Result.success(user);
 }
}

// UserService.java@Servicepublic class UserService {
 @Autowired private UserRepository userRepository;

 public User register(RegisterRequest request) {
 // ...
 return userRepository.save(user);
 }

 public User login(String username, String password) {
 // ...
 return userRepository.findByUsernameAndPassword(username, password);
 }
}