京东Java架构师讲解购物车原理及Java实现

今天来写一下关于购物车的京东架构解购及东西， 这里首先抛出四个问题：

1）用户没登陆用户名和密码，师讲a实添加商品，物车 关闭浏览器再打开后 不登录用户名和密码　问：购物车商品还在吗？原理 

2）用户登陆了用户名密码，添加商品，京东架构解购及关闭浏览器再打开后 不登录用户名和密码　问：购物车商品还在吗？师讲a实   

3）用户登陆了用户名密码，添加商品，物车 关闭浏览器,原理然后再打开，登陆用户名和密码  问：购物车商品还在吗？京东架构解购及

4）用户登陆了用户名密码，添加商品，师讲a实 关闭浏览器 外地老家打开浏览器  登陆用户名和密码 问：购物车商品还在吗？物车

上面四个问题都是以京东为模板， 那么大家猜猜结果是原理什么呢？

１）在

２）不在了

３）在

４）在

如果你能够猜到答案，那么说明你真的京东架构解购及很棒， 那么关于这四点是师讲a实怎么实现的呢?　（如果有不认可的小伙伴可以用京东实验一下）

下面我们就来讲解下购物车的原理，***再来说下具体的物车code实现。

1)用户没有登录，添加商品， 此时的商品是被添加到了浏览器的Cookie中， 所以当再次访问时(不登录),商品仍然在Cookie中，所以购物车中的商品还是存在的服务器租用。

2)用户登录了，添加商品, 此时会将Cookie中和用户选择的商品都添加到购物车中， 然后删除Cookie中的商品。所以当用户再次访问(不登录),此时Cookie中的购物车商品已经被删除了， 所以此时购物车中的商品不在了。

3)用户登录， 添加商品,此时商品被添加到数据库做了持久化存储， 再次打开登录用户名和密码，该用户选择的商品肯定还是存在的， 所以购物车中的商品还是存在的。

4)理由3)

这里再说下 没登录 保存商品到Cookie的优点以及保存到Session和数据库的对比：

1：Cookie： 优点： 保存用户浏览器（不用浪费我们公司的服务器） 缺点：Cookie禁用，不提供保存

2：Session：（Redis ： 浪费大量服务器内存：实现、禁用Cookie）  速度很快

3：数据库（Mysql、Redis、SOlr）  能持久化的就数据库  速度太慢

那么我今天要讲的就是:

用户没登陆：购物车添加到Cookie中 用户登陆： 保存购物车到Redis中  （不用数据库）

整体的思路图解:

接下来就是亿华云代码实例来实现 购物车的功能了:

首先我们看下购物车和购物项两个JavaBean的设计:

购物车: buyerCart.java

