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形式实现缓存.