版本
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-data-redis</artifactid>
<version>2.7.3</version>
</dependency>
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-dependencies</artifactid>
<version>2.6.13</version>
</dependency>rediscache 文件
@component
public class rediscache
{
@autowired
public redistemplate redistemplate;
}一、基础操作
1.1 key 相关操作
// 删除 key
redistemplate.delete("key");
// 删除多个 key
redistemplate.delete(arrays.aslist("key1", "key2"));
// 判断 key 是否存在
boolean exists = redistemplate.haskey("key");
// 设置过期时间(秒)
redistemplate.expire("key", 60, timeunit.seconds);
// 获取过期时间
long expiretime = redistemplate.getexpire("key");
// 移除过期时间,永久保存
redistemplate.persist("key");
// 获取所有匹配的 key
set<string> keys = redistemplate.keys("pattern*");1.2 通用操作
// 获取 key 的类型
datatype type = redistemplate.type("key");
// 随机获取一个 key
string randomkey = redistemplate.randomkey();
// 重命名 key
redistemplate.rename("oldkey", "newkey");
// 移动 key 到指定数据库
redistemplate.move("key", 1);二、string 类型操作
2.1 基本操作
// 设置值
redistemplate.opsforvalue().set("key", "value");
// 设置值并设置过期时间
redistemplate.opsforvalue().set("key", "value", 10, timeunit.minutes);
// 获取值
string value = (string) redistemplate.opsforvalue().get("key");
// 设置新值并返回旧值
object oldvalue = redistemplate.opsforvalue().getandset("key", "newvalue");
// 批量设置
map<string, string> map = new hashmap<>();
redistemplate.opsforvalue().multiset(map);
// 批量获取
list<object> values = redistemplate.opsforvalue().multiget(arrays.aslist("key1", "key2"));2.2 数值操作
// 递增
long incremented = redistemplate.opsforvalue().increment("counter", 1);
// 递减
long decremented = redistemplate.opsforvalue().decrement("counter", 1);
// 浮点数增加
double doublevalue = redistemplate.opsforvalue().increment("doublekey", 1.5);三、hash 类型操作
// 设置单个 field
redistemplate.opsforhash().put("hashkey", "field", "value");
// 获取单个 field
object fieldvalue = redistemplate.opsforhash().get("hashkey", "field");
// 设置多个 field
map<string, string> hashmap = new hashmap<>();
redistemplate.opsforhash().putall("hashkey", hashmap);
// 获取所有 field
map<object, object> allentries = redistemplate.opsforhash().entries("hashkey");
// 删除 field
redistemplate.opsforhash().delete("hashkey", "field1", "field2");
// 判断 field 是否存在
boolean hasfield = redistemplate.opsforhash().haskey("hashkey", "field");
// 获取所有 keys(fields)
set<object> hashkeys = redistemplate.opsforhash().keys("hashkey");
// 获取所有 values
list<object> hashvalues = redistemplate.opsforhash().values("hashkey");
// 获取大小
long size = redistemplate.opsforhash().size("hashkey");四、list 类型操作
// 左侧插入
redistemplate.opsforlist().leftpush("listkey", "value");
// 右侧插入
redistemplate.opsforlist().rightpush("listkey", "value");
// 批量插入
redistemplate.opsforlist().rightpushall("listkey", "v1", "v2", "v3");
// 左侧弹出
object leftvalue = redistemplate.opsforlist().leftpop("listkey");
// 右侧弹出
object rightvalue = redistemplate.opsforlist().rightpop("listkey");
// 获取列表长度
long listsize = redistemplate.opsforlist().size("listkey");
// 获取指定范围元素
list<object> range = redistemplate.opsforlist().range("listkey", 0, -1);
// 根据索引获取元素
object element = redistemplate.opsforlist().index("listkey", 1);
// 设置指定位置的值
redistemplate.opsforlist().set("listkey", 0, "newvalue");
// 删除指定值的元素
redistemplate.opsforlist().remove("listkey", 1, "value");五、set 类型操作
// 添加元素
redistemplate.opsforset().add("setkey", "value1", "value2");
// 获取所有元素
set<object> members = redistemplate.opsforset().members("setkey");
// 判断是否成员
boolean ismember = redistemplate.opsforset().ismember("setkey", "value");
// 删除元素
long removed = redistemplate.opsforset().remove("setkey", "value");
// 获取大小
long setsize = redistemplate.opsforset().size("setkey");
// 求交集
set<object> intersect = redistemplate.opsforset().intersect("set1", "set2");
// 求并集
set<object> union = redistemplate.opsforset().union("set1", "set2");
// 求差集
set<object> difference = redistemplate.opsforset().difference("set1", "set2");六、zset(有序集合)操作
// 添加元素(带分数)
redistemplate.opsforzset().add("zsetkey", "value", 100);
// 获取分数
double score = redistemplate.opsforzset().score("zsetkey", "value");
// 增加分数
double newscore = redistemplate.opsforzset().incrementscore("zsetkey", "value", 10);
// 按排名范围获取
set<object> rangebyrank = redistemplate.opsforzset().range("zsetkey", 0, -1);
// 按分数范围获取
set<object> rangebyscore = redistemplate.opsforzset().rangebyscore("zsetkey", 0, 100);
// 获取排名(从低到高)
long rank = redistemplate.opsforzset().rank("zsetkey", "value");
// 获取排名(从高到低)
long reverserank = redistemplate.opsforzset().reverserank("zsetkey", "value");
// 删除元素
redistemplate.opsforzset().remove("zsetkey", "value");
// 按排名范围删除
redistemplate.opsforzset().removerange("zsetkey", 0, 5);
// 按分数范围删除
redistemplate.opsforzset().removerangebyscore("zsetkey", 0, 50);七、事务操作
// 开启事务支持
redistemplate.setenabletransactionsupport(true);
// 执行事务
list<object> results = redistemplate.execute(new sessioncallback<list<object>>() {
@override
public list<object> execute(redisoperations operations) throws dataaccessexception {
operations.multi(); // 开始事务
operations.opsforvalue().set("key1", "value1");
operations.opsforvalue().set("key2", "value2");
return operations.exec(); // 执行事务
}
});八、管道操作
// 使用管道批量操作
list<object> results = redistemplate.executepipelined(new rediscallback<object>() {
@override
public object doinredis(redisconnection connection) throws dataaccessexception {
connection.openpipeline();
connection.set("key1".getbytes(), "value1".getbytes());
connection.set("key2".getbytes(), "value2".getbytes());
return null;
}
});
九、发布订阅
// 发送消息到频道
redistemplate.convertandsend("channelname", "message content");
// 接收消息需要配置 messagelistener(通常通过配置类实现)十、lua脚本执行
// 执行 lua 脚本
defaultredisscript<long> script = new defaultredisscript<>();
script.setscripttext("return redis.call('get', keys[1])");
script.setresulttype(long.class);
long result = redistemplate.execute(script, arrays.aslist("key"));到此这篇关于redis 中 redistemplate 的所有操作与函数详解的文章就介绍到这了,更多相关redis redistemplate函数内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!
发表评论