【雷丰阳-谷粒商城 】【分布式高级篇-微服务架构篇】【21】【购物车】


持续学习&持续更新中…

守破离


【雷丰阳-谷粒商城 】【分布式高级篇-微服务架构篇】【21】【购物车】

  • 购物车需求描述
  • 购物车数据结构
  • 数据Model抽取
  • 实现流程(参照京东)
  • 代码实现
  • 参考

购物车需求描述

  • 用户可以在登录状态下将商品添加到购物车【用户购物车/在线购物车】

    • 放入数据库
    • mongodb
    • 放入 redis(采用)
    • 登录以后,会将临时购物车的数据全部合并过来,并清空临时购物车
  • 用户可以在未登录状态下将商品添加到购物车【游客购物车/离线购物车/临时购物车】

    • 放入 localstorage
    • cookie
    • WebSQL
    • (客户端存储,后台不存,后台就没法分析用户的购物偏好)
    • 放入 redis(采用,有价值的数据要放在后端存储,便于大数据分析)
    • 浏览器即使关闭,下次进入,临时购物车数据都在
  • 用户可以使用购物车一起结算下单

  • 给购物车添加商品

  • 用户可以查询自己的购物车

  • 用户可以在购物车中修改购买商品的数量。

  • 用户可以在购物车中删除商品。

  • 保存选中不选中商品的状态

  • 在购物车中展示商品优惠信息

  • 提示购物车商品价格变化

注意:真实开发中,最好有一个Redis(集群) 专门负责购物车,不应该跟负责缓存的Redis混合起来使用

购物车数据结构

在这里插入图片描述

每一个购物项信息,都是一个对象,基本字段包括:

{skuId: 2131241, check: true, title: "Apple iphone.....", defaultImage: "...", price: 4999, count: 1, totalPrice: 4999, skuSaleVO: {...} 
}

购物车中不止一条数据,因此最终会是对象的数组:

[{},{},...
]

Redis 有 5 种不同数据结构,这里选择哪一种比较合适呢?

  • 首先不同用户应该有独立的购物车,因此购物车应该以用户作为 key 来存储,Value 是 用户的购物车(所有购物项)信息。这样看来基本的k-v结构就可以了。

  • 但是,我们对购物车中的商品进行增、删、改操作,基本都需要根据商品 id 进行判断, 为了方便后期处理,购物车里面也应该是k-v结构,key 是商品 id,value 是这个商品的购物项信息。

  • 综上所述,我们的购物车结构是一个双层Map:Map<String, Map<String, CartItemInfo>> 在这里插入图片描述

  • 第一层 Map,Key 是用户 id ,Value 是用户对应的购物车

  • 第二层 Map,Key 是购物车中的商品 id,Value 是对应商品的购物项信息

在这里插入图片描述

Map<String k1, Map<String k2, CartItemInfo item> userCart>

  • k1:标识每一个用户的购物车
  • k2:购物项的商品id

在Redis中

  • key:用户标识
  • value:Hash(k:商品id,v:购物项详情)

数据Model抽取

