redis缓存技术

Redis缓存学习
1） 优化现有架构
说明:通过缓存服务器可以有效的提升用户的访问的效率.
注意事项:
1.缓存的数据结构 应该选用 K-V结构 只要key唯一 那么结果必然相同…
2.缓存中的数据不可能一直存储,需要定期将内存数据进行优化 LRU算法…
3.缓存要求运行速度很快, C语言实现… 运行在内存中.
4.如果缓存运行的数据在内存中,如果断电/宕机,则内存数据直接丢失. 实现内存数据的持久化操作(磁盘).

2.2 Redis缓存服务器
网址: http://www.redis.cn/

2.2.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万/秒

2.2.2 Redis安装

2).移动文件/修改文件

3).安装Redis
命令1: make
命令2: make install

2.2.3 修改redis.conf配置文件
1.修改IP绑定

2.关闭保护模式

3.开启后台启动

2.2.4 Redis命令
1.启动redis redis-server redis.conf

2.检查redis服务项

3. 进入redis客户端
   redis-cli -p 6379
   1
   4.关闭redis
   1).命令 redis-cli -p 6379 shutdown
   2).kill命令 kill -9 pid号
   

2.3 SpringBoot整合Redis
2.3.1 导入jar包

    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-redis</artifactId>
    </dependency>
1
2
3
4
5
6
7
8

2.3.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);
1
2
3
4
5

// 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"));
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

}

.Redis命令
1.1 入门案例操作
@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 set = jedis.hkeys(“person”); //获取所有的key
List 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();
   }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

dis的IP地址和端口都是动态变化的,所以通过配置文件标识数据. 由于redis是公共部分,所以写到common中.
在这里插入图片描述

2.2 编辑配置类
package com.jt.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import redis.clients.jedis.Jedis;

@Configuration //标识我是配置类
@PropertySource(“classpath:/properties/redis.properties”)
public class RedisConfig {

@Value("${redis.host}")
private String  host;
@Value("${redis.port}")
private Integer port;

@Bean
public Jedis jedis(){

    return new Jedis(host, port);
}
1
2
3
4
5
6
7
8
9
10

}

3 对象与JSON串转化
3.1 对象转化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.调用对象的s
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15