Redis 精简笔记

127.0.0.1:6379> SET username zhangsan
OK

127.0.0.1:6379> GET username
"zhangsan"

127.0.0.1:6379> DEL age
(integer) 1

127.0.0.1:6379> HSET myhash username lisi
(integer) 1
127.0.0.1:6379> HSET myhash password 123
(integer) 1

127.0.0.1:6379> HDEL myhash username
(integer) 1

127.0.0.1:6379> LRANGE myList 0 -1
1) "b"
2) "a"
3) "c"

127.0.0.1:6379> SADD myset a
(integer) 1
127.0.0.1:6379> SADD myset a
(integer) 0
127.0.0.1:6379> SADD myset b c b d
(integer) 3

127.0.0.1:6379> SMEMBERS myset
1) "d"
2) "c"
3) "b"
4) "a"

127.0.0.1:6379> SREM myset a
(integer) 1

127.0.0.1:6379> ZADD mysort 60 zhangsan
(integer) 1
127.0.0.1:6379> ZADD mysort 50 lisi
(integer) 1
127.0.0.1:6379> ZADD mysort 80 wangwu
(integer) 1

127.0.0.1:6379> ZRANGE mysort 0 -1
1) "lisi"
2) "zhangsan"
3) "wangwu"

127.0.0.1:6379> ZRANGE mysort 0 -1 WITHSCORES
1) "zhangsan"
2) "60"
3) "wangwu"
4) "80"
5) "lisi"
6) "500"

127.0.0.1:6379> ZREM mysort lisi
(integer) 1

#   after 900 sec (15 min) if at least 1 key changed
#	在 15 分钟之后，只要有 1 个 key 发生改变，就持久化一次
save 900 1
#   after 300 sec (5 min) if at least 10 keys changed
#	在 5 分钟之后，只要有 10 个 key 发生改变，就持久化一次
save 300 10
#   after 60 sec if at least 10000 keys changed
#	在 60 秒之后，只要有 10000 个 key 发生改变，就持久化一次
save 60 10000

redis-server redis.windows.conf	

appendonly no（关闭） --> appendonly yes （开启）
				
# appendfsync always ： 每一次操作都进行持久化
appendfsync everysec ： 每隔一秒进行一次持久化
# appendfsync no	 ： 不进行持久化

redis-server redis.windows.conf	

<dependency>
	<groupId>redis.clients</groupId>
	<artifactId>jedis</artifactId>
	<version>2.9.0</version>
</dependency>

package cn.test;

import redis.clients.jedis.Jedis;

public class redis {
    public static void main(String[] args) {
        // 1. 获取连接
        // Jedis jedis = new Jedis("localhost");	默认 6379
        // Jedis jedis = new Jedis();	默认 localhost:6379
        Jedis jedis = new Jedis("localhost", 6379);
        // 设置 Redis 密码（如果密码为空，则不需要）
        // jedis.auth("123456");
        // 2. 操作
        jedis.set("username", "zhangsan");
        // 3. 关闭连接
        jedis.close();
    }
}

// 1. 获取连接
Jedis jedis = new Jedis();

// 2. 操作
// 存储
jedis.set("username", "zhangsan");
// 获取
String username = jedis.get("username");
// jedis.del("username");
System.out.println(username);

// 可以使用 setex() 方法存储可以指定过期时间的 key value
// 将 activecode：hehe 键值对存入 redis，并且 20 秒后自动删除该键值对（一些特殊场景有用，例如：限时激活码）
jedis.setex("activecode", 20, "hehe");

// 3. 关闭连接
jedis.close();

// 1. 获取连接
Jedis jedis = new Jedis();

// 2. 操作
// 存储 Hash
jedis.hset("user", "name", "lisi");
jedis.hset("user", "age", "23");
jedis.hset("user", "gender", "female");
	
// 获取 Hash
String name = jedis.hget("user", "name");
System.out.println(name);

// 获取 Hash 的所有 Map 中的数据
Map<String, String> user = jedis.hgetAll("user");
Set<String> keySet = user.keySet();
for (String key : keySet) {
	// 获取 value
	String value = user.get(key);
	System.out.println(key + ":" + value);
}

// 删除
jedis.hdel("user", "age");
	
// 3. 关闭连接
jedis.close();

 // 1. 获取连接
Jedis jedis = new Jedis();

// 2. 操作
// list 存储
jedis.lpush("mylist", "a", "b", "c");	// 从左边存
jedis.rpush("mylist", "a", "b", "c");	// 从右边存

// list 范围获取
List<String> mylist = jedis.lrange("mylist", 0, -1);
System.out.println(mylist);

// list 弹出
String element1 = jedis.lpop("mylist");	// c
System.out.println(element1);

