Redis学习笔记-2
本帖最后由 tomcar 于 2021-8-6 07:48 编辑2、分布式锁
>setnx lock:codehole true
....
>del lock:codehole
>setnx lock:codehole true
>expire lock:codehole 5 #5s后释放锁
...
>del lock:codehole
为了解决setnx与expire之间出现的一些不可预测问题，做了改进
>set lock:codehole true ex 5 nx
...
>del lock:codehole
3、延时队列实现
rpush lpop lpush rpop
pop改为延时pop，不会使队列中空了还在一直pop浪费资源
lpop -> blpop
rpop -> brpop
代码实现：
import java.lang.reflect.Type;
import java.util.Set;
import java.util.UUID;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import redis.clients.jedis.Jedis;
public class RedisDelayingQueue<T> {
static class TaskItem<T> {
public String id;
public T msg;
}
// fastjson 序列化对象中存在 generic 类型时，需要使用 TypeReference
private Type TaskType = new TypeReference<TaskItem<T>>() { }.getType();
private Jedis jedis;
private String queueKey;
public RedisDelayingQueue(Jedis jedis, String queueKey) {
this.jedis = jedis;
this.queueKey = queueKey;
}
public void delay(T msg) {
TaskItem task = new TaskItem();
task.id = UUID.randomUUID().toString(); // 分配唯一的 uuid
task.msg = msg;
String s = JSON.toJSONString(task); // fastjson 序列化
jedis.zadd(queueKey, System.currentTimeMillis() + 5000, s); // 塞入延时队列 ,5s 后再试
}
public void loop() {
while (!Thread.interrupted()) {
// 只取一条
Set values = jedis.zrangeByScore(queueKey, 0, System.currentTimeMillis(), 0, 1);
if (values.isEmpty()) {
try {
Thread.sleep(500); // 歇会继续
} catch (InterruptedException e) {
break;
}
continue;
}
String s = values.iterator().next();
if (jedis.zrem(queueKey, s) > 0) { // 抢到了
TaskItem task = JSON.parseObject(s, TaskType); // fastjson 反序列化
this.handleMsg(task.msg);
}
}
}
public void handleMsg(T msg) {
System.out.println(msg);
}
public static void main(String[] args) {
Jedis jedis = new Jedis();
RedisDelayingQueue queue = new RedisDelayingQueue<>(jedis, "q-demo");
Thread producer = new Thread() {
public void run() {
for (int i = 0; i < 10; i++) {
queue.delay("codehole" + i);
}
}
};
Thread consumer = new Thread() {
public void run() {
queue.loop();
}
};
producer.start();
consumer.start();
try {
producer.join();
Thread.sleep(6000);
consumer.interrupt();
consumer.join();
} catch (InterruptedException e) {
}
}}
4、位图
>setbit s 1 1 #10000000
>setbit s 2 1 #11000000
>setbit s 4 1 #11010000
>setbit s 9 1 #11010000 10000000
>setbit s 10 1 #11010000 11000000
>setbit s 13 1 #11010000 11001000
>setbit s 15 1 #11010000 11001010
>get s #"he"
>getbit s 1 #1
>set w hello
>bitcount w #21
>bitcount w 0 0 #第一个字符中1的个数
>bitcount w 0 1 #第二个字符中1的个数
>bitpos w 0 #第一个0位
>bitpos w 1 #第一个1位
>bitpos w 1 1 1 #从第二个字符算起，第一个1位
>bitpos w 1 2 2 #从第三个字符算起，第一个1位
4.1、魔术指令 bitfield
>bitfield w get u4 0 #从第一位开始取，取4个位，结果是无符号数(u)
>bitfield w get u4 2 #从第三位开始取，取4个位，结果是无符号数(u)
>bitfield w get i2 3 #从第四位开始取，取2个位，结果是有符号数(i)
>bitfield w set u8 8 97 #从第八位开始，将接下来的8个位替换成无符号数97
>get w #"hallo"
>bitfield w incrby u4 2 1 #从第三位开始，对接下来的4位无符号数+1
饱和截断SAT
>bitfield w overflow sat incrby u4 2 1 #从第三位开始，对接下来的4位无符号数+1，如果4个无符号数都为1，则不增加，保持最大值，返回为 最大值
失败不执行 FAIL
>bitfield w overflow fail incrby u4 2 1 #从第三位开始，对接下来的4位无符号数+1，如果4个无符号数都为1，则不执行，返回为 nil 看不懂没关系支持支持 tang588 发表于 2021-7-25 22:55
看不懂没关系支持支持
谢谢谢谢
页:
[1]