阿里Java架构师讲解购物车的原理及实现

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

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

2）用户登陆了用户名密码，添加商品，关闭浏览器再打开后不登录用户名和密码问：购物车商品还在吗？

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

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

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

１）在

２）不在了

３）在

４）在

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

下面我们就来讲解下购物车的原理，最后再来说下具体的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;  }

最后重定向到购物车展示页: 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)当购物车中午商品时, 刷新当前页面。

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

欢迎工作一到五年的Java工程师朋友们加入Java高级互联网架构群：643459718 免费领取架构师资料

阿里Java架构师讲解购物车的原理及实现相关推荐

mysql 左连接b表的一条数据_阿里java架构师教你怎么用mysql怒怼面试官
转载地址: 阿里java架构教你怎么用mysql怒怼面试官www.jianshu.com 说一下mysql比较宏观的面试,具体咋写sql的这里就不过多举例了.后面我还会给出一个关于mysql面试优化 ...
阿里java架构师+职级_阿里 P8 高级架构师年入100W+，到底什么水平？
原标题:阿里 P8 高级架构师年入100W+,到底什么水平? 大家都知道,阿里P8高级技术专家,基本上是一线技术人能达到的最高职级,也是很多程序员追求的目标.达到年入百万的P8 Java高级架构师级别 ...
阿里Java架构师精通资料：性能优化+亿级并发架构汇总+架构选型
分布式并发架构微服务.Docker容器的基本原理.架构设计,以及应用场景. 缓存:Redis.Memcached.CDN.本地缓存搜索引擎的选型:Lucene.Solr等选型与比较应用服务器雪崩 ...
BAT大牛分享如何在最短的时间升职为阿里Java架构师
Web应用,最常见的研发语言是Java和PHP. 后端服务,最常见的研发语言是Java和C/C++. 大数据,最常见的研发语言是Java和Python. 可以说,Java是现阶段中国互联网公司中,覆盖 ...
分享我如何在7年时间里成长为阿里Java架构师（附学习路线图）
2019独角兽企业重金招聘Python工程师标准>>> 如何更高效的学习? 1.架构师应不应该写代码总的来说,架构师和程序员在某些方面上有点像产品经理和用户的关系,大部分程序员并不 ...
阿里java架构师面试128题含答案：分布式架构+Dubbo+多线程+Redis
一.Java基础和高级 1.String类为什么是final的. 2.HashMap的源码,实现原理,底层结构. 3.反射中,Class.forName和classloader的区别 4.sessio ...
java 转化为utc的时间_我6年时间成长为阿里Java架构师，你呢（附学习路线图）...
前言我用了6年的时间成为阿里架构师,一步一步走到了现在,中途也想过转换行业,也去了解过别人领域比较好的技术.也想过要转其他的语言,但是最后还是坚持下来走Java这条路,希望我的经历可以帮助到后来的人 ...
阿里P9架构师讲解从单机至亿级流量大型网站系统架构的演进过程
阶段一.单机构建网站网站的初期,我们经常会在单机上跑我们所有的程序和软件.此时我们使用一个容器,如tomcat.jetty.jboos,然后直接使用JSP/servlet技术,或者使用一些开源的框架 ...
从普通JAVA程序员到阿里P8架构师，他用了六年
工作年限:8 年服务公司:4 家(含四大门户中的两家)最近职业:Java 架构师职场关键词:社交平台.高并发系统架构设计.技术团队管理.多款从零到一的产品城市! 六年间,这位职人呆过四大门户中的两家, ...

阿里Java架构师讲解购物车的原理及实现

阿里Java架构师讲解购物车的原理及实现相关推荐

最新文章

热门文章