1 public class BuyerCart implements Serializable{       /**      * 购物车       */      private static final long serialVersionUID = 1L;       //商品结果集       private List<BuyerItem> items = new ArrayList<BuyerItem>();           //添加购物项到购物车       public void addItem(BuyerItem item){           //判断是否包含同款           if (items.contains(item)) {               //追加数量               for (BuyerItem buyerItem : items) {                    if (buyerItem.equals(item)) {                        buyerItem.setAmount(item.getAmount() + buyerItem.getAmount());                   }               }           }else {               items.add(item);           }      }      public List<BuyerItem> getItems() {            return items;       }        public void setItems(List<BuyerItem> items) {           this.items = items;       }      //小计       //商品数量       @JsonIgnore       public Integer getProductAmount(){            Integer result = 0;           //计算           for (BuyerItem buyerItem : items) {               result += buyerItem.getAmount();           }           return result;       }          //商品金额       @JsonIgnore       public Float getProductPrice(){            Float result = 0f;           //计算          for (BuyerItem buyerItem : items) {               result += buyerItem.getAmount()*buyerItem.getSku().getPrice();          }           return result;       }             //运费       @JsonIgnore       public Float getFee(){            Float result = 0f;           //计算          if (getProductPrice() < 79) {                result = 5f;           }                      return result;       }             //总价       @JsonIgnore       public Float getTotalPrice(){            return getProductPrice() + getFee();       }   } 

这里使用了@JsonIgonre注解是因为下面需要将BuyerCart 转换成Json格式, 而这几个字段只有get 方法, 所以不能转换, 需要使用忽略Json。

下面是购物项: buyerItem.java

 public class BuyerItem implements Serializable{          private static final long serialVersionUID = 1L;         //SKu对象       private Sku sku;              //是否有货       private Boolean isHave = true;           //购买的数量       private Integer amount = 1;         public Sku getSku() {            return sku;       }         public void setSku(Sku sku) {            this.sku = sku;       }      public Boolean getIsHave() {            return isHave;       }       public void setIsHave(Boolean isHave) {            this.isHave = isHave;       }        public Integer getAmount() {            return amount;      }         public void setAmount(Integer amount) {            this.amount = amount;       }       @Override       public int hashCode() {            final int prime = 31;           int result = 1;           result = prime * result + ((sku == null) ? 0 : sku.hashCode());           return result;       }       @Override       public boolean equals(Object obj) {            if (this == obj) //比较地址               return true;          if (obj == null)               return false;           if (getClass() != obj.getClass())               return false;           BuyerItem other = (BuyerItem) obj;           if (sku == null) {                if (other.sku != null)                   return false;           } else if (!sku.getId().equals(other.sku.getId()))               return false;           return true;       }  } 

1、将商品加入购物车中

//加入购物车   function  addCart(){          //  + skuId         window.location.href="/shopping/buyerCart?skuId="+skuId+"&amount="+$("#buy-num").val();   } 

这里传入的参数是skuId(库存表的主键, 库存表保存的商品id,颜色,尺码,库存等信息), 购买数量amount。

接着我们来看Controller是如何来处理的：

 //加入购物车       @RequestMapping(value="/shopping/buyerCart")       public <T> String buyerCart(Long skuId, Integer amount, HttpServletRequest request,               HttpServletResponse response) throws JsonParseException, JsonMappingException, IOException{           //将对象转换成json字符串/json字符串转成对象          ObjectMapper om = new ObjectMapper();           om.setSerializationInclusion(Include.NON_NULL);           BuyerCart buyerCart = null;           //1,获取Cookie中的购物车           Cookie[] cookies = request.getCookies();           if (null != cookies && cookies.length > 0) {                for (Cookie cookie : cookies) {                    //                   if (Constants.BUYER_CART.equals(cookie.getName())) {                        //购物车 对象 与json字符串互转                       buyerCart = om.readValue(cookie.getValue(), BuyerCart.class);                       break;                   }               }           }                    //2,Cookie中没有购物车, 创建购物车对象           if (null == buyerCart) {               buyerCart = new BuyerCart();           }                    //3, 将当前款商品追加到购物车           if (null != skuId && null != amount) {                Sku sku = new Sku();               sku.setId(skuId);               BuyerItem buyerItem = new BuyerItem();               buyerItem.setSku(sku);               //设置数量               buyerItem.setAmount(amount);               //添加购物项到购物车               buyerCart.addItem(buyerItem);          }          //排序  倒序           List<BuyerItem> items = buyerCart.getItems();           Collections.sort(items, new Comparator<BuyerItem>() {                 @Override              public int compare(BuyerItem o1, BuyerItem o2) {                    return -1;               }          });                    //前三点 登录和非登录做的是一样的操作, 在第四点需要判断           String username = sessionProviderService.getAttributterForUsername(RequestUtils.getCSessionId(request, response));           if (null != username) {                //登录了               //4, 将购物车追加到Redis中               cartService.insertBuyerCartToRedis(buyerCart, username);               //5, 清空Cookie 设置存活时间为0, 立马销毁               Cookie cookie = new Cookie(Constants.BUYER_CART, null);               cookie.setPath("/");               cookie.setMaxAge(-0);               response.addCookie(cookie);           }else {               //未登录              //4, 保存购物车到Cookie中              //将对象转换成json格式               Writer w = new StringWriter();               om.writeValue(w, buyerCart);               Cookie cookie = new Cookie(Constants.BUYER_CART, w.toString());               //设置path是可以共享cookie               cookie.setPath("/");               //设置Cookie过期时间: -1 表示关闭浏览器失效  0: 立即失效  >0: 单位是秒, 多少秒后失效               cookie.setMaxAge(24*60*60);               //5,Cookie写会浏览器              response.addCookie(cookie);           }          //6, 重定向           return "redirect:/shopping/toCart";       } 

这里设计一个知识点: 将对象转换成json字符串/json字符串转成对象

我们在这里先写一个小的Demo来演示json和对象之间的互转, 这里使用到了springmvc中的ObjectMapper类。

 public class TestJson {       @Test      public void testAdd() throws Exception {            TestTb testTb = new TestTb();           testTb.setName("范冰冰");           ObjectMapper om = new ObjectMapper();           om.setSerializationInclusion(Include.NON_NULL);           //将对象转换成json字符串           Writer wr = new StringWriter();           om.writeValue(wr, testTb);           System.out.println(wr.toString());                     //转回对象           TestTb r = om.readValue(wr.toString(), TestTb.class);           System.out.println(r.toString());       }   } 

执行结果：

这里我们使用了Include.NON_NULL, 如果TestTb 中属性为null 的就不给转换成Json, 从对象-->Json字符串  用的是 objectMapper.writeValue(). 从Json字符串-->对象使用的是objectMapper.readValue()。

回归上面我们项目中的云服务器提供商代码, 只有未登录 添加商品时才会将此商品添加到Cookie中。

//未登录  //4, 保存购物车到Cookie中 //将对象转换成json格式  Writer w = new StringWriter();  om.writeValue(w, buyerCart);  Cookie cookie = new Cookie(Constants.BUYER_CART, w.toString());  //设置path是可以共享cookie  cookie.setPath("/");  //设置Cookie过期时间: -1 表示关闭浏览器失效  0: 立即失效  >0: 单位是秒, 多少秒后失效  cookie.setMaxAge(24*60*60);  //5,Cookie写会浏览器  response.addCookie(cookie); 

我们debug 可以看到：

这里已经将对象购物车对象buyerCart转换成了Json格式。

将商品添加到购物车, 不管是登录还是未登录, 都要先取出Cookie中的购物车, 然后将当前选择的商品追加到购物车中。

然后登录的话  就把Cookie中的购物车清空, 并将购物车的内容添加到Redis中做持久化保存。

如果未登录, 将选择的商品追加到Cookie中。

将购物车追加到Redis中的代码:insertBuyerCartToRedis(这里面包含了判断添加的是否是同款)

//保存购物车到Redis中 public void insertBuyerCartToRedis(BuyerCart buyerCart, String username){            List<BuyerItem> items = buyerCart.getItems();          if (items.size() > 0) {                //redis中保存的是skuId 为key , amount 为value的Map集合               Map<String, String> hash = new HashMap<String, String>();               for (BuyerItem item : items) {                    //判断是否有同款                   if (jedis.hexists("buyerCart:"+username, String.valueOf(item.getSku().getId()))) {                        jedis.hincrBy("buyerCart:"+username, String.valueOf(item.getSku().getId()), item.getAmount());                  }else {                       hash.put(String.valueOf(item.getSku().getId()), String.valueOf(item.getAmount()));                  }               }              if (hash.size() > 0) {                   jedis.hmset("buyerCart:"+username, hash);              }           }         } 

判断用户是否登录: String username =

sessionProviderService.getAttributterForUsername(RequestUtils.getCSessionId(request, response));

 public class RequestUtils {       //获取CSessionID       public static String getCSessionId(HttpServletRequest request, HttpServletResponse response){            //1, 从Request中取Cookie           Cookie[] cookies = request.getCookies();           //2, 从Cookie数据中遍历查找, 并取CSessionID           if (null != cookies && cookies.length > 0) {                for (Cookie cookie : cookies) {                    if ("CSESSIONID".equals(cookie.getName())) {                        //有, 直接返回                       return cookie.getValue();                   }               }          }           //没有, 创建一个CSessionId, 并且放到Cookie再返回浏览器.返回新的CSessionID           String csessionid = UUID.randomUUID().toString().replaceAll("-", "");           //并且放到Cookie中           Cookie cookie = new Cookie("CSESSIONID", csessionid);           //cookie  每次都带来, 设置路径           cookie.setPath("/");           //0:关闭浏览器  销毁cookie. 0:立即消失.  >0 存活时间,秒           cookie.setMaxAge(-1);          return csessionid;       }   }   //获取       public String getAttributterForUsername(String jessionId){            String value = jedis.get(jessionId + ":USER_NAME");           if(null != value){               //计算session过期时间是 用户***一次请求开始计时.               jedis.expire(jessionId + ":USER_NAME", 60*exp);               return value;          }           return null;       } 

2、购物车展示页面

*** 重定向到购物车展示页: return "redirect:/shopping/toCart"; 这里进入结算页有两种方式：

1) 在商品详情页 点击加入购物车。

2) 直接点击购物车按钮 进入购物车结算页。

下面来看下结算页的代码:

 @Autowired       private CartService cartService;       //去购物车结算, 这里有两个地方可以直达: 1,在商品详情页 中点击加入购物车按钮  2, 直接点击购物车按钮       @RequestMapping(value="/shopping/toCart")       public String toCart(Model model, HttpServletRequest request,              HttpServletResponse response) throws JsonParseException, JsonMappingException, IOException{             //将对象转换成json字符串/json字符串转成对象           ObjectMapper om = new ObjectMapper();           om.setSerializationInclusion(Include.NON_NULL);           BuyerCart buyerCart = null;          //1,获取Cookie中的购物车           Cookie[] cookies = request.getCookies();           if (null != cookies && cookies.length > 0) {                for (Cookie cookie : cookies) {                    //                   if (Constants.BUYER_CART.equals(cookie.getName())) {                        //购物车 对象 与json字符串互转                       buyerCart = om.readValue(cookie.getValue(), BuyerCart.class);                       break;                   }               }           }          //判断是否登录           String username = sessionProviderService.getAttributterForUsername(RequestUtils.getCSessionId(request, response));           if (null != username) {                //登录了               //2, 购物车 有东西, 则将购物车的东西保存到Redis中               if (null == buyerCart) {                    cartService.insertBuyerCartToRedis(buyerCart, username);                   //清空Cookie 设置存活时间为0, 立马销毁                   Cookie cookie = new Cookie(Constants.BUYER_CART, null);                   cookie.setPath("/");                   cookie.setMaxAge(-0);                  response.addCookie(cookie);               }              //3, 取出Redis中的购物车               buyerCart = cartService.selectBuyerCartFromRedis(username);           }          //4, 没有 则创建购物车           if (null == buyerCart) {                buyerCart = new BuyerCart();           }                    //5, 将购物车装满, 前面只是将skuId装进购物车, 这里还需要查出sku详情           List<BuyerItem> items = buyerCart.getItems();           if(items.size() > 0){                //只有购物车中有购物项, 才可以将sku相关信息加入到购物项中               for (BuyerItem buyerItem : items) {                    buyerItem.setSku(cartService.selectSkuById(buyerItem.getSku().getId()));              }           }                    //5,上面已经将购物车装满了, 这里直接回显页面           model.addAttribute("buyerCart", buyerCart);           //跳转购物页面           return "cart";       } 

这里 就是 购物车详情展示页面, 这里需要注意, 如果是同一件商品连续添加, 是需要合并的。

购物车详情展示页面就包括两大块, 1) 商品详情 2)总计(商品总额,运费)

其中1)商品详情又包括 商品尺码,商品颜色, 商品购买数量, 是否有货。

