Redis实战之商城购物车功能的实现代码

 package com.shoppingcart.controller; import com.shoppingcart.service.ShoppingCartServer; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import java.util.List; import java.util.Map; /** * redis实现购物车功能 */ @RestController @RequestMapping("/shoppingCart") public class ShoppingCartController { @Resource private ShoppingCartServer shoppingCartServer; /** * http://localhost:8099/shoppingCart/addCommodity?userId=001&shopId=1234560&commodityId=001&commodityNum=336 * 添加商品 * @return * @param: userId 用户ID * @param: [{shopId:商铺id,commodityId:商品id,commodityNum:商品数量},{shopId:商铺id,commodityId:商品id,commodityNum:商品数量}] * 测试数据： [ { "shopId": 123, "commodityId": 145350, "commodityNum": 155.88 }, { "shopId": 123, "commodityId": 6754434, "commodityNum": 945.09 }, { "shopId": 123, "commodityId": 7452, "commodityNum": 2445.09 }, { "shopId": 3210, "commodityId": 98766, "commodityNum": 2345.09 }, { "shopId": 456, "commodityId": 2435640, "commodityNum": 11945.09 } ] */ @GetMapping("/addCommodity") public Map addCommodity( @RequestParam(value = "userId", required = true) String userId, @RequestBody List> list ) { Map map = shoppingCartServer.addCommodity(userId, list); return map; } /** * 购物车列表 * http://localhost:8099/shoppingCart/shoppingCartList?userId=001 * * @param userId * @return 返回{店铺ID:商品ID=商品数量}的map。 */ @GetMapping("/shoppingCartList") public Map shoppingCartList( @RequestParam(value = "userId", required = true) String userId, @RequestParam(value = "pageNo", defaultValue = "0") Long pageNo, @RequestParam(value = "pageSize", defaultValue = "10") Long pageSize ) { Map map = shoppingCartServer.shoppingCartList(userId, pageNo, pageSize); return map; } /** * http://localhost:8099/shoppingCart/updateNum?userId=001&shopId=01&comId=123456&num=342 * 修改商品数量。 * * @param userId  用户id * @param commodityId 商品id * @param commodityNum 商品数量 * @return */ @GetMapping("/updateNum") public Map updateNum( @RequestParam(value = "userId", required = true) String userId, @RequestParam(value = "shopId", required = true) Long shopId, @RequestParam(value = "commodityId", required = true) Long commodityId, @RequestParam(value = "commodityNum", required = true) Double commodityNum ) { return shoppingCartServer.updateNum(userId, shopId, commodityId, commodityNum); } /** * http://localhost:8099/shoppingCart/delCom?userId=001&shopId=01&comId=123457 * 删除购物车中的商品 * @return * @param: userId 用户id * @param: [{shopId:商铺id,commodityId:商品id},{shopId:商铺id,commodityId:商品id}] */ @PostMapping("/delCommodity") public Map delCommodity( @RequestParam(value = "userId", required = true) String userId, @RequestBody List> list ) { return shoppingCartServer.delCommodity(userId, list); } }

 package com.shoppingcart.service; import java.util.List; import java.util.Map; public interface ShoppingCartServer { //购物车列表 public Map shoppingCartList(String userId,Long pageNo,Long pageSize); Map updateNum(String userId,Long shopId, Long commodityId, Double commodityNum); Map delCommodity(String userId, List> list); Map addCommodity(String userId, List> list); }

 package com.shoppingcart.service.impl; import com.shoppingcart.service.ShoppingCartServer; import com.shoppingcart.utils.RedisService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @Service public class ShoppingCartServerImpl implements ShoppingCartServer { @Autowired private RedisService redisService; //购物车键名前缀 public static final String SHOPPING_CART = "shoppingCart:"; //购物车的元素键名前缀 public static final String SHOP_ID = "shopId"; //添加商品 @Override public Map addCommodity(String userId, List> list) { //记录：list中有哪些商品在购物车中已经存在。 List existCommoditys = new ArrayList<>(); //todo 购物车key String key = SHOPPING_CART + userId; for (int i = 0; i  m = new HashMap() { { put("existCommoditys", existCommoditys); put("existCommoditysMsg", "这些商品在购物车中已经存在，重复数量："+existCommoditys.size()+"。"); } }; Map map = new HashMap(); map.put("data", m); map.put("code", 0); return map; } //购物车列表 @Override public Map shoppingCartList(String userId, Long pageNo, Long pageSize) { //返回{店铺ID:商品ID=商品数量}的map。 Map map = redisService.hmget(SHOPPING_CART + userId); return map; } //修改商品数量 @Override public Map updateNum(String userId, Long shopId, Long commodityId, Double commodityNum) { Map map = new HashMap(); //todo 购物车key String key = SHOPPING_CART + userId; //todo 商品key String commodityKey = SHOP_ID + shopId + ":" + commodityId; //修改购物车的数量 boolean boo = redisService.hset(key, commodityKey, commodityNum); Map m = new HashMap() { { put("key", key); put("commodityKey", commodityKey); put("commodityNum", commodityNum); } }; map.put("data", m); map.put("msg", boo == true ? "修改购物车商品数量成功。" : "修改购物车商品数量失败。"); map.put("code", boo == true ? 0 : 1); return map; } //删除商品 @Override public Map delCommodity(String userId, List> list) { Map map = new HashMap(); String[] commodityIds = new String[list.size()]; for (int i = 0; i 

 package com.shoppingcart.utils; import java.text.SimpleDateFormat; import java.util.Date; public class DateUtils { // 日期转字符串，返回指定的格式 public static String dateToString(Date date, String dateFormat) { SimpleDateFormat sdf = new SimpleDateFormat(dateFormat); return sdf.format(date); } }

 package com.shoppingcart.utils; import com.alibaba.fastjson.JSONObject; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.connection.RedisZSetCommands; import org.springframework.data.redis.connection.SortParameters; import org.springframework.data.redis.core.DefaultTypedTuple; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ZSetOperations; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import org.w3c.dom.ranges.Range; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; @Service public class RedisService { @Autowired private RedisTemplate redisTemplate; // =============================common============================ /** * 指定缓存失效时间 * * @param key 键 * @param time 时间(秒) * @return */ public boolean expire(String key, long time) { try { if (time > 0) { redisTemplate.expire(key, time, TimeUnit.SECONDS); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 根据key 获取过期时间 * * @param key 键 不能为null * @return 时间(秒) 返回0代表为永久有效 */ public long getExpire(String key) { return redisTemplate.getExpire(key, TimeUnit.SECONDS); } /** * 判断key是否存在 * * @param key 键 * @return true 存在 false不存在 */ public boolean hasKey(String key) { try { return redisTemplate.hasKey(key); } catch (Exception e) { e.printStackTrace(); return false; } } /** * 删除缓存 * * @param key 可以传一个值 或多个 */ @SuppressWarnings("unchecked") public void del(String... key) { if (key != null && key.length > 0) { if (key.length == 1) { redisTemplate.delete(key[0]); } else { List list = new ArrayList<>(Arrays.asList(key)); redisTemplate.delete(list); } } } /** * 删除缓存 * * @param keys 可以传一个值 或多个 */ @SuppressWarnings("unchecked") public void del(Collection keys) { if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(keys)) { redisTemplate.delete(keys); } } // ============================String============================= /** * 普通缓存获取 * * @param key 键 * @return 值 */ public Object get(String key) { return key == null ? null : redisTemplate.opsForValue().get(key); } /** * 普通缓存放入 * * @param key 键 * @param value 值 * @return true成功 false失败 */ public boolean set(String key, Object value) { try { redisTemplate.opsForValue().set(key, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 普通缓存放入并设置时间 * * @param key 键 * @param value 值 * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期 * @return true成功 false 失败 */ public boolean set(String key, Object value, long time) { try { if (time > 0) { redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS); } else { set(key, value); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 递增 * * @param key 键 * @param delta 要增加几(大于0) * @return */ public long incr(String key, long delta) { if (delta <0) { throw new RuntimeException("递增因子必须大于0"); } return redisTemplate.opsForValue().increment(key, delta); } /** * 递减 * * @param key 键 * @param delta 要减少几(小于0) * @return */ public long decr(String key, long delta) { if (delta <0) { throw new RuntimeException("递减因子必须大于0"); } return redisTemplate.opsForValue().increment(key, -delta); } // ================================Hash================================= /** * HashGet * * @param key 键 不能为null * @param item 项 不能为null * @return 值 */ public Object hget(String key, String item) { return redisTemplate.opsForHash().get(key, item); } /** * 获取hashKey对应的所有键值 * * @param key 键 * @return 对应的多个键值 */ public Map hmget(String key) { Map entries = redisTemplate.opsForHash().entries(key); return entries; } /** * HashSet * * @param key 键 * @param map 对应多个键值 * @return true 成功 false 失败 */ public boolean hmset(String key, Map map) { try { redisTemplate.opsForHash().putAll(key, map); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * HashSet 并设置时间 * * @param key 键 * @param map 对应多个键值 * @param time 时间(秒) * @return true成功 false失败 */ public boolean hmset(String key, Map map, long time) { try { redisTemplate.opsForHash().putAll(key, map); if (time > 0) { expire(key, time); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 向一张hash表中放入数据,如果存在就覆盖原来的值。 * * @param key 键 * @param item 项 * @param value 值 * @return true 成功 false失败 */ public boolean hset(String key, String item, Object value) { try { redisTemplate.opsForHash().put(key, item, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 向一张hash表中放入数据,如果存在就覆盖原来的值。 * * @param key 键 * @param item 项 * @param value 值 * @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间 * @return true 成功 false失败 */ public boolean hset(String key, String item, Object value, long time) { try { redisTemplate.opsForHash().put(key, item, value); if (time > 0) { expire(key, time); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 删除hash表中的值 * * @param key 键 不能为null * @param item 项 可以使多个 不能为null *    返回被删除的数量 */ public Long hdel(String key, Object... item) { return redisTemplate.opsForHash().delete(key, item); } /** * 删除hash表中的值 * * @param key 键 不能为null * @param items 项 可以使多个 不能为null */ public void hdel(String key, Collection items) { redisTemplate.opsForHash().delete(key, items.toArray()); } /** * 判断hash表中是否有该项的值 * * @param key 键 不能为null * @param item 项 不能为null * @return true 存在 false不存在 */ public boolean hHasKey(String key, String item) { return redisTemplate.opsForHash().hasKey(key, item); } /** * hash数据类型：给元素一个增量 如果不存在,就会创建一个 并把新增后的值返回 * * @param key 键 * @param item 项 * @param delta 要增加几(大于0) * @return */ public double hincr(String key, String item, double delta) { return redisTemplate.opsForHash().increment(key, item, delta); } // ============================set============================= /** * 根据key获取Set中的所有值 * * @param key 键 * @return */ public Set