Redis在项目上的常用操作【一】
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 | 同时使用两种持久化策略 |
