一、京东购物车多种场景分析

步骤1：先登录你的京东账号，查看购物车里商品。 （如有1件商品在购物车）

步骤2：先退出登录，再在无登录状态下的购物车中添加商品B，然后关闭浏览器再打开。

步骤3：再次登录你的京东账号。（购物车里已加入退出登录时加入购物车的商品，和登录时购物车商品进行了合并）

注：最近发现京东商城的购物车已经需要登录才能加入购物车了。

二、高并发的京东购物车技术实现

1. 登录状态下添加商品到购物车

1.添加购物车

2.写入redis

3.异步写入db

写入

登录状态

购物车服务

Redis

消息中间件MQ

DB

在高并发的情况下，登录用户添加购物车，购物车服务先把数据存储在redis，然后发消息给消息中间件，最后消费中间件的数据写入数据库。

这种高并发情况，就能保证所有的查询操作都能落在reids上，从而使数据平稳持久化到db。

2. 未登录状态下添加商品到购物车

1.添加购物车

2.写入redis

未登录状态

购物车服务

Redis

未登录用户添加购物车，购物车服务为该用户生成唯一id: cartId，并把该cartId作为key，把购物车的数据保存进redis(有效期3个月),最后购物车服务把该cartId回写进用户的cookies

这个环节不保存数据库了，因为没有对应的用户。以后用户每次添加商品都带上这个cartId就行，

3. 再登录状态合并

1.登录后合并购物车请求

2.合并写入db

3.刷新

再登录状态

购物车服务

DB

Redis

用户登录成功后，客户端把cookies里面的cartId和userId发给购物车系统，购物车系统通过cartId把redis未登录的数据合并插入到该userId的数据库里面。

最后重新刷新添加到登录userId的redis数据,删除未登录carId的redis数据。

三、购物车的redis经典场景

往购物车加入2件商品 采用hash数据结果，key=cart:user:用户id hash=《商品id，数量》

127.0.0.1:6379> hset cart:user:1000 101 1
(integer) 1
127.0.0.1:6379> hset cart:user:1000 102 1
(integer) 1
127.0.0.1:6379> hgetall cart:user:1000
1) "101"
2) "1"
3) "102"
4) "1"
复制代码

修改购物车的数据，为某件商品添加数量

127.0.0.1:6379> hincrby cart:user:1000 101 1
(integer) 2
127.0.0.1:6379> hincrby cart:user:1000 102 10
(integer) 11
127.0.0.1:6379> hgetall cart:user:1000
1) "101"
2) "2"
3) "102"
4) "11"
复制代码

统计购物车有多少件商品

127.0.0.1:6379> hlen cart:user:1000
(integer) 2
复制代码

删除购物车某件商品

127.0.0.1:6379> hdel cart:user:1000 102
(integer) 1
127.0.0.1:6379> hgetall cart:user:1000
1) "101"
2) "2"
复制代码

四、案例实战

SpringBoot+Redis+Cookies实现高并发的购物车

未登录购物车实体类
@Data
public class CookieCart {
     //商品id
    private Long productId;
    //商品数量
    private int amount;

}
复制代码

登录购物车实体类

@Data
public class Cart {

    private Long userId;
    //商品id
    private Long productId;
    //商品数量
    private int amount;

}
复制代码

业务类

    /**
     * 未登录
     * 添加购物车
     */
    @PostMapping(value = "/addCart")
    public void addCart(CookieCart obj) {
        //获取一个Cookies的cardId
        String cartId=this.getCookiesCartId();
        String key=COOKIE_KEY+cartId;
        Boolean hasKey = redisTemplate.opsForHash().getOperations().hasKey(key);
        //存在
        if(hasKey){
            //保存key为购物车，hash的key为商品id，value为数量
            this.redisTemplate.opsForHash().put(key, obj.getProductId().toString(),obj.getAmount());
        }else{
            this.redisTemplate.opsForHash().put(key, obj.getProductId().toString(), obj.getAmount());
            this.redisTemplate.expire(key,90, TimeUnit.DAYS);
        }
    }
    
     /**
     * 未登录
     * 更改购物车商品数量
     */
    @PostMapping(value = "/updateCart")
    public void updateCart(CookieCart obj) {
        String cartId=this.getCookiesCartId();
        String key=COOKIE_KEY+cartId;
        this.redisTemplate.opsForHash().put(key, obj.getProductId().toString(),obj.getAmount());
    }
    /**
     * 未登录
     * 删除购物车商品
     */
    @PostMapping(value = "/delCart")
    public void delCart(Long productId) {
        String cartId=this.getCookiesCartId();
        String key=COOKIE_KEY+cartId;
        this.redisTemplate.opsForHash().delete(key, productId.toString());
    }
    /**
     * 未登录
     * 查询某个用户的购物车
     */
    @PostMapping(value = "/findAll")
    public CartPage findAll() {
        String cartId=this.getCookiesCartId();
        String key=COOKIE_KEY+cartId;

        CartPage<CookieCart> cartPage=new CartPage();
        //查询该用户购物车的总数
        long size=this.redisTemplate.opsForHash().size(key);
        cartPage.setCount((int)size);

        //查询购物车的所有商品
        Map<String,Integer> map= this.redisTemplate.opsForHash().entries(key);
        List<CookieCart> cartList=new ArrayList<>();
        for (Map.Entry<String,Integer> entry:map.entrySet()){
            CookieCart cart=new CookieCart();
            cart.setProductId(Long.parseLong(entry.getKey()));
            cart.setAmount(entry.getValue());
            cartList.add(cart);
        }
        cartPage.setCartList(cartList);
        return cartPage;
    }

    /**
     * 登录
     * 合并购物车
     * 把cookie中的购物车合并到登录用户的购物车
     */
    @PostMapping(value = "/mergeCart")
    public void mergeCart(Long userId) {
        //第一步：提取未登录用户的cookie的购物车数据
        String cartId=this.getCookiesCartId();
        String keycookie=COOKIE_KEY+cartId;
        Map<String,Integer> map= this.redisTemplate.opsForHash().entries(keycookie);

        //第二步：把cookie中得购物车合并到登录用户的购物车
        String keyuser = "cart:user:" + userId;
        this.redisTemplate.opsForHash().putAll(keyuser,map);

        //第三步：删除redis未登录的用户cookies的购物车数据
        this.redisTemplate.delete(keycookie);

        //第四步：删除未登录用户cookies的cartid
        Cookie cookie=new Cookie("cartId",null);
        cookie.setMaxAge(0);
        response.addCookie(cookie);
    }
    
    
    /**
     * 获取cookies
     */
    public  String getCookiesCartId(){
        //第一步：先检查cookies是否有cartid
        Cookie[] cookies =  request.getCookies();
        if(cookies != null){
            for(Cookie cookie : cookies){
                if(cookie.getName().equals("cartId")){
                    return cookie.getValue();
                }
            }
        }
        //第二步：cookies没有cartid，直接生成全局id，并设置到cookie里面
        //生成全局唯一id
        long id=this.idGenerator.incrementId();
        //设置到cookies
        Cookie cookie=new Cookie("cartId",String.valueOf(id));
        response.addCookie(cookie);
        return id+"";
    }
}
复制代码

id生成器

@Service
public class IdGenerator {

    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    private static final String ID_KEY = "id:generator:cart";

    /**
     * 生成全局唯一id
     */
    public Long incrementId() {
        long n=this.stringRedisTemplate.opsForValue().increment(ID_KEY);
        return n;
    }

}
复制代码