文章目录
- 前言
- 一、下载与安装(Windows环境)
- ** 检查数据库连接状态 **
- ** 查看Redis数据库信息 **
- 二、Redis五种数据结构与基本操作
- 获取所有的key——keys *
- 清空所有的key——flushall
- 2.1 字符串操作
- 2.2 散列操作
- 2.3 列表操作
- 2.4 集合操作
- 2.5 位图操作
- 三、Java操纵Redis
- ** Jedis **
- 3.1 字符串操作
- 3.1.1 获取Redis连接
- 3.1.2 赋值与取值
- 3.1.3 截取与追加
- 3.1.4 设置过期时间
- 3.2 散列操作
- 3.2.1 赋值与取值
- 3.2.2 递增递减操作
- 3.2.3 获取所有键和值
- 3.3 列表操作
- 3.3.1 存取数据
- 3.3.2 获取指定位置元素
- 3.3.3 删除指定元素
- 3.4 集合操作
- 3.4.1 存取数据
- 3.4.2 集合运算
- 四、完整代码
- 4.1 工具类——RedisUtil
- 4.2 测试类——RedisUtilTest
前言
善始者繁多,克终者盖寡。
按照存储类型进行划分,Redis属于键值数据库的一种,其他常见的数据库如下图所示。Redis是基于内存的数据库,所有在数据读写方面它比mysql、mongodb等数据库要快,当数据库中数据量足够巨大时,系统的性能也会受到影响,所以通常情况下Redis数据库中的键都会有一个过期时间(Time To Live),与之相对的为了让数据更长久的保存下来,Redis需要进行数据持久化操作,具体来说有RDB和AOF两种方式,RDB是Redis默认持久化方式,可以理解为定期持久化,AOF类似于实时持久化。因为Redis数据库的数据读写速度快,所有它常常被用在缓存、计数器(秒杀功能)、消息队列上。
一、下载与安装(Windows环境)
Windows环境下下载Redis主要有两种渠道:官方下载和社区下载。推荐使用社区下载!!!
Redis官方发布的Linux和其他平台的Redis最新版本为7.2,但是!Windows版本还停留在3.x版本,据说官方已不再更新和维护Windows版本,也就是从官方渠道只能下载3.x的Windos版Redis。
第三方开发团队提供了更新的Windows版Redis,目前最新版本为5.0.14.1。
Windows版的Redis文件结构非常简单,将压缩包解压后可得到下图文件。
各程序功能描述如下图所示。使用Redis的第一步操作时启动Redis服务器,第二步是启动Redis客户端(默认地址和端口为127.0.0.1:6379)。
** 检查数据库连接状态 **
Redis服务器启动成功后会显示Reids版本、端口号、进程号、Redis配置文件地址等信息。
使用“ping”指令可以检查当前客户端与服务器连接情况,返回“PONG”时表明连接没有问题。
ping
** 查看Redis数据库信息 **
使用“info”指令可以查看当前Redis数据库服务器、客户端、内存使用情况、持久化等信息。
二、Redis五种数据结构与基本操作
获取所有的key——keys *
keys *
通过该指令可以用来验证指令和操作是否生效。
清空所有的key——flushall
flushall
通过该指令可以清空内存中所有的key。
2.1 字符串操作
-
赋值与取值
set key value [NX/UX]
get key [NX/UX]
NX:不覆盖,不存在就自动创建
XX:覆盖已存在,不存在时不会自动创建 -
取值后赋值
getset key value
该指令会返回原来key的值。 -
批量赋值和取值
mset key1 value1 key2 value2 key3 value3…
mget key1 key2 key3 -
判断字段是否存在
exists key -
递增/递减
incr/decr key
该指令使用默认步长(1或-1)进行递增和递减
incrby/decrby key increment/decrement
该指令可指定步长 -
获取字符串
strlen key
该指令返回字符串长度。
getrange key start end
该指令获取指定范围的字符,可以将end设置为-1,表示获取字符串第start个到最后一个字符。
setrange key start end
该指令用于覆盖原来的字符串,从指定位置开始覆盖
append key value -
删除字段
del key1 key2 key3…
2.2 散列操作
可以使用散列存储对象。
- 赋值与取值
hset key field value
hget key field
hsetNX:不覆盖,不存在就自动创建
hgetXX:覆盖,不存在不会自动创建
可以将key理解为对象的名字,例如car,将field理解为对象的属性,例如price、type。 - 批量赋值和取值
hmest key field1 value1 field2 value2
hmget key field1 field2
hgetall key
该指令获取指定散列的所有信息,包括field和value。
hkeys key
该指令获取指定散列的所有field,返回的是一个集合(因为field不能重复)。
hvals key
该指令获取指定散列的所有field,返回的是一个列表(value可以重复)。 - 判断字段是否存在
hexists key field - 递增/递减
hincrby key field increment/decrement
hincrbyfloat key field increment/decrement
递增递减操作都可以使用递增命令实现(递减就是加上一个负数),在散列中需要指定递增递减的步长。 - 获取长度
hstrlen key field
该指令返回指定散列某个field的值的长度,例如car的price是500,则返回3。
hlen key
该指令返回指定散列field的个数,例如car有price、color、type、city四个field,则返回4。 - 删除字段
hdel key field
2.3 列表操作
Redis中的列表类似于数据结构中的双向链表实现的队列,既可以从两端取元素又可以从两端存元素,并且每个元素还有索引(序号),大大加快了获取指定索引元素的速度。
- 添加元素
lpush/rpush key value1 value2 value3
lpush表示从依次向左侧添加元素;rpush表示依次向右侧添加元素,序号是从左往右排序的。 - 设置指定位置元素
lset key index value - 弹出元素
lpop/rpop key
lpop表示从左侧弹出元素;rpop表示从右侧弹出元素。
rpoplpush key1 key2
该指令表示将右侧弹出元素并添加到左侧,返回被弹出的元素。 - 获取列表长度
llen key - 获取指定位置的元素
lindex key index
lrange key 0 -1
该指令表示获取列表所有的元素,-1表示列表的最后一个元素。
2.4 集合操作
- 添加元素
sadd key value1 value2 value3
集合中不会存在相同元素。 - 删除/移动元素
srem key value1 value2 value3
smove key1 key2 value1 value2 value3
该指令表示将集合key1中的value移动到集合key2中。 - 获取集合中元素个数
smembers key
scard key - 判断元素是否在集合中
sismember key value - 集合运算
sinter key1 key2 key3 ##交集
sunion key1 key2 key3 ##并集
sdiff key1 key2 key3 ##差集
sinterstore/sunionstore/sdiffstore store key1 key2 key3
该指令表示将key1、key2、key3集合的交、并、差操作结果存储在集合store中。
2.5 位图操作
位图是Redis中特别有意思的一种数据结构,它使用二进制数表示数据,常常用于签到次数、点击次数等应用场景中。下图显示了“A”与“a”两个字符的unicode编码和十进制数,接下来在Redis客户端中进行验证。
依次取出key1的前8位数值,发现前8位数值与对应unicode编码相同。
接着将key1的第3位值由0改为1(系统返回值为该位置原来的值),再取出key1,发现key1由“A”变成了“a”。
- 赋值和取值
setbit key index value
getbit key index - 位元操作
bitcount key start end
该指令统计字符串被设置为1的bit数。
bitpos key value start end
该指令获取第一个为0或1的bit位。
bitop and/or/xor destkey key1 key2
bitop not key
上述两条指令表示与、或、异或、非位运算。
三、Java操纵Redis
** Jedis **
Jedis是Java开发中使用最广泛的Redis客户端库之一,它封装了大多数Redis的操作指令,让Java与Redis的交互变得容易。后续操作均借助Jedis完成。
3.1 字符串操作
3.1.1 获取Redis连接
public static Jedis getRedisConnection(){Jedis jedis = new Jedis("localhost",6379);return jedis;}
3.1.2 赋值与取值
public static void setAndGet(){Jedis connection = new Jedis("localhost",6379);connection.set("hello", "redis");System.out.println(connection.get("hello"));String oldValue = connection.getSet("hello", "jedis");System.out.println(oldValue);System.out.println(connection.get("hello"));connection.close();}
3.1.3 截取与追加
//截取字符串public static void subString(){Jedis connection = new Jedis("localhost", 6379);connection.set("hello", "redis");System.out.println(connection.strlen("hello"));System.out.println(connection.getrange("hello", 1, 3));connection.close();}//向末尾添加字符串public static void appendString(){Jedis connection = new Jedis("localhost", 6379);connection.set("hello", "redis");System.out.println(connection.append("hello", " 123"));System.out.println(connection.get("hello"));connection.close();}
3.1.4 设置过期时间
如前言中所述,Redis是一款基于内存的数据库,当数据量足够庞大时必然影响系统的运行速度,所有为“键”设置过期时间(Time To Live)十分有必要。
//设置键的过期时间public static void setExpire(){Jedis connection = new Jedis("localhost", 6379);connection.set("hello", "redis");//expire中传入的时间单位为“秒”connection.expire("hello", 1);try {//Thread中传入的时间单位是“毫秒”Thread.sleep(2000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(connection.get("hello"));/*用于显示键的过期时间-1表示键存在但未设置过期时间,意味着永久存在-2表示键不存在整数n表示当前键剩余过期时间*/System.out.println(connection.ttl("hello"));connection.close();}
3.2 散列操作
3.2.1 赋值与取值
public static void setAndGetHash(){Jedis connection = new Jedis("localhost", 6379);connection.hset("car", "color", "white");HashMap<String, String> carMap = new HashMap<>();carMap.put("brand", "BMW");carMap.put("price", "500");connection.hmset("car", carMap);System.out.println(connection.hgetAll("car"));connection.close();}
3.2.2 递增递减操作
public static void incrementDecrement(){Jedis connection = new Jedis("localhost", 6379);System.out.println(connection.hgetAll("car"));connection.hincrBy("car", "price", 500);System.out.println(connection.hgetAll("car"));connection.close();}
3.2.3 获取所有键和值
//获取所有的键和值public static void getAllKeysAndValues(){Jedis connection = new Jedis("localhost", 6379);Set<String> keys = connection.hkeys("car");for (String key : keys) {System.out.println(key);}List<String> values = connection.hvals("car");for (String value : values) {System.out.println(value);}connection.close();}
3.3 列表操作
3.3.1 存取数据
//列表操作之存取数据public static void listPushAndPop(){Jedis connection = new Jedis("localhost", 6379);connection.lpush("fruit","apple","banana");connection.rpush("fruit", "orange","grape", "pear");//获取列表fruit的长度并输出其中的内容while (connection.llen("fruit") > 0){System.out.println(connection.lpop("fruit"));}connection.close();}
3.3.2 获取指定位置元素
//获取列表中指定位置的元素public static void getListIndex(){Jedis connection = new Jedis("localhost", 6379);connection.rpush("fruit", "apple","banana","orange","grape","pear");System.out.println(connection.lindex("fruit", 1));//此处分隔表示和后面结果相区分System.out.println("*************");List<String> fruits = connection.lrange("fruit", 2, 4);for (String fruit : fruits) {System.out.println(fruit);}connection.close();}
3.3.3 删除指定元素
//删除列表中指定元素public static void removeListValue(){Jedis connection = new Jedis("localhost", 6379);connection.lpush("list","a","b","c","a","a","d");//从左往右删除列表中的两个aconnection.lrem("list", 2, "a");//通常情况下-1表示数据结构的最后一个元素List<String> list = connection.lrange("list", 0, -1);for (String s : list) {System.out.println(s);}connection.close();}
3.4 集合操作
3.4.1 存取数据
//集合操作之存取数据public static void addAndRemoveValue(){Jedis connection = new Jedis("localhost", 6379);connection.sadd("set","a","b","c","a","a","d");System.out.println("删除前的元素:");Set<String> set = connection.smembers("set");for (String s : set) {System.out.println(s);}System.out.println("删除后的元素");connection.srem("set", "a");set = connection.smembers("set");for (String s : set) {System.out.println(s);}connection.close();}
3.4.2 集合运算
//集合的运算public static void setOperation(){Jedis connection = new Jedis("localhost", 6379);//删除redis所有的键值对connection.flushAll();connection.sadd("fruit", "apple","tomato");connection.sadd("vegetable", "tomato","potato", "carrot");//求集合的交集Set<String> sinter = connection.sinter("fruit", "vegetable");System.out.println("交集是:");for (String s:sinter){System.out.println(s);}//求集合的并集Set<String> sunion = connection.sunion("fruit", "vegetable");System.out.println("\n并集是:");for (String s:sunion){System.out.println(s);}//求集合的差集fruit减去vegetableSet<String> sdiff = connection.sdiff("fruit", "vegetable");System.out.println("\n差集是:");for (String s:sdiff){System.out.println(s);}connection.close();}
四、完整代码
4.1 工具类——RedisUtil
import redis.clients.jedis.Jedis;import java.util.HashMap;
import java.util.List;
import java.util.Set;public class RedisUtil {public static void main(String[] args) {}public static Jedis getRedisConnection(){Jedis jedis = new Jedis("localhost",6379);return jedis;}//设置、获取字符串的键值public static void setAndGet(){Jedis connection = new Jedis("localhost",6379);connection.set("hello", "redis");System.out.println(connection.get("hello"));String oldValue = connection.getSet("hello", "jedis");System.out.println(oldValue);System.out.println(connection.get("hello"));connection.close();}//截取字符串public static void subString(){Jedis connection = new Jedis("localhost", 6379);connection.set("hello", "redis");System.out.println(connection.strlen("hello"));System.out.println(connection.getrange("hello", 1, 3));connection.close();}//向末尾添加字符串public static void appendString(){Jedis connection = new Jedis("localhost", 6379);connection.set("hello", "redis");System.out.println(connection.append("hello", " 123"));System.out.println(connection.get("hello"));connection.close();}//设置键的过期时间public static void setExpire(){Jedis connection = new Jedis("localhost", 6379);connection.set("hello", "redis");connection.expire("hello", 1);try {Thread.sleep(2000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(connection.get("hello"));/*用于显示键的过期时间-1表示键存在但未设置过期时间,意味着永久存在-2表示键不存在整数n表示当前键剩余过期时间*/System.out.println(connection.ttl("hello"));connection.close();}//散列的赋值与取值public static void setAndGetHash(){Jedis connection = new Jedis("localhost", 6379);connection.hset("car", "color", "white");HashMap<String, String> carMap = new HashMap<>();carMap.put("brand", "BMW");carMap.put("price", "500");connection.hmset("car", carMap);System.out.println(connection.hgetAll("car"));connection.close();}//递增递减操作public static void incrementDecrement(){Jedis connection = new Jedis("localhost", 6379);System.out.println(connection.hgetAll("car"));connection.hincrBy("car", "price", 500);System.out.println(connection.hgetAll("car"));connection.close();}//获取所有的键和值public static void getAllKeysAndValues(){Jedis connection = new Jedis("localhost", 6379);Set<String> keys = connection.hkeys("car");for (String key : keys) {System.out.println(key);}List<String> values = connection.hvals("car");for (String value : values) {System.out.println(value);}connection.close();}//列表操作之存取数据public static void listPushAndPop(){Jedis connection = new Jedis("localhost", 6379);connection.lpush("fruit","apple","banana");connection.rpush("fruit", "orange","grape", "pear");//获取列表fruit的长度并输出其中的内容while (connection.llen("fruit") > 0){System.out.println(connection.lpop("fruit"));}connection.close();}//获取列表中指定位置的元素public static void getListIndex(){Jedis connection = new Jedis("localhost", 6379);connection.rpush("fruit", "apple","banana","orange","grape","pear");System.out.println(connection.lindex("fruit", 1));//此处分隔表示和后面结果相区分System.out.println("*************");List<String> fruits = connection.lrange("fruit", 2, 4);for (String fruit : fruits) {System.out.println(fruit);}connection.close();}//删除列表中指定元素public static void removeListValue(){Jedis connection = new Jedis("localhost", 6379);connection.lpush("list","a","b","c","a","a","d");//从左往右删除列表中的两个aconnection.lrem("list", 2, "a");//通常情况下-1表示数据结构的最后一个元素List<String> list = connection.lrange("list", 0, -1);for (String s : list) {System.out.println(s);}connection.close();}//集合操作之存取数据public static void addAndRemoveValue(){Jedis connection = new Jedis("localhost", 6379);connection.sadd("set","a","b","c","a","a","d");System.out.println("删除前的元素:");Set<String> set = connection.smembers("set");for (String s : set) {System.out.println(s);}System.out.println("删除后的元素");connection.srem("set", "a");set = connection.smembers("set");for (String s : set) {System.out.println(s);}connection.close();}//集合的运算public static void setOperation(){Jedis connection = new Jedis("localhost", 6379);//删除redis所有的键值对connection.flushAll();connection.sadd("fruit", "apple","tomato");connection.sadd("vegetable", "tomato","potato", "carrot");//求集合的交集Set<String> sinter = connection.sinter("fruit", "vegetable");System.out.println("交集是:");for (String s:sinter){System.out.println(s);}//求集合的并集Set<String> sunion = connection.sunion("fruit", "vegetable");System.out.println("\n并集是:");for (String s:sunion){System.out.println(s);}//求集合的差集fruit减去vegetableSet<String> sdiff = connection.sdiff("fruit", "vegetable");System.out.println("\n差集是:");for (String s:sdiff){System.out.println(s);}connection.close();}
}
4.2 测试类——RedisUtilTest
测试工具为Junit5,开发环境为IDEA,在Eclipse中测试方法必须以test开头,此处与IDEA有所区别。
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;import static org.junit.jupiter.api.Assertions.*;class RedisUtilTest {@Testvoid getRedisConnection() {Jedis connection = RedisUtil.getRedisConnection();System.out.println(connection);connection.close();}@Testvoid setAndGet() {RedisUtil.setAndGet();}@Testvoid subString() {RedisUtil.subString();}@Testvoid appendString() {RedisUtil.appendString();}@Testvoid setExpire() {RedisUtil.setExpire();}@Testvoid setAndGetHash() {RedisUtil.setAndGetHash();}@Testvoid incrementDecrement() {RedisUtil.incrementDecrement();}@Testvoid getAllKeysAndValues() {RedisUtil.getAllKeysAndValues();}@Testvoid listPushAndPop() {RedisUtil.listPushAndPop();}@Testvoid getListIndex() {RedisUtil.getListIndex();}@Testvoid removeListValue() {RedisUtil.removeListValue();}@Testvoid addAndRemoveValue() {RedisUtil.addAndRemoveValue();}@Testvoid setOperation() {RedisUtil.setOperation();}
}