(一):Redis的事务操作
1:Redis 事务可以一次执行多个命令, 并且带有以下三个重要的保证:
批量操作在发送 EXEC 命令前被放入队列缓存。
收到 EXEC 命令后进入事务执行,事务中任意命令执行失败,其余的命令 依然被执行。但是如果队列中的命令在编译时候就出现了错误,那么整个事务队列中的语句都不会执行。
在事务执行过程,其他客户端提交的命令请求不会插入到事务执行命令序列中。
一个事务从开始到执行会经历以下三个阶段:
开始事务。
命令入队。
执行事务。
我们的事务中的语句是有执行顺序的,执行exec的时候每条语句依次执行,并且要注意,一个事务执行结束之后下次再执行还要再次开启。
127.0.0.1:6379> multi #开启事务
OK
127.0.0.1:6379(TX)> set k1 1 #事务中的语句
QUEUED
127.0.0.1:6379(TX)> set k2 2
QUEUED
127.0.0.1:6379(TX)> exec #执行事务
1) OK
2) OK
像下面这种在命令入队的时候就会出现的编译错误,那么我们执行exec的时候整个事务都是不执行的。
127.0.0.1:6379(TX)> set k3 3
QUEUED
127.0.0.1:6379(TX)> set k4 4
QUEUED
127.0.0.1:6379(TX)> setget k5
(error) ERR unknown command `setget`, with args beginning with: `k5`,
127.0.0.1:6379(TX)> exec
(error) EXECABORT Transaction discarded because of previous errors
但是像下面的这种,语句编译的时候没有问题,运行的时候才会出现问题的时候,只有本条出现错误的语句执行失败,其他的都能够执行成功,所以在Redis里面的事务是不保证原子性的。
127.0.0.1:6379(TX)> set k3 4
QUEUED
127.0.0.1:6379(TX)> set k5 5
QUEUED
127.0.0.1:6379(TX)> set k6 k6k
QUEUED
127.0.0.1:6379(TX)> incr k6
QUEUED
127.0.0.1:6379(TX)> exec
1) OK
2) OK
3) OK
4) (error) ERR value is not an integer or out of range
(二):Redis中实现乐观锁
1:首先我先开启两个服务模拟两个线程
我先在第一个线程中执行下面的代码
127.0.0.1:6379> set money 100
OK
127.0.0.1:6379> set out 0
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
127.0.0.1:6379(TX)> exec
1) (integer) 80
2) (integer) 20
***********************************************************************************************
然后写下下面的代码,暂时先不执行
127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
***********************************************************************************************
这时候我在第二个线程中对money的值进行修改
127.0.0.1:6379> get money
"80"
127.0.0.1:6379> set money 1000
OK
***********************************************************************************************
然后我在第一个线程中执行事务,会发现事务执行出现错误,其实也就是事务中所有的语句都没有执行成功。这也就是乐观锁的实现。
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
127.0.0.1:6379(TX)> exec
(nil)
***********************************************************************************************
注意只要我在第一个线程中使用watch在第二个线程修改之前那么我获得的就是相当于上一个version的值,所以执行事务会失败,需要先unclok一下再重新监视,就是获得锁定的对象的最新版本。
1:String类型
key、value键值对的形式,一般都是使用这个数据类型
2:List
列表,实际上就是链表,
用户的关注列表,粉丝列表都可以使用这种数据结构
3:Hash
字典,可以把用户的id作为key,存储用户的属性信息放进去。
4:Set集合
在微博应用中,每个用户关注的人存在一个集合中,就很容易实现求两个人的共同好友功能。
5: Sorted Set(有序集合)
如用户的积分排行榜需求就可以通过有序集合实现
在允许一定误差的情况下可以用HyperLogLog来统计网站的访问的用户数,
可以用bitMap统计员工的打卡次数。