取出Redis中的购物车： buyerCart = cartService.selectBuyerCartFromRedis(username)；

    //取出Redis中购物车       public BuyerCart selectBuyerCartFromRedis(String username){            BuyerCart buyerCart = new BuyerCart();           //获取所有商品, redis中保存的是skuId 为key , amount 为value的Map集合           Map<String, String> hgetAll = jedis.hgetAll("buyerCart:"+username);           Set<Entry<String, String>> entrySet = hgetAll.entrySet();           for (Entry<String, String> entry : entrySet) {                //entry.getKey(): skuId               Sku sku = new Sku();               sku.setId(Long.parseLong(entry.getKey()));               BuyerItem buyerItem = new BuyerItem();              buyerItem.setSku(sku);               //entry.getValue(): amount              buyerItem.setAmount(Integer.parseInt(entry.getValue()));               //添加到购物车中              buyerCart.addItem(buyerItem);           }                    return buyerCart;       } 

将购物车装满, 前面只是将skuId装进购物车, 这里还需要查出sku详情: List<BuyerItem> items = buyerCart.getItems();

buyerItem.setSku(cartService.selectSkuById(buyerItem.getSku().getId()));

 //向购物车中的购物项 添加相应的数据, 通过skuId 查询sku对象, 颜色对象, 商品对象      public Sku selectSkuById(Long skuId){            Sku sku = skuDao.selectByPrimaryKey(skuId);          //颜色           sku.setColor(colorDao.selectByPrimaryKey(sku.getColorId()));           //添加商品信息           sku.setProduct(productDao.selectByPrimaryKey(sku.getProductId()));          return sku;      } 