/*** 整个购物车* 需要计算的属性,必须重写他的get方法,保证每次获取属性都会进行计算*/
public class Cart {List<CartItem> items;private Integer countNum;//商品数量private Integer countType;//商品类型数量private BigDecimal totalAmount;//商品总价private BigDecimal reduce = new BigDecimal("0.00");//减免价格public List<CartItem> getItems() {return items;}public void setItems(List<CartItem> items) {this.items = items;}public Integer getCountNum() {int count = 0;if (items != null && items.size() > 0) {for (CartItem item : items) {count += item.getCount();}}return count;}public Integer getCountType() {int count = 0;if (items != null && items.size() > 0) {for (CartItem item : items) {count += 1;}}return count;}public BigDecimal getTotalAmount() {BigDecimal amount = new BigDecimal("0");//1、计算购物项总价if (items != null && items.size() > 0) {for (CartItem item : items) {if(item.getCheck()){BigDecimal totalPrice = item.getTotalPrice();amount = amount.add(totalPrice);}}}//2、减去优惠总价BigDecimal subtract = amount.subtract(getReduce());return subtract;}public BigDecimal getReduce() {return reduce;}public void setReduce(BigDecimal reduce) {this.reduce = reduce;}
}
/*** 购物项内容*/
public class CartItem {private Long skuId;private Boolean check = true;private String title;private String image;private List<String> skuAttr;private BigDecimal price;private Integer count;private BigDecimal totalPrice;public Long getSkuId() {return skuId;}public void setSkuId(Long skuId) {this.skuId = skuId;}public Boolean getCheck() {return check;}public void setCheck(Boolean check) {this.check = check;}public String getTitle() {return title;}public void setTitle(String title) {this.title = title;}public String getImage() {return image;}public void setImage(String image) {this.image = image;}public List<String> getSkuAttr() {return skuAttr;}public void setSkuAttr(List<String> skuAttr) {this.skuAttr = skuAttr;}public BigDecimal getPrice() {return price;}public void setPrice(BigDecimal price) {this.price = price;}public Integer getCount() {return count;}public void setCount(Integer count) {this.count = count;}/*** 计算当前项的总价* @return*/public BigDecimal getTotalPrice() {return this.price.multiply(new BigDecimal("" + this.count));}public void setTotalPrice(BigDecimal totalPrice) {this.totalPrice = totalPrice;}
}

Redis本来就是<key,value>结构

所以,我们只需要BoundHashOperations<String, Object, Object> hashOperations = stringRedisTemplate.boundHashOps(CartConstant.CART_REDIS_KEY_PREFIX + key);,即可从Redis中获取一个类似于HashMap的对象,充当用户的购物车

保存购物项就可以这样写:hashOperations .put(skuId.toString(), JSON.toJSONString(cartItem));

获取购物项可以这样写:CartItem cartItem = JSON.parseObject(hashOperations.get(skuId.toString()), CartItem.class);

实现流程(参照京东)

在这里插入图片描述

user-key 是随机生成的 id,不管有没有登录都会有这个 cookie 信息。

  • 浏览器有一个cookie;user-key;标识用户身份,一个月后过期;
  • 如果第一次使用jd的购物车功能,都会给一个临时的用户身份;user-key 这个 Cookie
  • 浏览器以后保存,每次访问都会带上这个cookie;
  • 登录:session中有用户信息
  • 没登录:按照cookie里面带来的user-key来做
  • 第一次使用购物车页面:如果没有临时用户user-key,就帮忙创建一个临时用户user-key。

ThreadLocal—同一个线程共享数据:(Map<Thread,Object> threadLocal )

在这里插入图片描述

