Redis(版本7.0)的数据结构主要包括字符串(String)、哈希表(Hash)、列表(List)、集合(Set)、有序集合(Sorted Set)、超日志(HyperLogLog)、位图(Bitmap)、地理坐标(Geo)、流(Stream)。
1 字符串 String
键和值既可以是文字也可以是二进制数据。
赋值与读取 | 单个:GET、SET、GETSET(获取旧值并用新值替换) 批量操作:MGET、MSET、MSTNX |
字符串 | 字符串的字节长度:STRLEN 获取字符串指定索引范围上的内容:GETRANGE 对字符串的指定索引范围进行设置:SETRANGE 追加新内容到值的末尾:APPEND |
数值运算 | 整数运算(不可用于浮点数运算):INCRBY、INCR、DECRBY、DECR 浮点数(可用于整数运算):INCRBYFLOAT |
表 字符串数据结构相关命令
NX (Non-Existing):字段不存在则赋值,否则不操作。
XX(Existing):字段存在则赋值,否则不操作。
图 字符串的索引
1.1 示例
限速器:为了保障系统的安全性和性能,并保证系统的重要资源不会滥用。系统的会对用户的行为做些限制: 例如,在一定时间内,用户只能对某个资源访问5次,否则只能再等待下个时间段来访问。
public class SPeedLimiter {private final static Jedis jedis = RedisPool.getRedis();private final static String SPEED_LIMIT_KEY = "speed_limit_str::%s";public static void execute(String ip) {Long count = jedis.incr(String.format(SPEED_LIMIT_KEY, ip));if (count > 5) {System.out.println("操作满5次,请稍后再操作");return;}System.out.println("操作成功:" + ip);}public static void main(String[] args) {for (int i = 0; i < 6; i++) {execute("127.0.0.1");}}
}
2 散列(哈希表)Hash
Redis的散列表是一种存储键值对的数据结构。类似于Java的HashMap。但是其键和值只能是字符串(或字节)类型,不能嵌套。
赋值与读取 | 单个:HSET(也可以批量设置)、HSETNX、HGET 批量操作:HMSET、HMGET |
数值运算 | HINCRBY、HINCRBYFLOAT |
散列 | 字段相关:HSTRLEN(字段值字节长度)、HEXISTS(检查字段是否存在)、HDEL(删除字段) 散列相关:HLEN(字段数量)、HKEYS(获取所有字段)、HVALS(获取所有值)、HGETALL(所有字段和值) |
表 散列数据结构相关命令
2.1 与字符串结构对比
字符串 | 字符串键命令提供的操作比散列键更为丰富; 键过期功能针对的是整个键,用户无法为散列中不同字段设置不同的过期时间。 |
散列 | 只需在数据库里创建一个键,就可以把任意多的字段和值聚合在一起; 可以有效地组织起相关的多项数据,让程序产生给更容易操作的数,使得针对数据的批量操作变得更方便。 |
表 散列与字符串数据结构对比
2.2 示例
短网址生成:遇到很长的网址时,我们会将其转换为相应的短网址,用这个短网址访问的内容和原网址是一样的。
原理:将需要转换的网址与数据库的id相关联,然后把这个id值转换为特定的字符串。这样就使用“ 服务 + /特定字符串”的形式进行访问时,后端根据这个字符串查找原网址,然后跳转至原网址。
public class ShortURLGenerator {private final static String SHORT_URL_ID_COUNTER_KEY = "short_url_id_counter";private final static String SHORT_URL_HASH_KEY = "short_url_hash";private final static String START_URL = "http://localhost:8080/";private final static Jedis jedis = RedisPool.getRedis();public static String generateShortUrl(String targetUrl) {Long id = jedis.incr(SHORT_URL_ID_COUNTER_KEY);jedis.hset(SHORT_URL_HASH_KEY,id.toString(),targetUrl);return START_URL + id;}public static String resolutionUrl(String url) {if (url == null || !url.startsWith(START_URL)) return null;String target = url.substring(START_URL.length());return jedis.hget(SHORT_URL_HASH_KEY,target);}public static void main(String[] args) {System.out.println(resolutionUrl("http://localhost:8080/1"));System.out.println(resolutionUrl("http://localhost:8080/2"));System.out.println(resolutionUrl("http://localhost:8080/3"));System.out.println(resolutionUrl("2http://localhost:8080/1"));}}
3 列表List
列表是一种线性的有序结构,可以按照元素被推入列表中的顺序来存储元素。这些元素既可以是文字,也可以是二进制,并且元素可重复。
推入弹出 | 推入:LPUSH、RPUSH、LPUSHX(只对已存在的列表执行推入操作)、RPUSHX 弹出:LPOP、RPOP 将源列表最右端元素弹出,然后将该元素左推入目标列表:RPOPLPUSH |
列表 | 长度:LLEN 获取单个元素:LINDEX 获取元素列表:LRANGE 覆盖:LSET 插入:LINSERT 修剪:LTRIM 删除:LREM |
阻塞 | BLPOP、BRPOP、BRPOPLPUSH |
表 列表数据结构相关命令
3.1 示例
带有阻塞功能的消息队列:一个线程创建一个简单消息接收者,在没有消息时,这个线程会被阻塞,当消息出现时,该接收者将打印这条消息。
public class BlockMessageQueue {private final static String BLOCK_MESSAGE_QUEUE_KEY = "block_message_queue";public static void main(String[] args) {Runnable run1 = () -> {System.out.println("具有阻塞功能的消息队列读取");System.out.println(RedisPool.getRedis().brpop(5,BLOCK_MESSAGE_QUEUE_KEY));;System.out.println("阻塞功能end");};Runnable run2 = () -> {try {Thread.sleep(2000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("写入进程2");RedisPool.getRedis().lpush(BLOCK_MESSAGE_QUEUE_KEY,"run2");};Runnable run3 = () -> {try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("写入进程3");RedisPool.getRedis().lpush(BLOCK_MESSAGE_QUEUE_KEY,"run3");};Thread thread1 = new Thread(run1);Thread thread2 = new Thread(run2);Thread thread3 = new Thread(run3);thread1.start();thread2.start();thread3.start();}
}