接着就返回"cart.jsp", 这个就是购物车详情展示页面了。

3、去结算页面

到了这里就说明用户必须要 登录, 而且购物车中必须要有商品。

所以这里我么你需要利用springmvc的过滤功能, 用户点击结算的时候必须要先登录, 如果没有登录的话就提示用户需要登录。

 //去结算       @RequestMapping(value="/buyer/trueBuy")       public String trueBuy(String[] skuIds, Model model, HttpServletRequest request, HttpServletResponse response){           //1, 购物车必须有商品,            //取出用户名  再取出购物车           String username = sessionProviderService.getAttributterForUsername(RequestUtils.getCSessionId(request, response));           //取出所有购物车           BuyerCart buyerCart = cartService.selectBuyerCartFromRedisBySkuIds(skuIds, username);           List<BuyerItem> items = buyerCart.getItems();           if (items.size() > 0) {                //购物车中有商品               //判断所勾选的商品是否都有货, 如果有一件无货, 那么就刷新页面.               Boolean flag = true;               //2, 购物车中商品必须有库存 且购买大于库存数量时视为无货. 提示: 购物车原页面不动. 有货改为无货, 加红提醒.               for (BuyerItem buyerItem : items) {                    //装满购物车的购物项, 当前购物项只有skuId这一个东西, 我们还需要购物项的数量去判断是否有货                   buyerItem.setSku(cartService.selectSkuById(buyerItem.getSku().getId()));                   //校验库存                   if (buyerItem.getAmount() > buyerItem.getSku().getStock()) {                        //无货                       buyerItem.setIsHave(false);                       flag = false;                   }                   if (!flag) {                        //无货, 原页面不动, 有货改成无货, 刷新页面.                       model.addAttribute("buyerCart", buyerCart);                       return "cart";                  }               }           }else {                //购物车没有商品               //没有商品: 1>原购物车页面刷新(购物车页面提示没有商品)               return "redirect:/shopping/toCart";           }           //3, 正常进入下一个页面           return "order";      } 