@ToString
@Data
public class UserInfoTo {private Long userId;private String userKey; //一定会封装,user-key 是随机生成的 id,不管有没有登录都会有这个 cookie 信息。private boolean flag = false; // 只需要让浏览器保存一次user-key这个cookie即可
}
public class CartConstant {public static final String TEMP_USER_COOKIE_NAME = "user-key";public static final int TEMP_USER_COOKIE_TIMEOUT = 60*60*24*30; // Cookie的有效期 一个月后过期
}
/*** 判断用户的登录状态。并封装传递(用户信息)给 controller。命令浏览器保存user-key这个Cookie*/
public class GulimallCartInterceptor implements HandlerInterceptor {//   ThreadLocal: 同一个线程共享数据,可以让Controller等,快速得到用户信息UserInfoTopublic static final ThreadLocal<UserInfoTo> THREAD_LOCAL = new ThreadLocal<>();/*** 目标方法执行之前*/@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {UserInfoTo userInfoTo = new UserInfoTo();//        request是SpringSession已经包装过的MemberRespVo member = (MemberRespVo) request.getSession().getAttribute(AuthServerConstant.LOGIN_USER);if (null != member) { // 登录了userInfoTo.setUserId(member.getId());
//            利用GULISESSION这个Cookie(SpringSession配置的),也就是sessionId作为user-key合适吗?
//            不合适
//            虽然能判断并获取这个信息,但是你使用了认证服务的信息,符合微服务分模块开发吗?
//            而且这样用的话,会增加复杂性
//            比如在用户没有登陆的情况下,userInfoTo的user-key一定会被设置过了,并且浏览器也保存了这个user-key
//            然后用户再次登录,不能将这个信息作为user-key直接使用了,又得给UserInfoTo再增添一个字段,比如叫userSessionId,反正很麻烦
//            Cookie[] cookies = request.getCookies();
//            if (cookies != null && cookies.length > 0) {
//                for (Cookie cookie : cookies) {
//                    if (cookie.getName().equals("GULISESSION")) {
//                        System.out.println(cookie.getName() + "====>" + cookie.getValue());
//                        break;
//                    }
//                }
//            }}//        判断浏览器有没有带来user-key这个CookieCookie[] cookies = request.getCookies();if (cookies != null && cookies.length > 0) {for (Cookie cookie : cookies) {
//                  浏览器有带来user-key这个cookie(不是第一次使用购物车页面)if (cookie.getName().equals(CartConstant.TEMP_USER_COOKIE_NAME)) {userInfoTo.setUserKey(cookie.getValue());// 浏览器已经保存了user-key这个Cookie,那么就不需要浏览器再次保存了,如果不设置,那么这个Cookie会无限续期userInfoTo.setFlag(true);break;}}}//        只要没有user-key,不管你有没有登录,就代表是第一次使用购物车页面,都给你生成一个user-keyif (StringUtils.isEmpty(userInfoTo.getUserKey())) { // 是第一次使用购物车页面String userKey = UUID.randomUUID().toString();userInfoTo.setUserKey(userKey);}THREAD_LOCAL.set(userInfoTo);return true;}/*** 业务执行之后;分配临时用户,让浏览器保存user-key*/@Overridepublic void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {UserInfoTo userInfoTo = THREAD_LOCAL.get();//如果没有临时用户一定要让浏览器保存一个临时用户if (!userInfoTo.isFlag()) {Cookie cookie = new Cookie(CartConstant.TEMP_USER_COOKIE_NAME, userInfoTo.getUserKey());cookie.setMaxAge(CartConstant.TEMP_USER_COOKIE_TIMEOUT);cookie.setDomain("gulimall.com");response.addCookie(cookie); // 让浏览器保存user-key这个Cookie}}}
@Configuration
public class GulimallCartWebConfig implements WebMvcConfigurer {/*** 添加拦截器*/@Overridepublic void addInterceptors(InterceptorRegistry registry) {registry.addInterceptor(new GulimallCartInterceptor()).addPathPatterns("/**");}
}

代码实现

两个功能比较重要:新增商品到购物车、查询购物车。

新增商品:判断是否登录

  • 是:则添加商品到后台 Redis 中,把 user 的唯一标识符作为 key。
  • 否:则添加商品到后台 redis 中,使用随机生成的 user-key 作为 key。
  • 购物车里有该商品,更改数量即可
  • 购物车里没有该商品, 添加新商品到购物车

查询购物车列表:判断是否登录

