redis的基础用法
1. Redis的应用场景
- 缓存-是JavaEE项目中使用最多的功能
如: 数据查询、短连接、新闻内容、商品内容等 - 任务队列
如:秒杀、抢购、12306等等 - 数据过期处理(精确单位毫秒级)
- 分布式集群架构中的session分离(等同于nginx负债均衡的(ip_hash)策略,其目的都是解决用户session一致性问题)
实际项目中:对于nginx的ip绑定策略同一用户的访问打到同一个机器上,也是存在风险的,而且也失去了负债均衡的意义。
实际项目中分布式架构中的session共享问题解决如下:其一:把session放到redis中,中间需要多次访问redis。但是这种方式可以水平扩展(增加redis服务集群)即使服务器重启session也不会丢失,但是需要注意下session在redis中的刷新/失效机制。这种方式不仅可以跨服务器session共享,甚至可以跨平台共享(如网页端和APP端)
其二:无session状态的场景,(api无状态服务)很多接口类中每次接口访问都不依赖于session,不依赖于前一次的接口访问。
- 网站访问统计
- 应用排行榜
- 聊天室的在线好友列表
2. Redis优势
性能非常高-官方公布redis读速度高达110000次/s、写的速度是81000次/s
五种数据类型:
支持二进制案例的:String类型、list类型、set类型、hash类型、sorted set类型原子性-redis所有操作都是原子性的、同时redis还支持对几个操作全并后的原子性执行
丰富的特性(通知、key过期等特性)
一个redis实例最多可提供16个数据库,下标0-15
3. 注意事项
其中的key是字符串类型,尽可能满足如下几点:
- key不要太长,最好不要操作1024个字节,这不仅会消耗内存还会降低查找效率
- key不要太短,如果太短会降低key的可读性
- 在项目中,key最好有一个统一的命名规范(根据企业的需求)
4. Redis 在Linux下的安装流传
- 获取、编辑、运行
$ wget http://download.redis.io/releases/redis-5.0.7.tar.gz
$ tar xzf redis-5.0.7.tar.gz
$ cd redis-5.0.7
$ make
$ make install PREFIX=/usr/local/redis
$ ./redis-server
-rwxr-xr-x. 1 root root 2076400 2月 17 19:41 redis-benchmark
-rwxr-xr-x. 1 root root 25000 2月 17 19:41 redis-check-aof
-rwxr-xr-x. 1 root root 55840 2月 17 19:41 redis-check-dump
-rwxr-xr-x. 1 root root 2200528 2月 17 19:41 redis-cli
lrwxrwxrwx. 1 root root 12 2月 17 19:41 redis-sentinel -> redis-server
-rwxr-xr-x. 1 root root 4331312 2月 17 19:41 redis-server
-
redis 文件说明
5. Redis-发布与订阅功能
-
Redis发布订阅(pub/sub)是一种消息通信模式:发送者(publish)发送消息,订阅者(subscribe)接收消息。发布订阅也叫生产者消费者模式,是实现消息队列的一种方式
-
基础命令
- publish发布消息
- 语法:publish chanel message 作用:将message消息发送到channel频道。message是要发送的消息,channel是自定 义的频道名称(例如channel1,channel2),唯一标识发布者。 返回值:数字。接收到消息订阅者的数量。
- subscribe订阅频道
- 语法:subscribe channel[channel…] 作用:订阅一个或多个频道的信息 返回值:订阅的消息。
- unsubscribe退订频道
- 语法:unsubscribe channel [channel] 作用:退出指定的频道,不订阅。 返回值:退订的告知消息。
- 命令示例:
127.0.0.1:6379> publish chanel "test-mseeage"
(integer) 2
---
127.0.0.1:6379> SUBSCRIBE chanel
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "chanel"
3) (integer) 1
1) "message"
2) "chanel"
3) "test-mseeage"
---
127.0.0.1:6379> SUBSCRIBE chanel
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "chanel"
3) (integer) 1
1) "message"
2) "chanel"
3) "test-mseeage"
- 业务逻辑实现方法
说明:
JedisPubSub类:Jedis中的JedisPubSub类是Jedis的一个抽象类,此类定义了publish/subscribe的回调方法,通过继承JedisPubSub类,重写回调方法。实现java中Redis的发布订阅。当Reids发生发布或订阅的相关事件时会调用这些回调方法。只在回调方法中 实现自己的业务逻辑。
onMessage():发布者发布消息时,会执行订阅者的回调方法onMessage(),接收发布的消息。在此方法实现消息接收后的,自定义业务逻辑处理,比如访问数据库,更新库存等。
- pom文件引入依赖
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.1.0</version>
</dependency>
- 定义发布者类,发布消息
public class MyRedisPublish {
public static void main(String[] args) {
// 创建Jedis
Jedis jedis = new Jedis("192.168.6.129", 6379);
jedis.publish("chanel1", "发送message");
System.out.println("发布消息完毕....");
}
}
- 定义订阅者,接受消息
public class RedisSubScribe extends JedisPubSub {
/**
* 当订阅者接收到消息时回自动调用改方法 String channel--->频道的名称
String message--->发布的消息
*/
@Override
public void onMessage(String channel, String message) {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd
HH:mm:ss");
System.out.println("我是订阅者:订阅频道[" + channel + "],收到
的消息是:[" + message + "],时间为:[" + df.format(new Date()) + "]");
}
public static void main(String[] args) {
// 创建Jedis
Jedis jedis = new Jedis("192.168.1.90", 6379);
// 创建redisSubScribe对象
RedisSubScribe redisSubScribe = new RedisSubScribe();
// 从Redis订阅
jedis.subscribe(redisSubScribe, "chanel1");
}
}
6. redis的事物机制
- 事物简介
事务是指一系列操作步骤,这一系列的操作步骤,要么完全地执行要么完全地不执行。
Redis中的事务(transaction)是一组命令的集合,至少是两个或两个以上的命令,redis事 务保证这些命令被执行时中间不会被任何其他操作打断。
- redis事物命令
序号 | 命令 | 描述 |
---|---|---|
1 | multi | 开启事务用于标记事物的开始,其后执行的命令都将被存入命令队列,直到执行EXEC时,这些命令才会被原子的执行,类似关系数据库中的:begin transaction |
2 | exec | 提交事物,类似关系数据库中的:comm |
3 | discard | 事物回滚,类似关系数据中的:rollback |
4 | watck | watch key [key ...] 作用:监视一个(或多个) key ,如果在事务执行之前这个(或这些) key 被其他命令所改动, 那么事务将被打断。 返回值:总是返回 ok |
5 | unwatch | unwatch 作用:取消 WATCH 命令对所有 key 的监视。如果在执行WATCH 命令之后, EXEC 命令 或 DISCARD 命令先被执行了的话,那么就不需要再执行 UNWATCH 了 返回值:总是返回 ok |
- redis的watch机制说明:
A、Redis的WATCH机制 WATCH机制原理:
WATCH机制:使用WATCH监视一个或多个key,跟踪key的value修改情况,如果有 key的value值在事务EXEC执行之前被修改了,整个事务被取消。EXEC返回提示信息,表示事务已经失败。
WATCH机制使的事务,EXEC变的有条件,事务只有在被WATCH的key没有修改的前提下 才能执行。不满足条件,事务被取消。使用WATCH监视了一个带过期时间的键,那么即使 这个键过期了,事务仍然可以正常执行 大多数情况下,不同的客户端会访问不同的键,相互同时竞争同一key的情况一般都 很少,乐观锁能够以很好的性能解决数据冲突的问题。
B、何时取消key的监视(WATCH)?
①WATCH命令可以被调用多次。对键的监视从WATCH执行之后开始生效,直到调 用EXEC为止。不管事务是否成功执行,对所有键的监视都会被取消。
②当客户端断开连接时,该客户端对键的监视也会被取消。
③UNWATCH命令可以手动取消对所有键的监视。
C、 WATCH 的事例 执行步骤:
首先启动 redis-server , 在开启两个客户端连接。 分别叫 A 客户端 和 B 客户端。 启动 Redis 服务器A 客户端:WATCH 某个 key, 同时执行事务 B 客户端:对 A 客户端 WATCH 的 key 修改其 value 值。
① 在 A 客户端设置 key : str.lp 登录人数为 10
② 在 A 客户端监视 key : str.lp 3)
在A 客户端开启事务 multi 4) 在 A 客户端修改 str.lp 的值为 11 5) 在 B 客户端修改str.lp 的值为 15 6) 在 A 客户端执行事务 exec 7) 在 A 客户端查看 str.lp 值,A 客户端执行的事务没有提交,因为 WATCH 的 str.lp 的值已 经被修改了, 所有放弃事务。
- redis的持久化策略
redis的高性能是由于其将所有数据都存储在了内存中,为了使redis在重启之后乃能保存数据不丢失。需要将数据从内存中同步到硬盘中,这一过程就是持久化。
redis支持两种方式的持久化:RDB和AOF,也可将两者结合使用。
序号 | 策略 | 解释 |
---|---|---|
1 | RDB持久化 | (redis默认机制)该机制在 指定的时间间隔内将内存中的数据集快照写入硬盘 |
2 | AOF持久化 | 该机制以日志形式记录服务器所处理的每一个写操作。在redis服务器启动之初会读取该文件来重新构建数据库,保证启动后数据库的数据是完整的 |
3 | 无持久化 | 通过配置可以禁用redis持久化功能,这样可以将redis看成一个加强版的memcached了 |
4 | RDB&AOF | 同时使用两种持久化策略 |