事务
Redis事务可以一次执行多个命令。三个特点:
- Redis单条命令保证原子性,但Redis事务不保证原子性!
- 事务的所有命令都会被序列化,在执行过程中,会按照顺序执行。
- 所有命令在事务中,没有直接执行,只有在发起执行命令的时候才会执行。
Redis事务顺序:开启事务(multi) ==> 命令入队 ==> 执行事务(exec)
- 开启、执行事务(multi、exec)
127.0.0.1:6379> multi #mutli开启事务
OK
127.0.0.1:6379> set k1 v1 #命令入队
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> get k2
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> exec #执行事务
1) OK
2) OK
3) "v2"
4) OK
127.0.0.1:6379> keys *
1) "k2"
2) "k3"
3) "k1"
- 放弃事务(discard)
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> get k2
QUEUED
127.0.0.1:6379> discard #中途放弃事务,事务不执行
OK
127.0.0.1:6379> get k1
(nil)
- 编译型异常
语法错误,事务中所有命令都不会执行。
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> getset k3 #命令错误,不存在该命令,所有命令都不会执行
(error) ERR wrong number of arguments for 'getset' command
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> set k5 v5
QUEUED
127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> keys *
(empty list or set)
- 运行时异常
逻辑错误,其他命令可以正常执行,错误命令抛出异常。
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> incr k1 # 此时执行命令失败,但不影响其他命令执行
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> get k4
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) (error) ERR value is not an integer or out of range
4) OK
5) OK
6) "v4"
127.0.0.1:6379> keys *
1) "k4"
2) "k2"
3) "k3"
4) "k1"
- 事务的悲观锁和乐观锁(watch)
- 悲观锁:假定任何时候都会出问题,无论做什么都会加锁。
- 乐观锁:假定任何时候都不会出问题,只在要出错时加锁。乐观锁一般通过添加字段version实现,更新数据时比较version,以此表明在此期间是否有人修改过数据。大部分软件包括Redis都采用的是乐观锁机制,因为悲观锁效率太低。
不加乐观锁时:
###进程1
127.0.0.1:6379> unwatch #不监视任何资源
OK
127.0.0.1:6379> get money
"100"
127.0.0.1:6379> get out
"0"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> decrby money 20
QUEUED
127.0.0.1:6379> incrby out 20 #此时在执行exec命令前执行进程2,再执行事务
QUEUED
127.0.0.1:6379> exec
1) (integer) 180
2) (integer) 20
###进程2
127.0.0.1:6379> get money
"100"
127.0.0.1:6379> get out
"0"
127.0.0.1:6379> set money 200
OK
加乐观锁时:
###进程1
127.0.0.1:6379> get money
"200"
127.0.0.1:6379> get out
"0"
127.0.0.1:6379> watch money #乐观锁监视money,即获取money的version
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> decrby money 20
QUEUED
127.0.0.1:6379> incrby out 20 #此时在执行exec命令前执行进程2,再事务
QUEUED
127.0.0.1:6379> exec
(nil)
###进程2
127.0.0.1:6379> get money
"200"
127.0.0.1:6379> get out
"0"
127.0.0.1:6379> set money 100
OK
Jedis:使用Java操作Redis
使用Java操作Redis的中间件。
- 导入依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.2.0</version>
</dependency>
- Jedis中所有命令,都和Redis中一样。
Jedis jedis = new Jedis("localhost",6379);
System.out.println(jedis.ping());
System.out.println(jedis.set("k1","k2")); //OK
System.out.println(jedis.get("k1")); //k2
- Jedis中事务操作
Jedis jedis = new Jedis("localhost",6379);
jedis.flushDB();
Transaction multi = jedis.multi();
try {
multi.set("k1","v1");
multi.set("k2","v2");
multi.exec(); //执行事务
} catch (Exception e) {
multi.discard(); //放弃事务
e.printStackTrace();
} finally {
System.out.println(jedis.get("k1"));
System.out.println(jedis.get("k2"));
jedis.close(); //关闭连接
}
Spring Boot整合Redis
- Spring Boot 2.X之后,将原来使用的Jedis替换成lettuce。
- lettuce采用netty,实例可以在多个线程中共享,不存在线程不安全的情况,更像NIO模式。而Jedis采用的是直连,多个线程操作的话,是不安全的。
步骤:
- 导入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
- 连接配置
//yml连接Redis
spring:
redis:
host: 127.0.0.1
port: 6379
//使用Redis
@Autowired
private RedisTemplate redisTemplate;
- 操作数据
//对各个数据类型进行操作
ValueOperations valueOperations = redisTemplate.opsForValue();
ListOperations listOperations = redisTemplate.opsForList();
SetOperations setOperations = redisTemplate.opsForSet();
HashOperations hashOperations = redisTemplate.opsForHash();
ZSetOperations zSetOperations = redisTemplate.opsForZSet();
GeoOperations geoOperations = redisTemplate.opsForGeo();
HyperLogLogOperations hyperLogLogOperations = redisTemplate.opsForHyperLogLog();
//获取连接对象
RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
connection.flushAll();
connection.flushDb();
redis.conf配置文件
- 配置文件 unit单位对大小写不敏感
- 绑定网络
bind 127.0.0.1 #绑定ip
protected-mode yew #保护模式
port 6379 #端口
- Redis默认不是以守护进程的方式运行,可以通过配置参数,启用守护进程
daemonize yes #默认为no,yes启用守护进程
- 日志配置
loglevel notice #日志等级
logfile "" #日志文件的位置
- 持久化及rdb配置:在规定时间内,执行固定次操作,就会持久化到文件 .rdb和.aof
save 900 1 #900秒内,至少有1个key进行了修改,就会进行持久化操作。
save 300 10 #300秒内,至少有10个key进行了修改,就会进行持久化操作。
save 60 10000 #60秒内,至少有10000个key进行了修改,就回进行持久化操作。
stop-writes-on-bgsave-error yes #持久化操作如果出错,是否继续工作。yes表示继续。
rdbcompression yes #是否压缩.rdb文件,压缩需要消耗CPU资源
rdbchecksum yes #保存.rdb文件时是否进行校验。
dir ./ #.rdb文件保存的目录
- 安全
requirepass foobared #登录redis默认没有密码,可设置登录密码
- 限制
maxClients 10000 #设置连接客户端最大数量
maxmemory <bytes> #设置redis最大内存容量
maxmemory-policy noeviction #内存达到上限后的处理策略
#volatile-lru:只对设置了过期时间的key进行LRU算法,redis默认采用此策略
#allkeyds-lru:删除LRU算法的key
#volatile-random:随机删除即将过期的key
#allkeys-random:随机删除
#volatile-ttl:删除即将过期的
#noeviction:永不过期,返回错误
- aof配置
appendonly no #aof默认不开启,使用rdb方式持久化。在大部分情况下,rdb完全够用。
appendfilename "appendonly.aof" #aof文件名
appendfsync everysec #每秒执行一次同步,但可能会丢失1s的数据
#always #每次修改都同步,会消耗性能
#no #不同步