抢红包案例分析以及代码实现（四）

前文回顾

上面三篇博文是使用的MySql数据库来作为数据的载体数据最终会将数据保存到磁盘中，而Redis使用的是内存，内存的速度比磁盘速度肯定要快很多。

对于使用 Redis实现抢红包,首先需要知道的是Redis的功能不如数据库强大，事务也不是很完整.因此要保证数据的正确性数据的正确性可以通过严格的验证得以保证。

而 Redis的 Lua 语言是原子性的,且功能更为强大，所以优先选择使用Lua语言来实现抢红包。

但是无论如何对于数据而言，在 Redis 当中存储，始终都不是长久之计 ， 因为 Redis并非一个长久储存数据的地方,更多的时候只是为了提供更为快速的缓存，所以当红包金额为 0 或者红包超时的时候(超时操作可以使用定时机制实,这里暂不讨论)， 会将红包数据保存到数据库中,，这样才能够保证数据的安全性和严格性。

所以本篇博文我们将使用Redis + lua脚本来实现抢红包的功能。

实现步骤

注解方式配置 Redis

首先在类 RootConfig 上创建一个 RedisTemplate 对象，并将其装载到 Spring IoC 容器中。

这样 RedisTemplate 就可以在 Spring 上下文中使用了。

注意， JedisConnectionFactory对象在最后的时候需要自行调用 afterPropertiesSet 方法，它实现了 lnitializingBean 接 口。 如果将其配置在 Spring IoC 容器中， Spring 会自动调用它，但是这里我们是自行创建的， 因此需要自行调用，否则在运用的时候会抛出异常。

lua脚本和异步持久化功能的开发

Redis 并不是一个严格的事务，而且事务的功能也是有限的 。加上 Redis 本身的命令也比较有限，功能性不强，为了增强功能性，还可以使用 Lua 语言。

Redis 中的 Lua 语言是一种原子性的操作，可以保证数据的一致性。

依据这个原理可以避免超发现象，完成抢红包的功能，而且对于性能而言， Redis 会比数据库快得多。

第一次运行 Lua 脚本的时候，先在 Redis 中编译和缓存脚本，这样就可以得到一个 SHA1字符串，之后通过 SHAl 字符串和参数就能调用 Lua 脚本了。

流程:

判断是否存在可抢的库存，如果己经没有可抢夺 的红包，则返回为 0，结束流程

有可抢夺的红包，对于红包的库存减1 ，然后重新设置库存

将抢红包数据保存到 Redis 的链表当中，链表的 key 为 red_packet_list_ {id｝

如果当前库存为 0 ，那么返回 2，这说明可以触发数据库对 Redis 链表数据的保存，链表的 key 为 red_packet_ list_ {id｝，它将保存抢红包的用户名和抢的时间

如果当前库存不为 0 ，那么将返回 1，这说明抢红包信息保存成功。

当返回为 2 的时候，说明红包己经没有库存，会触发数据库对链表数据的保存， 这是一个大数据量的保存。为了不影响最后一次抢红包的响应，在实际的操作中往往会考虑使用 JMS 消息发送到别的服务器进行操作，我们这里选择一种简单的方式来实现，去创建一条新的线程去运行保存 Redis 链表数据到数据库。

那就在Service层写一个持久到数据库的服务类吧

接口

实现类

注解＠Async 表示让 Spring 自动创建另外一条线程去运行它，这样它便不在抢最后一个红包的线程之内。因为这个方法是一个较长时间的方法，如果在同一个线程内，那么对于最后抢红包的用户需要等待的时间太长，用户体验不好

这里是每次取出 1 000 个抢红包的信息，之所以这样做是为了避免取出 的数据过大 ， 导致JVM 消耗过多的内存影响系统性能。

对于大批量的数据操作，这是我们在实际操作中要注意的，最后还会删除 Redis保存的链表信息，这样就帮助 Redis 释放内存了

对于数据库的保存 ，这里采用了 JDBC的批量处理，每 1000 条批量保存一次，使用批量有助于性能的提高。

注解＠Async 的前提是提供一个任务池给 Spring 环境，这个时候要在原有的基础上改写配置类 WebConfig

使用 表明支持异步调用，而我们实现了接口 的 方法，它是获取一个任务池，当在 Spring 环境中遇到注解＠Async就会启动这个任务池的一条线程去运行对应的方法，这样便能执行异步了。

Service层添加Redis抢红包的逻辑

UserRedPacketService接口新增接口方法grapRedPacketByRedis

实现类

这里使用了保存脚本返回 的 SHAl 字符串 ，所以只会发送一次脚本到 Redis 服务器，之后只传输 SHAl 字符串和参数到 Redis 就能执行脚本 了， 当脚本返回为 2 的时候， 表示此时所有的红包都已经被抢光了 ，那么就会触发 redisRedPacketService 的 saveUserRedPacketByRedis 方法。由于在 saveU serRedPacketByRedis 加入注解＠Async ， 所以 Spring 会创建一条新的线程去运行它 ， 这样就不会影响最后抢一个红包用户 的响应时间了 。

Controller层新增路由方法

构造模拟数据，测试

先在 Redis 上添加红包信息

初始化了一个编号为1 的大红包，其中库存为 2 万个，每个 10 元. 需要保证数据库的红包表内也有对应的记录才可以。

复制个grapByRedis.jsp,测试吧

启动应用，访问 http://localhost:8080/ssm_redpacket/grapByRedis.jsp

结合前几篇的数据统计，使用Redis的方式数据一致性也得到了保证且性能远远高于乐观锁和悲观锁的方式。

代码

https://github.com/yangshangwei/ssm_redpacket

好了，抢红包案例到此就讲解完了，下面是对这一系列文章的整体总结。

总结

（全剧终）

Java团长

专注于Java干货分享

扫描上方二维码获取更多Java干货