springboot redis 实现 购物车

实现购物车可以使用 Redis 来存储购物车的数据，Spring Boot 中可以使用 Spring Data Redis 来操作 Redis。

首先，需要添加 Redis 相关的依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

然后，需要在配置文件中配置 Redis 的连接信息：

spring:
  redis:
    host: localhost
    port: 6379

接下来，定义一个购物车项的类：

public class CartItem {
    private Long productId;
    private Integer quantity;

    // getters and setters
}

然后，定义一个购物车的服务类：

@Service
public class CartService {
    private final RedisTemplate<String, CartItem> redisTemplate;

    public CartService(RedisTemplate<String, CartItem> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public void addItem(String userId, Long productId, Integer quantity) {
        String key = "cart:" + userId;
        CartItem cartItem = redisTemplate.opsForHash().get(key, productId);
        if (cartItem == null) {
            cartItem = new CartItem();
            cartItem.setProductId(productId);
            cartItem.setQuantity(quantity);
        } else {
            cartItem.setQuantity(cartItem.getQuantity() + quantity);
        }
        redisTemplate.opsForHash().put(key, productId, cartItem);
    }

    public void removeItem(String userId, Long productId) {
        String key = "cart:" + userId;
        redisTemplate.opsForHash().delete(key, productId);
    }

    public List<CartItem> getItems(String userId) {
        String key = "cart:" + userId;
        Map<Object, Object> entries = redisTemplate.opsForHash().entries(key);
        List<CartItem> items = new ArrayList<>(entries.size());
        for (Map.Entry<Object, Object> entry : entries.entrySet()) {
            CartItem cartItem = (CartItem) entry.getValue();
            items.add(cartItem);
        }
        return items;
    }
}

在这个购物车服务类中，我们使用 Redis 的 Hash 类型来存储购物车数据，其中键为用户 ID，值为一个 Hash，其中每个键值对表示一个购物车项。在 `addItem` 方法中，我们首先根据用户 ID 和商品 ID 获取原来的购物车项，如果购物车项不存在，则创建一个新的购物车项；否则，更新购物车项的数量。然后，使用 Redis 的 `opsForHash()` 方法将购物车项保存到 Redis 中。在 `removeItem` 方法中，我们使用 `opsForHash().delete()` 方法从 Redis 中删除购物车项。在 `getItems` 方法中，我们使用 `opsForHash().entries()` 方法获取购物车中所有的商品项，并将所有的购物车项转换成一个列表返回。

最后，我们可以在控制器中注入购物车服务类，然后调用其方法来实现购物车的增加、删除和查询：

@RestController
public class CartController {
    private final CartService cartService;

    public CartController(CartService cartService) {
        this.cartService = cartService;
    }

    @PostMapping("/cart")
    public void addItem(@RequestParam String userId,
                        @RequestParam Long productId,
                        @RequestParam Integer quantity) {
        cartService.addItem(userId, productId, quantity);
    }

    @DeleteMapping("/cart")
    public void removeItem(@RequestParam String userId,
                           @RequestParam Long productId) {
        cartService.removeItem(userId, productId);
    }

    @GetMapping("/cart")
    public List<CartItem> getItems(@RequestParam String userId) {
        return cartService.getItems(userId);
    }
}

这样，我们就可以使用 Redis 实现购物车了。