java配置SSM纯注解整合Redis开发高并发抢红包项目

前言：

前段时间学习点Redis，这次结合ssm实现一个高并发抢红包的项目。
跟以前不一样的：

1. 基于java配置SSM，而并非XML.为什么要这样呢？
   找了点网络上的答案：

在使用Spring开发时，我们经常会看到各种各样xml配置，过于繁多的xml配置显得复杂烦人。 在Spring3之后，Spring支持使用JavaConfig来代替xml配置， 这种方式也得到越来越多人的推荐，甚至在Spring Boot的项目中，基本上已经见不到xml的影子了。

1. 抢红包的记录使用Lua保存到Redis内存中，最后再异步使用批量事务插入到Mysql。
   目的：Redis内存响应速度比Mysql硬盘响应速度快。

这个项目的目的也是为了实现上面的两个内容。
具体的项目我已经放到Github上了：有兴趣的朋友可以下载看看，里面也都写好了注释，如果有不明白的，可以联系我QQ：1115106468 一起交流

https://github.com/jjc123/Grab_RED_PACKET/blob/master/README.md

问题：此项目中高并发为了使用Redis？

如果使用Mysql直接保存，也可以，那如何解决数据不一致的问题？
可以使用乐观锁和悲观锁，此次项目中我使用的是Lua+Redis，看一下这三者区别：
悲观锁：
使用数据库的锁机制，并发的过程中同时只能有一个线程操作数据，其他得不到资源的线程就会被挂起，过程中会频繁得被挂起和恢复，导致cpu频繁切换现场上下文。
可以通过for update语句锁行如果是使用主键查询如where id=#{id}是锁行，如果是非主键查询要考虑是否对全表加锁。可以消除数据不一致性，但是性能会下降，因为他是阻塞性的，而且需要大量的恢复过程。
乐观锁：
不会阻塞并发，是非阻塞锁，他是具有CAS原理，但是会有ABA问题（CAS和ABA具体百度，更详细），可以通过添加版本号，但是会导致多次请求服务失败的概率大大提高，可以通过重入的方法（按时间戳或者次数限定）来提高成功率，但是会导致大量SQL被执行，容易引发性能瓶颈。
Lua+Redis：
正是因为上面集中方法的局限性，所以选择Redis去实现高并发，因为Lua具有原子性，消除了数据不一致。而且Redis是保存在内存中的，响应速度极快。
注意：
为了不影响最后抢一个红包的响应时间，在最后一次操作数据的时候，开启一个新的线程，批量处理数据插入Mysql。而且最后还会删除Redis中批量处理的数据。

---

现在正是开始这个高并发的抢红包项目吧！

首先我们先配置数据库：

两个表：
T_RED_PACKET存红包信息
T_USER_RED_PACKET存用户抢红包信息

create table T_RED_PACKET( id int(12) not null auto_increment, user_id int(12) not null, amount decimal(16,2) not null, send_date timestamp not null, total int(12) not null, unit_amount decimal(12) not null, stock int(12) not null, version int(12) default 0 not null, note varchar(256) null, primary key clustered(id) ); create table T_USER_RED_PACKET( id int(12) not null auto_increment, red_packet_id int(12) not null, user_id int(12) not null, amount decimal(16,2) not null, grab_time timestamp not null, note varchar(256) null, primary key clustered (id) ); insert into T_RED_PACKET(user_id,amount,send_date,total,unit_amount,stock,note) values(1,200000.00,now(),20000,10.00,20000,'20万元金额，2万个小红包 每个10元');

注意：

amount ：金额 要用decimal而不是double send_date ：发红包时间 stock：剩余的红包数 primary key clustered (id) 是设置主键和聚集索引

题外话：
Ubuntu下设置MySQL字符集为utf8

1.mysql配置文件地址
/etc/mysql/my.cnf

2.在[mysqld]在下方添加以下代码
[mysqld]
init_connect='SET collation_connection = utf8_unicode_ci'
init_connect='SET NAMES utf8'
character-set-server=utf8
collation-server=utf8_unicode_ci
skip-character-set-client-handshake

3.重启mysql服务
sudo service mysql restart

4.检测字符集是否更新成utf8.

进入mysql，mysql -u root -p,输入show variables like '%character%' 查看字符集
Variable_name	Value
character_set_client	utf8
character_set_connection	utf8
character_set_database	utf8
character_set_filesystem	binary
character_set_results	utf8
character_set_server	utf8
character_set_system	utf8
character_sets_dir	/usr/share/mysql/charsets/

配置Redis：

注意：redis的数据即使电脑关机下次打开redis的时候还会存在

进入redis的src然后./redis-server ../redis.conf &指定配置文件启动而且是后台启动
再打开新的客户端：./redis-cli
127.0.0.1:6379> hset red_packet_2 stock 20000 （保存红包库存 也可以用来直接修改）
(integer) 0
127.0.0.1:6379> hset red_packet_2 unit_amount 10 (保存单个红包库存)
(integer) 0
题外话：

hget red_packet_2 stock hash获取该键的值 ltrim red_packet_list_2 1 0 清空list对应键的值 RPUSH red_packet_list_2 c list添加单个元素 LRANGE red_packet_list_2 0 -1 获取对应list的所有值 LLEN red_packet_list_2 获取list长度

---

这些外部内容已经配置好了，具体的项目我也放到了github上 有兴趣的朋友可以看看。

需要注意的是ubuntu每次开机运行项目的时候老是我的端口被占用：
查看端口：
sudo netstat -lnp | grep 8082
杀死占用端口进程：
sudo kill-9 进程号

注意：使用jdbc批量处理的时候需要：url添加rewriteBatchedStatements=true

我的测试数据：
url添加rewriteBatchedStatements=true

开始保存数据 耗时：5917插入数量:20000

url不添加rewriteBatchedStatements=true

开始保存数据 耗时：13315插入数量:20000

所以批量处理一定要加上rewriteBatchedStatements=true