  • 否:直接根据 user-key 查询 redis 中数据并展示
  • 是:已登录,则需要先根据 user-key 查询 redis 是否有数据。
    • 有:合并离线购物车数据到登录用户的购物车,而后查询 redis。
    • 否:直接去后台查询 redis,而后返回。
    private BoundHashOperations<String, Object, Object> getCurrentUserCartHashOps() {UserInfoTo userInfoTo = GulimallCartInterceptor.THREAD_LOCAL.get();String userKey = userInfoTo.getUserKey();Long userId = userInfoTo.getUserId();BoundHashOperations<String, Object, Object> hashOperations;if (userId != null) { // 登录了,操作登录购物车hashOperations = stringRedisTemplate.boundHashOps(CartConstant.CART_REDIS_KEY_PREFIX + userId);} else { // 没登陆,操作离线购物车hashOperations = stringRedisTemplate.boundHashOps(CartConstant.CART_REDIS_KEY_PREFIX + userKey);}return hashOperations;}private List<CartItem> listCartItems(Object userInfoKey) {BoundHashOperations<String, Object, Object> ops = stringRedisTemplate.boundHashOps(CartConstant.CART_REDIS_KEY_PREFIX + userInfoKey);List<Object> values = ops.values();if (null != values && values.size() > 0)return values.stream().map(item -> JSON.parseObject(item.toString(), CartItem.class)).collect(Collectors.toList());return null;}

添加商品到购物车:

    @Overridepublic CartItem addToCart(Long skuId, Integer num) throws ExecutionException, InterruptedException {BoundHashOperations<String, Object, Object> cartOps = getCurrentUserCartHashOps();Object o = cartOps.get(skuId.toString());if (o != null) {// 购物车里有该商品,更改数量即可String cartItemJSON = o.toString();CartItem cartItem = JSON.parseObject(cartItemJSON, CartItem.class);cartItem.setCount(cartItem.getCount() + num);cartOps.put(skuId.toString(), JSON.toJSONString(cartItem));return cartItem;} else {// 购物车里没有该商品 添加新商品到购物车CartItem cartItem = new CartItem();//1、远程查询当前要添加的商品的信息CompletableFuture<Void> getSkuInfoTask = CompletableFuture.runAsync(() -> {R skuInfo = productFeignService.getSkuInfo(skuId);SkuInfoVo data = skuInfo.getData("skuInfo", new TypeReference<SkuInfoVo>() {});cartItem.setCheck(true);cartItem.setCount(num);cartItem.setImage(data.getSkuDefaultImg());cartItem.setTitle(data.getSkuTitle());cartItem.setSkuId(skuId);cartItem.setPrice(data.getPrice());}, executor);//2、远程查询sku的组合信息CompletableFuture<Void> getSkuSaleAttrValues = CompletableFuture.runAsync(() -> {List<String> values = productFeignService.getSkuSaleAttrValues(skuId);cartItem.setSkuAttr(values);}, executor);CompletableFuture.allOf(getSkuInfoTask, getSkuSaleAttrValues).get();String s = JSON.toJSONString(cartItem);cartOps.put(skuId.toString(), s);return cartItem;}}

获取用户的购物车:

    @Overridepublic Cart getCart() throws ExecutionException, InterruptedException {UserInfoTo userInfoTo = GulimallCartInterceptor.THREAD_LOCAL.get();Long userId = userInfoTo.getUserId();String userKey = userInfoTo.getUserKey();Cart cart = new Cart();if (userId != null) {// 如果用户有离线购物车,需要合并离线购物车到登录购物车,并且清空临时购物车List<CartItem> tempCartItems = listCartItems(userKey);if (null != tempCartItems && tempCartItems.size() > 0) {for (CartItem tempCartItem : tempCartItems) {addToCart(tempCartItem.getSkuId(), tempCartItem.getCount()); // 合并离线购物车的购物项到登录购物车}CompletableFuture.runAsync(() -> {stringRedisTemplate.delete(CartConstant.CART_REDIS_KEY_PREFIX + userKey); // 清空临时购物车}, executor);}// 登录了,展示登录购物车List<CartItem> loginCartItems = listCartItems(userId);cart.setItems(loginCartItems);} else {// 没登陆,展示离线购物车List<CartItem> tempCartItems = listCartItems(userKey);cart.setItems(tempCartItems);}return cart;}

controller使用:

   /*** 浏览器有一个cookie;user-key;标识用户身份,一个月后过期;* 如果第一次使用jd的购物车功能,都会给一个临时的用户身份;user-key这个Cookie* 浏览器以后保存,每次访问都会带上这个cookie;* <p>* 登录:session有用户信息* 没登录:按照cookie里面带来user-key来做* 第一次使用购物车页面:如果没有临时用户user-key,帮忙创建一个临时用户user-key。*/@GetMapping("/cart.html")public String cartListPage(Model model) throws ExecutionException, InterruptedException {
//        Cart cart = cartService.getCart();
//        model.addAttribute("cart",cart);
//        UserInfoTo userInfoTo = GulimallCartInterceptor.THREAD_LOCAL.get();
//        System.out.println("CartController ===> " + userInfoTo);Cart cart = cartService.getCart();model.addAttribute("cart", cart);return "cartList";}/*** 添加商品到购物车* http://cart.gulimall.com/addToCart?skuId=1&num=1* * RedirectAttributes ra*      ra.addFlashAttribute();将数据放在session里面可以在页面取出,但是只能取一次*      ra.addAttribute("skuId",skuId);将数据放在url后面*/@GetMapping("/addToCart")public String addToCart(@RequestParam("skuId") Long skuId, @RequestParam("num") Integer num, RedirectAttributes redirectAttributes) throws ExecutionException, InterruptedException {CartItem cartItem = cartService.addToCart(skuId, num);redirectAttributes.addAttribute("skuId", skuId);return "redirect:http://cart.gulimall.com/addToCartSuccess"; //重定向到成功页面,防止用户刷新页面再次提交数据添加到购物车}/*** 跳转到成功页*/@GetMapping("/addToCartSuccess")public String addToCartSuccess(@RequestParam("skuId") Long skuId, Model model) {//添加商品到购物车成功,再次查询购物车数据即可CartItem item = cartService.getCartItem(skuId);model.addAttribute("item", item);return "success";}

参考

雷丰阳: Java项目《谷粒商城》Java架构师 | 微服务 | 大型电商项目.


本文完,感谢您的关注支持!


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/42533.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

CSS技巧:纯CSS实现文字渐变动画效果

文字渐变动画&#xff0c;可以实现的有两种&#xff1a;一种是一行文字整体变化颜色&#xff1b;另一种一行文字依次变化颜色。接下来&#xff0c;我就介绍一下这两种文字渐变的实现过程。 布局代码&#xff1a; <div class"con"><div class"animate…

7.pwn 工具安装和使用

关闭保护的方法 pie: -no-pie Canary:-fno-stack-protector aslr:查看:cat /proc/sys/kernel/randomize_va_space 2表示打开 关闭:echo 0>/proc/sys/kernel/randomize_va_space NX:-z execstack gdb使用以及插件安装 是GNU软件系统中的标准调试工具&#xff0c;此外GD…

electron 初始使用

electron electron文档地址deno下载地址安装命令 yarn config set electron_mirror https://cdn.npm.taobao.org/dist/electron/ npm install下载文件 文件下载完成后&#xff0c;新建dist目录&#xff0c;解压到list目录下&#xff1b;path文件中写入electron.exe 运行命令 …

排序格式排序格式

排序格式排序格式

P5. 微服务: Bot代码的执行

P5. 微服务: Bot代码的执行 0 概述1 Bot代码执行框架2 Bot代码传递给BotRunningSystem3 微服务: Bot代码执行的实现逻辑3.1 整体微服务逻辑概述3.2 生产者消费者模型实现3.3 consume() 执行代码函数的实现3.4 执行结果返回给 nextStep 4 扩展4.1 Bot代码的语言 0 概述 本章介绍…

Vulnhub靶场DC-5练习

目录 0x00 准备0x01 主机信息收集0x02 站点信息收集0x03 漏洞查找与利用1. 利用burpsuite爆破文件包含的参数2. 文件包含3. nginx日志挂马4. 反弹shell5.漏洞利用和提权 0x04 总结 0x00 准备 下载链接&#xff1a;https://download.vulnhub.com/dc/DC-5.zip 介绍&#xff1a; …

kafka-3

Kafka 消费组 consumer-offsets-N 稀疏索引 Kafka集群 集群搭建 集群启动和验证 Topic的意义 Topic和Partition 分区 副本 集群操作指令 多分区&多副本 多分区消费组 Rebalance机制 Rebalance机制处理流程 Rebalance机制-Range Rebalance机制-RoudRobin Rebalance机制-St…

计数排序的实现

原理 对一个数组进行遍历&#xff0c;再创建一个count数组 每找到一个值则在count数组中对应的位置加一&#xff0c;再在count数组中找到数字上方的count值&#xff0c;count值为几&#xff0c;则打印几次数组中的值. 开空间 相对映射 排序的实现 void CountSort(int* a, i…

PageHelper分页查询遇到的小问题

如果我们是这样子直接查询 pagehelper会拼接导我们的sql语句之后 这样子我们搜索出来的list&#xff0c;就是里面参杂了PageHelper的东西 所以我们可以直接转成我们的Page类型 但是如果我们搜索出来的是List<Blog>&#xff0c;我有些信息不想返回给前端&#xff0c;所以…

mac M1安装 VSCode

最近在学黑马程序员Java最新AI若依框架项目开发&#xff0c;里面前端用的是Visual Studio Code 所以我也就下载安装了一下&#xff0c;系统是M1芯片的&#xff0c;安装过程还是有点坑的写下来大家注意一下 1.在appstore中下载 2.在系统终端中输入 clang 显示如下图 那么在终端输…

C++语言相关的常见面试题目(一)

1. const关键字的作用 答&#xff1a; 省流&#xff1a;&#xff08;1&#xff09;定义变量&#xff0c;主要为了防止修改 (2) 修饰函数参数&#xff1a;防止在函数内被改变 &#xff08;3&#xff09;修饰函数的返回值 &#xff08;4&#xff09;修饰类中的成员函数 2. Sta…

并发编程-05AQS原理

并发编程-深入理解AQS之ReentrantLock 一 认识AQS 在讲解AQS原理以及相关同步器之前&#xff0c;我们需要对AQS有一些基本的认识&#xff0c;了解下它有什么样的机制&#xff0c;这样追踪源码的时候就不会太过于迷茫&#xff01; 1.1 什么是AQS java.util.concurrent包中的大…

LabVIEW与OpenCV图像处理对比

LabVIEW和OpenCV在图像处理方面各有特点。LabVIEW擅长图形化编程、实时处理和硬件集成&#xff0c;而OpenCV则提供丰富的算法和多语言支持。通过DLL、Python节点等方式&#xff0c;OpenCV的功能可在LabVIEW中实现。本文将结合具体案例详细分析两者的特点及实现方法。 LabVIEW与…

某大会的影响力正在扩大,吞噬了整个数据库世界!

1.规模空前 你是否曾被那句“上有天堂&#xff0c;下有苏杭”所打动&#xff0c;对杭州的湖光山色心驰神往&#xff1f;7月&#xff0c;正是夏意正浓的时节&#xff0c;也是游览杭州的最佳时期。这座古典与现代交融的城市将迎来了第13届PostgreSQL中国技术大会。作为全球数据库…

LabVIEW从测试曲线中提取特征值

在LabVIEW中开发用于从测试曲线中提取特征值的功能时&#xff0c;可以考虑以下几点&#xff1a; 数据采集与处理&#xff1a; 确保你能够有效地采集和处理测试曲线数据。这可能涉及使用DAQ模块或其他数据采集设备来获取曲线数据&#xff0c;并在LabVIEW中进行处理和分析。 特…

系统级别的原生弹窗窗口

<!DOCTYPE html> <html lang"zh-CN"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>原生的弹出窗口dialog</title><style>…

【TB作品】51单片机 Proteus仿真 基于单片机的LCD12864万年历及温度监测系统设计

实验报告&#xff1a;基于单片机的LCD12864万年历及温度监测系统设计 背景介绍 本实验旨在设计并实现一个基于STC89C52单片机的LCD12864显示的万年历系统&#xff0c;同时集成温度传感器以实现温度监测功能。系统具备整点报时和闹钟功能&#xff0c;通过蜂鸣器进行提示。该设…

初中物理知识点总结(人教版)

初中物理知识点大全 声现象知识归纳 1 .声音的发生&#xff1a;由物体的振动而产生。振动停止&#xff0c;发声也停止。 2.声音的传播&#xff1a;声音靠介质传播。真空不能传声。通常我们听到的声音是靠空气传来的。 3.声速&#xff1a;在空气中传播速度是&#xff1a;340…

【2024_CUMCM】T检验、F检验、卡方检验

T检验 T检验主要用于比较两组数据的均值差异&#xff0c;适用于小样本数据分析。它可以分为单样本T检验、独立样本T检验和配对样本T检验。 单样本T检验用于比较一个样本与已知的总体均值差异&#xff0c;独立样本T检验用于比较两个独立样本的均值差异&#xff0c;配对样本T检…

【Transformer】transformer模型结构学习笔记

文章目录 1. transformer架构2. transformer子层解析3. transformer注意力机制4. transformer部分释疑 图1 transformer模型架构 图2 transformer主要模块简介 图3 encoder-decoder示意图N6 图4 encoder-decoder子层示意图 1. transformer架构 encoder-decoder框架是一种处理NL…