Redis实战(3)-数据结构List实战一之商品信息的有序存储

作者: 修罗debug
版权声明:本文为博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。



摘要:电商平台的管理后端一般有两大角色的用户可以使用,一个是系统管理员,一个是平台的卖家/商家,对于商家而言,管理自个儿的商品是日常工作中再为普通不过的事情了,本文我们将以“有序存储并展示电商平台中商家上传的各式各样的商品列表”,这里的关键词是“有序存储与展示”,我们将借助缓存中间件Redis的数据结构~列表List进行实战实现!

内容:对于Redis的数据结构~列表List,在实际的项目开发实战中,也算是其中一种比较常见、应用也比较广泛的数据结构吧!

其底层数据存储结构跟JavaSE集合体系的List有极其相似之处,即数据在底层是有序、排好顺序的,在将列表的数据获取出来的时候,会发现其中的数据确实是已经排好顺序的了,给大家绘制了一个简单的List的存储和获取流程图,如下所示:


从该图中,可以看出,当我们往Redis的列表List中添加数据时,具有“先进先出”的特性,即所谓的“FIFO”(有点队列Queue的特性!),而且数据是紧凑、一个挨着一个存储的!

即当我们在往缓存Redis的列表List添加数据时,可以采用“LPush 即从左边的方向添加”的方式往缓存Redis的List中添加,然后再采用“LPop 即从左边的方向弹出数据”或者“RPop 即从右边的方向弹出数据”的方式获取这一有序存储的列表数据!

知道了列表List的数据存储和读取流程,其实我们也就几乎知晓了在实际的项目实战开发中的代码实现了。

下面我们以“电商平台~商家添加/下架商品时如何将其商品列表有序存储至缓存Redis的List中,每次获取商家当前的商品列表时可以直接从缓存中读取,减少每个商家在每次登陆之后都需要走数据库DB频繁查询 所带来的压力!”

(1)首先,当然是需要来个“产品信息表”啦,其完整的DDL(即数据定义语言)如下所示:

CREATE TABLE `product` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) CHARACTER SET utf8mb4 NOT NULL COMMENT '商品名称',
`user_id` int(11) NOT NULL COMMENT '所属商户id',
`scan_total` int(255) DEFAULT NULL COMMENT '浏览量',
`is_active` tinyint(255) DEFAULT '1' COMMENT '是否有效',
PRIMARY KEY (`id`),
KEY `indx_scan_total` (`scan_total`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='商户商品表';

(2)然后,当然是需要开发一个Controller啦,在该Controller中我们需要开设两个请求方法,一个是给商户使用的“添加商品”(进DB,并塞入Redis),另外一个是获取当前商户已添加的“商品列表”,其完整的源代码如下所示:  

/**
* 列表List实战-商户商品列表存储
* @Author:debug (SteadyJack)
* @Link: weixin-> debug0868 qq-> 1948831260
* @Date: 2019/10/30 20:58
**/
@RestController
@RequestMapping("list")
public class ListController extends AbstractController{

@Autowired
private ListService listService;

//添加
@RequestMapping(value = "put",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
public BaseResponse put(@RequestBody Product product,BindingResult result){
BaseResponse response=new BaseResponse(StatusCode.Success);
try {
log.info("--商户商品信息:{}",product);
response.setData(listService.addProduct(product));
}catch (Exception e){
log.error("--List实战-商户商品-添加-发生异常:",e.fillInStackTrace());
response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage());
}
return response;
}

//获取列表详情
@RequestMapping(value = "get",method = RequestMethod.GET)
public BaseResponse get(@RequestParam("userId") final Integer userId){
BaseResponse response=new BaseResponse(StatusCode.Success);
try {
response.setData(listService.getHistoryProducts(userId));

}catch (Exception e){
log.error("--List实战-商户商品-获取列表-发生异常:",e.fillInStackTrace());
response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage());
}
return response;
}
}

(3)紧接着,我们需要开发Controller对应的Service,其职责当然是用来处理真正的业务逻辑,“添加商品”时,它负责将该商品信息添加进DB数据库,并添加进缓存Redis中;“获取商品”时,自然而然是从缓存Redis获取出List列表数据,其完整的源代码如下所示:  

/**
* 列表List服务
* @Author:debug (SteadyJack)
* @Link: weixin-> debug0868 qq-> 1948831260
* @Date: 2019/10/30 9:48
**/
@Service
public class ListService {

public static final Logger log= LoggerFactory.getLogger(ListService.class);

@Autowired
private ProductMapper productMapper;

@Autowired
private RedisTemplate redisTemplate;

//添加商品
@Transactional(rollbackFor = Exception.class)
public Integer addProduct(Product product) throws Exception{
if (product!=null){
product.setId(null);
//将该商品塞入数据库DB中
productMapper.insertSelective(product);
Integer id=product.getId();

if (id>0){
//将该商品塞入缓存Redis中
this.pushRedisService(product);
}
return id;
}
return -1;
}

//TODO:往缓存中塞信息-可以抽取到ListRedisService
private void pushRedisService(final Product product) throws Exception{
ListOperations<String,Product> listOperations=redisTemplate.opsForList();
listOperations.leftPush(Constant.RedisListPrefix+product.getUserId(),product);
}

//获取历史发布的商品列表
public List<Product> getHistoryProducts(final Integer userId) throws Exception{
List<Product> list= Lists.newLinkedList();

ListOperations<String,Product> listOperations=redisTemplate.opsForList();
final String key=Constant.RedisListPrefix+userId;
//TODO:倒序->userID=10010 ->Rabbitmq入门与实战,Redis入门与实战,SpringBoot项目实战
list=listOperations.range(key,0,listOperations.size(key));
log.info("--倒序:{}",list);

//TODO:顺序->userID=10010 ->SpringBoot项目实战,Redis入门与实战,Rabbitmq入门与实战
//Collections.reverse(list);
//log.info("--顺序:{}",list);

//TODO:弹出来移除的方式
//Product entity=listOperations.rightPop(key);
//while (entity!=null){
//list.add(entity);
//entity=listOperations.rightPop(key);
//}
return list;
}
}

(4)至此,我们的代码实战就完毕了,最后我们就基于Postman进入测试环节吧,我们给商户10010添加两个商品吧,如下所示:



完成之后还可以前往数据库Mysql中查看刚刚已经添加完成的商品列表,如下图所示:


最后,我们再在Postman发起“获取当前商户已经添加完成的商品列表-有序展示”(可以通过修改代码的方式,实现“顺序”、“倒序”等功效),如下所示:


好了,本篇文章我们就介绍到这里了,建议各位小伙伴一定要照着文章提供的样例代码撸一撸,只有撸过才能知道这玩意是咋用的,否则就成了“空谈者”!

对Redis相关技术栈以及实际应用场景实战感兴趣的小伙伴可以前往Debug搭建的技术社区的课程中心进行学习观看:https://www.fightjava.com/web/index/course/detail/12

其他相关的技术,感兴趣的小伙伴可以关注底部Debug的技术公众号,或者加Debug的微信,拉你进“微信版”的真正技术交流群!一起学习、共同成长!

补充:

1、本文涉及到的相关的源代码可以到此地址,check出来进行查看学习:

https://gitee.com/steadyjack/SpringBootRedis

2、目前Debug已将本文所涉及的内容整理录制成视频教程,感兴趣的小伙伴可以前往观看学习:https://www.fightjava.com/web/index/course/detail/12

3、关注一下Debug的技术微信公众号,最新的技术文章、课程以及技术专栏将会第一时间在公众号发布哦!