博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
redis系列:通过日志案例学习string命令
阅读量:7232 次
发布时间:2019-06-29

本文共 7496 字,大约阅读时间需要 24 分钟。

  hot3.png

前言

该文章将通过一个小demo将讲述Redis中的string类型命令。demo将以springboot为后台框架快速开发,iview前端框架进行简单的页面设计,为了方便就不使用DB存储数据了,直接采用Redis作为存储。

文中不会讲述springboot用法及项目搭建部分。直接根据功能方面进行讲述,穿插string命令操作说明。

案例

demo功能是记录日志,整个demo的大致页面如下

准备工作

首先定义一个key的前缀,已经存储自增id的key

private static final String MY_LOG_REDIS_KEY_PREFIX = "myLog:";private static final String MY_LOG_REDIS_ID_KEY = "myLogID";

日志相关的key将会以myLog:1、myLog:2、myLog:3的形式存储

redis操作对象

private RedisTemplate redisTemplate;//string 命令操作对象private ValueOperations valueOperations;

新增

先来看看gif图吧

来看看后台的方法

@RequestMapping(value = "/addMyLog",method = RequestMethod.POST)public boolean addMyLog(@RequestBody JSONObject myLog){    //获取自增id    Long myLogId = valueOperations.increment(MY_LOG_REDIS_ID_KEY, 1);    String date = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));    myLog.put("id",myLogId);    myLog.put("createDate", date);    myLog.put("updateDate", date);    //将数据写到redis中    valueOperations.set(MY_LOG_REDIS_KEY_PREFIX+myLogId, myLog.toString());    return true;}

从上面代码可以看出有两个操作redis的地方

valueOperations.increment(MY_LOG_REDIS_ID_KEY, 1);

valueOperations.set(MY_LOG_REDIS_KEY_PREFIX+myLogId, myLog.toString());

命令介绍

valueOperations.increment其实就相当于Redis中的INCR、INCRBY、INCRBYFLOAT、DECR、DECRBY

INCR

INCR key

对存储在指定key的数值执行原子的加1操作。没有对应的key则设置为0,再相加

INCRBY

INCRBY key increment

其实和INCR类似,不同的是这个命令可以指定具体加多少

INCRBYFLOAT

INCRBYFLOAT key increment

也是类似的,不同的是加的数值是浮点数

incrbyfloat incrByFloatKey 5.11incrbyfloat incrByFloatKey 5.22

执行结果如下

下面是java代码

@Testpublic void incrByFloat() {    System.out.println(jedis.incrByFloat("incrByFloatKey", 5.11));    System.out.println(redisTemplate.opsForValue().increment("incrByFloatKey", 5.22));}

与INCR相反的命令有DECR和DECRBY,这里就不做介绍了。

valueOperations.set就是对应Redis的SET命令了,相关联的还有SETEX、SETNX和PSETEX。需要注意的是set在Redis版本2.6.12 提供了EXPXNXXX参数用于取代SETEX、SETNX和PSETEX,后续版本可能会移除SETEX、SETNX和PSETEX命令。下面是官网的原话

Since the  command options can replace , , , it is possible that in future versions of Redis these three commands will be deprecated and finally removed.

SET

SET key value [expiration EX seconds|PX milliseconds] [NX|XX]

设置键key对应value

参数选项

EX seconds – 设置键key的过期时间,单位时秒

PX milliseconds – 设置键key的过期时间,单位时毫秒

NX – 只有键key不存在的时候才会设置key的值
XX – 只有键key存在的时候才会设置key的值

SETRANGE

SETRANGE key offset value

替换从指定长度开始的字符

set setRangeKey "Hello World"setrange setRangeKey 6 "Redis"get setRangeKey

执行结果如下

下面是java代码

@Testpublic void setRange() {    jedis.set("setRangeKey", "Hello World");    jedis.setrange("setRangeKey", 6 , "Redis");    System.out.println(jedis.get("setRangeKey"));    //spring    redisTemplate.opsForValue().set("setRangeKey", "learyRedis", 6);    System.out.println(redisTemplate.opsForValue().get("setRangeKey"));}

MSET

MSET key value [key value ...]

同时设置多个key、value

 MSETNX

MSETNX key value [key value ...]

同时设置多个key、value,key存在则忽略

查询

接着写个查询方法,将新增的内容查询出来

@RequestMapping(value = "/getMyLog",method = RequestMethod.GET)public List getMyLog(){    //获取mylog的keys    Set myLogKeys = redisTemplate.keys("myLog:*");    return  valueOperations.multiGet(myLogKeys);}

方法中的两行都涉及到了Redis操作,先是通过keys命令获取myLog:*相关的key集合,然后通过multiGet方法(也就是mget命令)获取记录。

命令介绍

KEYS

KEYS pattern

查找所有符合给定模式pattern(正则表达式)的 key

GET

GET key

获取key对应的value

set getKey getValueget getKey

执行结果如下

GETRANGE

GETRANGE key start end

获取start到end之间的字符

set getRangeKey "Hello learyRedis"getrange getRangeKey 6 -1getrange getRangeKey 0 -12

执行结果如下

GETSET

GETSET key value

设置key对应的新value且返回原来key对应的value

getset getSetKey newValueset getSetKey valuegetset getSetKey newValueget getSetKey

执行结果如下

MGET

MGET key [key ...]

返回所有指定的key的value

mset mGetKey1 mGetValue1 mGetKey2 mGetValue2 mGetKey3 mGetValue3mget mGetKey1 mGetKey2 mGetKey3 mGetKey4

执行结果如下

更新

来看看代码

@RequestMapping(value = "/updateMyLog",method = RequestMethod.POST)public boolean updateMyLog(@RequestBody JSONObject myLog){    String myLogId = myLog.getString("id");    myLog.put("updateDate", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));    valueOperations.set(MY_LOG_REDIS_KEY_PREFIX+myLogId, myLog.toString());    return true;}

这里的set在新增方法里面讲述过,那么来看看APPEND、STRLEN命令吧

命令介绍

APPEND

APPEND key value

在value的尾部追加新值

redis客户端执行的命令如下

append appendKey appendappend appendKey Valueget appendKey

执行结果如下

STRLEN

STRLEN key

返回value的长度

删除

代码如下

@RequestMapping(value = "/delMyLog/{id}", method = RequestMethod.DELETE)public boolean delMyLog(@PathVariable  String id){    return redisTemplate.delete(MY_LOG_REDIS_KEY_PREFIX + id);}

可以看到代码中只用了delete方法,对应着Redis的DEL命令(属于基本命令)

命令介绍

DEL

DEL key [key ...]

删除key

BIT相关命令

bit命令有SETBIT、GETBIT、BITCOUNT、BITFIELD、BITOP、BITPOS这些。

命令这里就不做介绍了,直接讲述bit相关的案例。

Pattern: real time metrics using bitmaps

BITOP is a good complement to the pattern documented in the BITCOUNT command documentation. Different bitmaps can be combined in order to obtain a target bitmap where the population counting operation is performed.

See the article called "Fast easy realtime metrics using Redis bitmaps" for a interesting use cases.

案例地址

网上译文也有许多,有需要的百度或者google即可

这里大概讲述下使用位图法统计日登入用户数、周连续登入用户数和月连续登入用户数

位图法就是bitmap的缩写,所谓bitmap,就是用每一位来存放某种状态,适用于大规模数据,但数据状态又不是很多的情况。通常是用来判断某个数据存不存在的。 ------来自百度百科

就好像java中int有4个字节,也就是32位。当32位全为1时,也就是int的最大值。

位只能被设置位0或者1,也就是二进制。

java中可以用BitSet来操作位的相关操作

场景

有一万个用户,id从1到10000,根据当前是否上线,来设置在第id位上是否为1或者0。通过每天的记录来统计用户连续上线的情况。

分析

一号有id为5、3、1的上线了,二号有id为5、4、3的上线了,三号有id为3、2、1的上线了。存储的数据如下

序号:5 4 3 2 1 0一号:1 0 1 0 1 0二号:1 1 1 0 0 0三号:0 0 1 1 1 0

那么我们只有将三天的数据进行与操作就可以知道,三天连续上线的有哪些了,与操作的结果如下

序号:5 4 3 2 1 0结果:0 0 1 0 0 0

很明显是id为3的用户连续登入3天。

代码

先定义一些常量

//存储的key前缀private static final String ONLINE_KEY_PREFIX = "online:";//天数private static final int DAY_NUM = 30;//用户数量private static final int PEOPLE_NUM = 10000;

然后模拟一个月的数据

public void createData() {    //用来保证线程执行完在进行后面的操作    CountDownLatch countDownLatch = new CountDownLatch(DAY_NUM);    int poolSize = Runtime.getRuntime().availableProcessors() * 2;    ThreadPoolExecutor executor = new ThreadPoolExecutor(poolSize, poolSize, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(DAY_NUM-poolSize));    //DAY_NUM天    for (int i = 1; i <= DAY_NUM; i++) {        int finalI = i;        executor.execute(() -> {            //假设有PEOPLE_NUM个用户            for (int j = 1; j <= PEOPLE_NUM; j++) {                redisTemplate.opsForValue().setBit(ONLINE_KEY_PREFIX + finalI, j, Math.random() > 0.1);            }            countDownLatch.countDown();        });    }    //等待线程全部执行完成    try {        countDownLatch.await();    } catch (InterruptedException e) {        e.printStackTrace();    }}

最后是统计

public void calActive(int day) {    if (day < 0 || day > DAY_NUM){        throw new IllegalArgumentException("传入的天数不能小于0或者大于30天!");    }    long calStart = System.currentTimeMillis();    BitSet active = new BitSet();    active.set(0, PEOPLE_NUM);    for (int i = 1; i <= day; i++) {        BitSet bitSet = BitSet.valueOf(jedis.get((ONLINE_KEY_PREFIX + i).getBytes()));        active.and(bitSet);    }    long calEnd = System.currentTimeMillis();    System.out.println(day + "天的上线用户" + active.cardinality() + ",花费时长:" + (calEnd - calStart));}

测试方法

@Testpublic void daliyActive() {    /**     *模拟数据     */    createData();    /**     * 开始统计     */    //1    calActive(1);    //7    calActive(7);    //15    calActive(15);    //30    calActive(30);}

测试结果

1天的上线用户9015,花费时长:07天的上线用户4817,花费时长:015天的上线用户2115,花费时长:030天的上线用户431,花费时长:15

有需要看相关代码的请点击

其他

关于其他相关的命令可以查看下方地址

命令比较多,但是还是建议学习的人最好每个命令都去敲下,加深印象。

下面诗句送给每一个阅读的人。

纸上得来终觉浅,绝知此事要躬行。————出自《冬夜读书示子聿》

作者:

本文为云栖社区原创内容,未经允许不得转载。 

转载于:https://my.oschina.net/yunqi/blog/1925587

你可能感兴趣的文章
RamDisk块设备驱动实例开发讲解一
查看>>
【CSS3 入门教程系列】CSS3 Media Queries 实现响应式设计
查看>>
VC1.窗体设计-自绘对话框
查看>>
Synergy 一个bug的解决办法
查看>>
HTML5socket通信——postMessage出现的不能提交的问题
查看>>
常用的CSS[持续更新]
查看>>
ssh框架下junit测试
查看>>
html中的fieldset
查看>>
(myconnpy出现,pymysql可以入冷宫了)打个小补丁,让pymysql正确处理日期类型和NULL类型 - MK2 - 博客园...
查看>>
MySQL的复制主从设置
查看>>
简要记录浮点型数据的二进制存储格式
查看>>
git 创建 .gitignore 文件 建立项目过滤规则
查看>>
LETTERS(搜索题)
查看>>
android完全退出应用程序
查看>>
使用SQLIO测试磁盘性能
查看>>
大学两年读了大概 200 本书,为什么感觉读书的价值还是没有体现出来呢?
查看>>
浏览器 的 session 如何保持?!
查看>>
.net 破解的几个常用工具
查看>>
设置输入域(input/textarea)中文本光标的位置
查看>>
sql server 还原数据库时提示数据库正在使用,无法进行操作的解决方法
查看>>