1.Redis 介绍
Redis 是一个开源（BSD 许可）的，内存中的数据结构存储系统，它能够用作数据库、缓存和消息中间件 。它反对多种类型的数据结构，如 字符串（strings），散列（hashes），列表（lists），汇合（sets），有序汇合（sorted sets） 与范畴查问，bitmaps，hyperloglogs 和 天文空间（geospatial）索引半径查问。Redis 内置了 复制（replication），LUA 脚本（Lua scripting），LRU 驱动事件（LRU eviction），事务（transactions）和不同级别的 磁盘长久化（persistence），并通过 Redis 哨兵（Sentinel）和主动 分区（Cluster）提供高可用性（high availability）。
nginx: 3- 5 万 / 秒
redis: 读: 11.2 万 / 秒 写: 8.6 万 / 秒 均匀 10 万 / 秒
吞吐量: 50 万 / 秒Redis 缓存服务器：网址: http://www.redis.cn/
2.Redis 装置
2.1 步骤
1). 解压 redis 文件
2). 挪动文件 / 批改文件
3). 装置 Redis
命令 1: make
命令 2: make install
2.2 批改 redis.conf 配置文件
1. 批改 IP 绑定
2. 敞开保护模式
3. 开启后盾启动
3.Redis 命令
1. 启动 redis redis-server redis.conf
2. 查看 redis 服务项 ps -ef |grep redis
- 进入 redis 客户端 redis-cli -p 6379
- 4. 敞开 redis
1). 命令 redis-cli -p 6379 shutdown
2).kill 命令 kill -9 pid 号
3.1 字符串（strings），
3.2 散列（hashes），
3.3 列表（lists），
3.4 汇合（sets），
3.5 有序汇合（sorted sets）
3.6 Redis 事务命令 **
4. 作用（优化现有架构）
阐明: 通过缓存服务器能够无效的晋升用户的拜访的效率.
注意事项:
1. 缓存的数据结构 应该选用 K- V 构造 只有 key 惟一 那么后果必然雷同…
2. 缓存中的数据不可能始终存储, 须要定期将内存数据进行优化 LRU 算法…
3. 缓存要求运行速度很快, C 语言实现… 运行在内存中.
4. 如果缓存运行的数据在内存中, 如果断电 / 宕机, 则内存数据间接失落. 实现内存数据的 长久化操作(磁盘).
5.SpringBoot 整合 Redis
5.1 导入 jar 包
<!--spring 整合 redis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
</dependency>5.2 入门案例
package com.jt;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.params.SetParams;
public class TestRedis {
/**
* 1. 实现 redis 测试
* 报错查看:
* 1. 查看 redis.conf 配置文件 1.ip 绑定问题 2. 保护模式问题 3. 后盾启动问题
* 2. 查看 redis 启动形式 redis-server redis.conf
* 3. 查看防火墙
* */
@Test
public void test01(){Jedis jedis = new Jedis("192.168.126.129",6379);
jedis.set("2007", "redis 入门案例");
System.out.println(jedis.get("2007"));
}
/**
* 我想判断是否有 key 数据, 如果没有则新增数据, 如果有则放弃新增 */
@Test
public void test02(){Jedis jedis = new Jedis("192.168.126.129",6379);
// if(!jedis.exists("2007")){ // 判断数据是否存在.
// jedis.set("2007", "测试案例 2222");
// }
//setnx 作用: 如果有数据, 则不做解决.
jedis.setnx("2007", "测试高级用法");
System.out.println(jedis.get("2007"));
}
/**
* 需要:
* 向 redis 中增加一个数据.set-key-value, 要求增加超时工夫 100 秒.
* 暗藏 bug: 代码执行过程中, 如果报错, 则可能删除失败.
* 原子性: 要么同时胜利, 要不同时失败.
* 解决办法: 将入库操作 / 超时工夫一齐设定. setex
*/
@Test
public void test03() throws InterruptedException {Jedis jedis = new Jedis("192.168.126.129",6379);
//jedis.set("2007", "测试工夫");
// 暗藏含意: 业务须要 到期删除数据
//jedis.expire("2007", 100);
jedis.setex("2007", 100, "测试工夫");
System.out.println(jedis.ttl("2007")+"秒");
}
/**
* 1. 如果数据存在, 则不操作数据 setnx
* 2. 同时设定超时工夫, 留神原子性 setex
* 参数阐明:
* 1. XX = "xx"; 只有 key 存在, 则进行操作
* 2. NX = "nx"; 没有 key, 进行写操作
* 3. PX = "px"; 毫秒
* 4. EX = "ex"; 秒
*/
@Test
public void test04() throws InterruptedException {Jedis jedis = new Jedis("192.168.126.129",6379);
SetParams setParams = new SetParams();
setParams.xx().ex(100);
jedis.set("2007", "bbbbb",setParams);
System.out.println(jedis.get("2007"));
}
}5.3Redis 命令: 入门案例操作
@Test
public void testHash() throws InterruptedException {Jedis jedis = new Jedis("192.168.126.129",6379);
jedis.hset("person", "id", "18");
jedis.hset("person", "name", "hash 测试");
jedis.hset("person", "age", "2");
Map<String,String> map = jedis.hgetAll("person");
Set<String> set = jedis.hkeys("person"); // 获取所有的 key
List<String> list = jedis.hvals("person");
}
@Test
public void testList() throws InterruptedException {Jedis jedis = new Jedis("192.168.126.129",6379);
jedis.lpush("list", "1","2","3","4");
System.out.println(jedis.rpop("list"));
}
@Test
public void testTx(){Jedis jedis = new Jedis("192.168.126.129",6379);
//1. 开启事务
Transaction transaction = jedis.multi();
try {transaction.set("a", "a");
transaction.set("b", "b");
transaction.set("c", "c");
transaction.exec(); // 提交事务}catch (Exception e){transaction.discard();
}
}5.4 对象与 JSON 串转化
package com.jt;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.jt.pojo.ItemDesc;
import org.junit.jupiter.api.Test;
import java.util.Date;
public class TestObjectMapper {private static final ObjectMapper MAPPER = new ObjectMapper();
/**
* 1. 对象如何转化为 JSON 串的???
* 步骤:
* 1. 获取对象的所有的 getXXXX()办法.
* 2. 将获取的 getXXX 办法的前缀 get 去掉 造成了 json 的 key=xxx
* 3. 通过 getXXX 办法的调用获取属性的值, 造成了 json 的 value 的值.
* 4. 将获取到的数据 利用 json 格局进行拼接 {key : value,key2:value2....}
* 2.JSON 如何转化为对象???
* {lyj:xxx}
* 步骤:
* 1. 依据 class 参数类型, 利用 java 的反射机制, 实例化对象.
* 2. 解析 json 格局, 辨别 key:value
* 3. 进行办法的拼接 setLyj()名称.
* 4. 调用对象的 setXXX(value) 将数据进行传递,
* 5. 最终将所有的 json 串中的 key 转化为对象的属性.
*
*
* @throws JsonProcessingException
*/
@Test
public void testTOJSON() throws JsonProcessingException {ItemDesc itemDesc = new ItemDesc();
itemDesc.setItemId(100L).setItemDesc("测试数据转化")
.setCreated(new Date()).setUpdated(new Date());
//1. 将对象转化为 JSON
String json = MAPPER.writeValueAsString(itemDesc);
System.out.println(json);
//2. 将 json 转化为对象 src: 须要转化的 JSON 串, valueType: 须要转化为什么对象
ItemDesc itemDesc2 = MAPPER.readValue(json, ItemDesc.class);
/**
* 字符串转化对象的原理:
*/
System.out.println(itemDesc2.toString());
}
}5.5 实现商品分类缓存实现
步骤：
1. 编辑 ObjectMapper 工具 API
2. 编辑 ItemCatController
阐明: 切换业务调用办法, 执行缓存调用3. 编辑 ItemCatService
5.6 AOP 实现 Redis 缓存
现有代码存在的问题
1. 如果间接将缓存业务, 写到业务层中, 如果未来的缓存代码发生变化, 则代码耦合高, 必然重写编辑代码.
2. 如果其余的业务也须要缓存, 则代码的反复率高, 开发效率低.
解决方案: 采纳 AOP 形式实现缓存.