String element2 = jedis.rpop("mylist");	// c
System.out.println(element2);
	
// list 范围获取
List<String> mylist2 = jedis.lrange("mylist", 0, -1);
System.out.println(mylist2);
	
// 3. 关闭连接
jedis.close();

// 1. 获取连接
Jedis jedis = new Jedis();

// 2. 操作
// set 存储
jedis.sadd("myset", "java", "php", "c++", "c++");

 // set 获取
Set<String> myset = jedis.smembers("myset");
System.out.println(myset);

// 删除
jedis.srem("myset", "java");

 // 3. 关闭连接
jedis.close();

// 1. 获取连接
Jedis jedis = new Jedis();

// 2. 操作
// sortedset 存储
jedis.zadd("mysortedset", 3, "亚瑟");
jedis.zadd("mysortedset", 30, "后裔");
jedis.zadd("mysortedset", 24, "孙悟空");
jedis.zadd("mysortedset", 18, "小乔");
	
// sortedset 获取
Set<String> mysortedset = jedis.zrange("mysortedset", 0, -1);
System.out.println(mysortedset);

// 删除
jedis.zrem("mysortedset", "亚瑟");

// 3. 关闭连接
jedis.close();

  <groupId>org.apache.commons</groupId>

  <artifactId>commons-pool2</artifactId>

  <version>2.8.0</version>

// 创建一个配置对象
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(50);		// 最大连接数
config.setMaxIdle(10);		// 最大空闲连接

// 1.创建 Jedis 连接池对象（配置对象不是必须的，ip 和 端口 也可以省略采用默认）
JedisPool jedisPool = new JedisPool(config, "localhost", 6379);	
// 2.获取连接
Jedis jedis = jedisPool.getResource();
// 设置 Redis 密码（如果密码为空，则不需要）
// jedis.auth("123456");
// 3. 使用
jedis.set("hehe", "heihei");
// 4. 关闭（归还到连接池中）
jedis.close();

package cn.jerry.jedis.util;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * JedisPoll 工具类：加载配置文件，配置连接池参数，提供获取连接的方法
 */
public class JedisPoolUtils {
    private static JedisPool jedisPool;

    // 当类加载读取配置文件
    static {
        InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("resources/jedis.properties");
        // 创建 Properties 对象
        Properties pro = new Properties();
        // 关联文件
        try {
            pro.load(is);
        } catch (IOException e) {
            e.printStackTrace();
        }
        // 获取数据，设置到 JedisPoolConfig 中
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));
        config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));
        // 初始化 JedisPool
        // jedisPool = new JedisPool(config, pro.getProperty("host"), Integer.parseInt(pro.getProperty("port")));
        // 如果要设置密码的话，可以这样做，只不过这种做法必须在 password，之前把 timeout 也设置上
        // timeout：在 timeout 时间内如果没有数据交互，redis 将关闭连接，0 代表永不断开（推荐设为 0，这也是默认值）
        jedisPool = new JedisPool(config, pro.getProperty("host"), Integer.parseInt(pro.getProperty("port")), Integer.parseInt(pro.getProperty("timeout")), pro.getProperty("password"));
    }

    // 获取连接的方法
    public static Jedis getJedis() {
        return jedisPool.getResource();
    }
}

host=127.0.0.1
port=6379
maxTotal=50
maxIdle=10
timeout=0
#如果密码为空，则不需要加 password，会自动活得空值
#password=123456

package cn;

import redis.clients.jedis.Jedis;
import util.JedisPoolUtils;

public class Test {
    public static void main(String[] args) {
        // 1. 通过连接池工具类获取连接
        Jedis jedis = JedisPoolUtils.getJedis();
        // 2. 操作
        jedis.set("hehe", "heihei");
        // 3. 关闭（归还到连接池）
        jedis.close();
}

// 1.先从 Redis 中查询数据
// 1.1 获取 Redis 客户端连接
Jedis jedis = JedisPoolUtils.getJedis();
String classMembers_json = jedis.get("classMembers");

// 2. 判断 classMembers_json 数据是否为 null 或 长度为 0
if (classMembers_json == null || classMembers_json.length() == 0) {
	// Redis 中没有数据
    // 2.1 从 MySQL 数据库中查询
    List<Member> members = classMembersService.selectAll();
    // 2.2 将 List 序列化为 json
    classMembers_json = JSON.toJSONString(members);
     // 2.3 将 json 数据存入 Redis
    jedis.set("classMembers", classMembers_json);
    // 归还连接
    jedis.close();
}

// 返回数据
response.setContentType("text/json;charset=utf-8");
response.getWriter().write(classMembers_json);