取出 所指定的购物车, 因为我们结算之前在购物车详情页面会勾选 我们 需要购买的商品, 所以这里是根据所勾选的商品去结算的.

BuyerCart buyerCart = cartService.selectBuyerCartFromRedisBySkuIds(skuIds, username);

从购物车中取出指定商品：

 //从购物车中取出指定商品       public BuyerCart selectBuyerCartFromRedisBySkuIds(String[] skuIds, String username){           BuyerCart buyerCart = new BuyerCart();         //获取所有商品, redis中保存的是skuId 为key , amount 为value的Map集合          Map<String, String> hgetAll = jedis.hgetAll("buyerCart:"+username);           if (null != hgetAll && hgetAll.size() > 0) {                Set<Entry<String, String>> entrySet = hgetAll.entrySet();               for (Entry<String, String> entry : entrySet) {                    for (String skuId : skuIds) {                        if (skuId.equals(entry.getKey())) {                            //entry.getKey(): skuId                           Sku sku = new Sku();                           sku.setId(Long.parseLong(entry.getKey()));                           BuyerItem buyerItem = new BuyerItem();                           buyerItem.setSku(sku);                           //entry.getValue(): amount                           buyerItem.setAmount(Integer.parseInt(entry.getValue()));                          //添加到购物车中                           buyerCart.addItem(buyerItem);                      }                 }              }           }                    return buyerCart;      } 

1) 当我们购买的商品只要有一件是无货的状态, 那么刷新购物车详情页面, 回显无货的商品状态。

2)当购物车中午商品时, 刷新当前页面。

购物车就这么多东西，可能有讲解不到或者错误的地方， 欢迎大家指出来。如果对你有帮助的话也请点个赞支持一下，谢谢~ 

很赞哦!（88848）