栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Redisson--SpringBoot--整合/使用/用法/实例/示例/实战/教程/官网--Redis客户端

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Redisson--SpringBoot--整合/使用/用法/实例/示例/实战/教程/官网--Redis客户端

原文网址:Redisson--SpringBoot--整合/使用/用法/实例/示例/实战/教程/官网--Redis客户端_IT利刃出鞘的博客-CSDN博客

简介

说明

        Redis的客户端有RedisTemplate、Jedis、Redisson等。Redisson是最好的客户端,原因如下:

  1. 简单好用。
    1. 它实现了JDK里的List、Set、Map等接口,可以用操作JDK的类的方式操作Redis。
  2. 分布式锁很完美。
    1. 它在锁的续期、可重入、释放等处理的很好。详见:Redisson原理--Redis分布式锁--方案/机制--续期/释放/互斥/可重入_IT利刃出鞘的博客-CSDN博客

官网

git文档:https://github.com/redisson/redisson/wiki
git:https://github.com/redisson/redisson
官网:https://redisson.org/

Redisson功能

  • 支持同步/异步/异步流/管道流方式连接
  • 多样化数据序列化
  • 集合数据分片
  • 分布式对象
  • 分布式集合
  • 分布式锁和同步器
  • 分布式服务
  • 独立节点模式
  • 三方框架整合
依赖

    org.redisson
    redisson-spring-boot-starter
    3.16.1

当然,只引用Redisson也可以。(但这样配置繁琐,本文不使用此法)


      org.redisson
      redisson
      3.8.2
配置

官网

2. 配置方法 · redisson/redisson Wiki · GitHub(官网wiki的配置文档)

简介

        以下方法的推荐度由高到低。

        对于配置文件方案,引入的依赖必须是redisson-spring-boot-starter;对于配置类配置方案,引入的依赖可以是redisson-spring-boot-starter也可以是redisson。

法1:application.yml

spring:
  redis:
    host: 
    port: 
    database: 
    password: 
    cluster:
      nodes: 
    sentinel:
      master: 
      nodes: 
    ssl: 
    timeout: 

上边这个redis的通用配置基本够用了。可对Redisson进行更加详细的配置:哨兵、集群等

spring:
  redis:
    host: 
    port: 
    database: 
    password: 
    cluster:
      nodes: 
    sentinel:
      master: 
      nodes: 
    ssl: 
    timeout: 
    redisson:
      clusterServersConfig:
        idleConnectionTimeout: 10000
        connectTimeout: 10000
        timeout: 3000
        retryAttempts: 3
        retryInterval: 1500
        password: null
        subscriptionsPerConnection: 5
        clientName: null
        loadBalancer: ! {}
        slaveSubscriptionConnectionMinimumIdleSize: 1
        slaveSubscriptionConnectionPoolSize: 50
        slaveConnectionMinimumIdleSize: 32
        slaveConnectionPoolSize: 64
        masterConnectionMinimumIdleSize: 32
        masterConnectionPoolSize: 64
        readMode: "SLAVE"
        nodeAddresses:
        - "redis://127.0.0.1:7004"
        - "redis://127.0.0.1:7001"
        - "redis://127.0.0.1:7000"
        scanInterval: 1000
      threads: 0
      nettyThreads: 0
      codec: ! {}
      "transportMode":"NIO"

法2:将redisson配置单独拿出来  

需要在Resource目录下创建redisson.yml。 

redisson配置文件优先级高于springboot配置文件优先级;

application.yml

spring:
  redis:
    host: 
    port: 
    database: 
    password: 
    cluster:
      nodes: 
    sentinel:
      master: 
      nodes: 
    ssl: 
    timeout: 
    redisson:
      config: classpath:redisson.yml

redisson.yml

clusterServersConfig:
  idleConnectionTimeout: 10000
  connectTimeout: 10000
  timeout: 3000
  retryAttempts: 3
  retryInterval: 1500
  password: null
  subscriptionsPerConnection: 5
  clientName: null
  loadBalancer: ! {}
  slaveSubscriptionConnectionMinimumIdleSize: 1
  slaveSubscriptionConnectionPoolSize: 50
  slaveConnectionMinimumIdleSize: 32
  slaveConnectionPoolSize: 64
  masterConnectionMinimumIdleSize: 32
  masterConnectionPoolSize: 64
  readMode: "SLAVE"
  nodeAddresses:
  - "redis://127.0.0.1:7004"
  - "redis://127.0.0.1:7001"
  - "redis://127.0.0.1:7000"
  scanInterval: 1000
threads: 0
nettyThreads: 0
codec: ! {}
"transportMode":"NIO"

法3:编写配置类(不推荐)

需要在Resource目录下创建redisson.yml。  

@Configuration
public class RedssonConfig {
    @Bean(destroyMethod="shutdown")
    public RedissonClient redisson() throws IOException {
        RedissonClient redisson = Redisson.create(
                Config.fromYAML(new ClassPathResource("redisson-single.yml").getInputStream()));
        return redisson;
    }
}

        上边这种方法已经违背配置大于编程了。

法4:用代码配置(不推荐)

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RedissonConfig {
    @Bean
    public RedissonClient redissonClient() {
		//指定编码,默认编码为org.redisson.codec.JsonJacksonCodec   
		//config.setCodec(new org.redisson.client.codec.StringCodec());  
		
		config.useSingleServer().setAddress("redis://127.0.0.1:6379");  
		config.useSingleServer().setClientName("root");
		config.useSingleServer().setPassword("abcabc");
		 
        return Redisson.create(config);
    }
}
实例

其他网址

2-(1)、SpringBoot整合redisson实现分布式锁 - 简书
(Redis使用系列) Springboot 整合Redisson 实现分布式锁 七-CSDN博客
SpringBoot集成redisson分布式锁 - 自行车上的程序员 - 博客园

代码 

package com.xiaoliu.redission.lock;

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ShopCartController {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Autowired
    private RedissonClient redissonClient;

    private static final String product="MoonCake";

    @GetMapping("/submitOrder")
    public String submitOrder(){
        RLock lock = redissonClient.getLock(product);

        try {
            lock.lock();//阻塞
//            boolean b = lock.tryLock();//非阻塞
            int stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
            if (stock>0){
                //下单
                stock-=1;
                stringRedisTemplate.opsForValue().set("stock", String.valueOf(stock));
                System.out.println("扣减成功,库存stock:"+stock);
            }else {
                //没库存
                System.out.println("扣减失败,库存不足");
            }
        } finally {
            lock.unlock();//释放锁
        }
        return "end";
    }
}
常用操作 

获得Redisson客户端

@Autowired
private RedissonClient redissonClient;

根据key获得value

所有get开头的方法:如果key不存在会在保存时以此key为key保存。

方法返回类型
getSet("xxx")RSet
getList("xxx")RList
getMap("anyMap");RMap
getSetMultimap("myMultimap");RSetMultimap
getSortedSet("anySet");RSortedSet
getScoredSortedSet("simple");RScoredSortedSet
getLexSortedSet("simple");RLexSortedSet set
getQueue("anyQueue");RQueue
getDeque("anyDeque");RDeque
getBlockingQueue("anyQueue");BlockingQueue
getBoundedBlockingQueue("anyQueue");RBoundedBlockingQueue
getBlockingDeque("anyDeque");RBlockingDeque
getBlockingFairQueue("myQueue");RBlockingFairQueue
getBlockingFairDeque("myDeque");RBlockingFairDeque
getDelayedQueue(distinationQueue);RDelayedQueue
getPriorityQueue("anyQueue");RPriorityQueue
getPriorityDeque("anyQueue");RPriorityDeque
getPriorityBlockingQueue("anyQueue");RPriorityBlockingQueue
RPriorityBlockingDequegetPriorityBlockingDeque("anyQueue");

将key-value写回Redis

所有添加都会自动将值写回Redis。例如:

RSet set = redisson.getSet("anySet");
set.add("Tony");
所有方法

过期时间

所有的类型都有过期时间,例如:

RSet set = redisson.getSet("anySet");
set.add("Tony");
set.expire(3, TimeUnit.MINUTES);

过期时间在类型为空时是无效的,例如:

RSet set = redisson.getSet("anySet");
set.expire(3, TimeUnit.MINUTES);
set.add("Tony");

也可以给某一个值设置过期时间

RSetCache set = redisson.getSetCache("anySet");
// ttl = 10 seconds
set.add("abc", 10, TimeUnit.SECONDS);
Redis命令与Redisson方法对应
Redis commandSync / Async Api
Redisson.create(config)
Reactive Api
Redisson.createReactive(config)
RxJava2 Api
Redisson.createRx(config)
AUTHConfig.setPassword()--
APPENDRBinaryStream.
getOutputStream().write()
--
BZPOPMAXRScoredSortedSet.
pollLast()
pollLastAsync()
RScoredSortedSetReactive.
pollLast()
RScoredSortedSetRx.
pollLast()
BZPOPMINRScoredSortedSet.
pollFirst()
pollFirstAsync()
RScoredSortedSetReactive.
pollFirst()
RScoredSortedSetRx.
pollFirst()
BITCOUNTRBitSet.
cardinality()
cardinalityAsync()
RBitSetReactive.
cardinality()
RBitSetRx.
cardinality()
BITOPRBitSet.
or()
and()
xor()
orAsync()
andAsync()
xorAsync()
RBitSetReactive.
or()
and()
xor()
RBitSetRx.
or()
and()
xor()
BITPOSRBitSet.
length()
lengthAsync()
RBitSetReactive.
length()
RBitSetRx.
length()
BLPOPRBlockingQueue.
take()
poll()
pollFromAny()
takeAsync()
pollAsync()
pollFromAnyAsync()
RBlockingQueueReactive.
take()
poll()
pollFromAny()
RBlockingQueueRx.
take()
poll()
pollFromAny()
BRPOPRBlockingDeque.
takeLast()
takeLastAsync()
RBlockingDequeReactive.
takeLast()
RBlockingDequeRx.
takeLast()
BRPOPLPUSHRBlockingQueue.
pollLastAndOfferFirstTo()
pollLastAndOfferFirstToAsync()
RBlockingQueueReactive.
pollLastAndOfferFirstTo()
RBlockingQueueRx.
pollLastAndOfferFirstTo()
ConFIG GETRedisNode.
setConfig()
setConfigAsync()
--
ConFIG SETRedisNode.
getConfig()
getConfigAsync()
--
COPYRObject.
copy()
copyAsync()
RObjectReactive.
copy()
RObjectRx.
copy()
CLIENT SETNAMEConfig.setClientName()--
CLIENT REPLYBatchOptions.skipResult()--
CLUSTER INFOClusterNode.info()--
CLUSTER KEYSLOTRKeys.
getSlot()
getSlotAsync()
RKeysReactive.
getSlot()
RKeysRx.
getSlot()
CLUSTER NODESUsed in ClusterConnectionManager
DECRBYRAtomicLong.
addAndGet()
addAndGetAsync()
RAtomicLongReactive.
addAndGet()
RAtomicLongRx.
addAndGet()
DUMPRObject.
dump()
dumpAsync()
RObjectReactive.
dump()
RObjectRx.
dump()
DBSIZERKeys.
count()
countAsync()
RKeysReactive.
count()
RKeysRx.count()
DECRRAtomicLong.
decrementAndGet()
decrementAndGetAsync()
RAtomicLongReactive.
decrementAndGet()
RAtomicLongRx.
decrementAndGet()
DELRObject.
delete()
deleteAsync()

RKeys.
delete()
deleteAsync()
RObjectReactive.
delete()

RKeysReactive.
delete()
RObjectRx.
delete()

RKeysRx.
delete()
STRLENRBucket.
size()
sizeAsync()
RBucketReactive.
size()
RBucketRx.
size()
evalRscript.
eval()
evalAsync()
RscriptReactive.
eval()
RscriptRx.
eval()
evalSHARscript.
evalSha()
evalShaAsync()
RscriptReactive.
evalSha()
RscriptRx.
evalSha()
EXECRBatch.
execute()
executeAsync()
RBatchReactive.
execute()
RBatchRx.
execute()
EXISTSRObject.
isExists()
isExistsAsync()
RObjectReactive.
isExists()
RObjectRx.
isExists()
FLUSHALLRKeys.
flushall()
flushallAsync()
RKeysReactive.
flushall()
RKeysRx.
flushall()
FLUSHDBRKeys.
flushdb()
flushdbAsync()
RKeysReactive.
flushdb()
RKeysRx.
flushdb()
GETRANGERBinaryStream.
getChannel().read()
RBinaryStreamReactive.
read()
RBinaryStreamRx.
read()
GEOADDRGeo.
add()
addAsync()
RGeoReactive.
add()
RGeoRx.
add()
GEODISTRGeo.
dist()
distAsync()
RGeoReactive.
dist()
RGeoRx.
dist()
GEOHASHRGeo.
hash()
hashAsync()
RGeoReactive.
hash()
RGeoRx.
hash()
GEOPOSRGeo.
pos()
posAsync()
RGeoReactive.
pos()
RGeoRx.
pos()
GEORADIUSRGeo.
radius()
radiusAsync()
radiusWithDistance()
radiusWithDistanceAsync()
radiusWithPosition()
radiusWithPositionAsync()
RGeoReactive.
radius()
radiusWithDistance()
radiusWithPosition()
RGeoRx.
radius()
radiusWithDistance()
radiusWithPosition()
GETRBucket.
get()
getAsync()

RBinaryStream.
get()
getAsync()
RBucketReactive.
get()

RBinaryStreamReactive.
get()
RBucketRx.
get()

RBinaryStreamRx.
get()
GETBITRBitSet.
get()
getAsync()
RBitSetReactive.
get()
RBitSetRx.
get()
GETSETRBucket.
getAndSet()
getAndSetAsync()

RAtomicLong.
getAndSet()
getAndSetAsync()

RAtomicDouble.
getAndSet()
getAndSetAsync()
RBucketReactive.
getAndSet()

RAtomicLongReactive.
getAndSet()

RAtomicDoubleReactive.
getAndSet()
RBucketRx.
getAndSet()

RAtomicLongRx.
getAndSet()

RAtomicDoubleRx.
getAndSet()
HDELRMap.
fastRemove()
fastRemoveAsync()
RMapReactive.
fastRemove()
RMapRx.
fastRemove()
HEXISTSRMap.
containsKey()
containsKeyAsync()
RMapReactive.
containsKey()
RMapRx.
containsKey()
HGETRMap.
get()
getAsync()
RMapReactive.
get()
RMapRx.
get()
HSTRLENRMap.
valueSize()
valueSizeAsync()
RMapReactive.
valueSize()
RMapRx.
valueSize()
HGETALLRMap.
readAllEntrySet()
readAllEntrySetAsync()
RMapReactive.
readAllEntrySet()
RMapRx.
readAllEntrySet()
HINCRBYRMap.
addAndGet()
addAndGetAsync()
RMapReactive.
addAndGet()
RMapRx.
addAndGet()
HINCRBYFLOATRMap.
addAndGet()
addAndGetAsync()
RMapReactive.
addAndGet()
RMapRx.
addAndGet()
HKEYSRMap.
readAllKeySet()
readAllKeySetAsync()
RMapReactive.
readAllKeySet()
RMapRx.
readAllKeySet()
HLENRMap.
size()
sizeAsync()
RMapReactive.
size()
RMapRx.
size()
HMGETRMap.
getAll()
getAllAsync()
RMapReactive.
getAll()
RMapRx.
getAll()
HMSETRMap.
putAll()
putAllAsync()
RMapReactive.
putAll()
RMapRx.
putAll()
HSCANRMap.
keySet().iterator()
values().iterator()
entrySet().iterator()
RMapReactive.
keyIterator()
valueIterator()
entryIterator()
RMapRx.
keyIterator()
valueIterator()
entryIterator()
HSETRMap.
fastPut()
fastPutAsync()
RMapReactive.
fastPut()
RMapRx.
fastPut()
HSETNXRMap.
fastPutIfAbsent()
fastPutIfAbsentAsync()
RMapReactive.
fastPutIfAbsent()
RMapRx.
fastPutIfAbsent()
HVALSRMap.
readAllValues()
readAllValuesAsync()
RMapReactive.
readAllValues()
RMapRx.
readAllValues()
INCRRAtomicLong.
incrementAndGet()
incrementAndGetAsync()
RAtomicLongReactive.
incrementAndGet()
RAtomicLongRx.
incrementAndGet()
INCRBYRAtomicLong.
addAndGet()
addAndGetAsync()
RAtomicLongReactive.
addAndGet()
RAtomicLongRx.
addAndGet()
INCRBYFLOATRAtomicDouble.
addAndGet()
addAndGetAsync()
RAtomicDoubleReactive.
addAndGet()
RAtomicDoubleRx.
addAndGet()
KEYSRKeys.
getKeysByPattern()
getKeysByPatternAsync()
RKeysReactive.
getKeysByPattern()
RKeysRx.
getKeysByPattern()
LINDEXRList.
get()
getAsync()
RListReactive.
get()
RListRx.
get()
LLENRList.
size()
sizeAsync()
RListReactive.
size()
RListRx.
size()
LPOPRQueue.
poll()
pollAsync()
RQueueReactive.
poll()
RQueueRx.
poll()
LPUSHRDeque.
addFirst()
addFirstAsync()
RDequeReactive.
addFirst()
LRANGERList.
readAll()
readAllAsync()
RListReactive.readAll()RListRx.readAll()
LPUSHXRDeque.
addFirstIfExists()
addFirstIfExistsAsync()
RDequeReactive.
addFirstIfExists()
RDequeRx.
addFirstIfExists()
LREMRList.
fastRemove()
fastRemoveAsync()
RListReactive.
fastRemove()
RListRx.
fastRemove()
LSETRList.
fastSet()
fastSetAsync()
RListReactive.
fastSet()
RListRx.
fastSet()
LTRIMRList.
trim()
trimAsync()
RListReactive.
trim()
RListRx.
trim()
LINSERTRList.
addBefore()
addAfter()
addBeforeAsync()
addAfterAsync()
RListReactive.
addBefore()
addAfter()
RListRx.
addBefore()
addAfter()
MULTIRBatch.
execute()
executeAsync()
RBatchReactive.
execute()
RBatchRx.
execute()
MGETRBuckets.
get()
getAsync()
RBucketsReactive.
get()
RBucketsRx.
get()
MSETNXRBuckets.
trySet()
trySetAsync()
RBucketsReactive.
trySet()
RBucketsRx.
trySet()
MIGRATERObject.
migrate()
migrateAsync()
RObjectReactive.
migrate()
RObjectRx.
migrate()
MOVERObject.
move()
moveAsync()
RObjectReactive.
move()
RObjectRx.
move()
MSETRBuckets.
set()
setAsync()
RBucketsReactive.
set()
RBucketsRx.
set()
PERSISTRExpirable.
clearExpire()
clearExpireAsync()
RExpirableReactive.
clearExpire()
RExpirableRx.
clearExpire()
PEXPIRERExpirable.
expire()
expireAsync()
RExpirableReactive.
expire()
RExpirableRx.
expire()
PEXPIREATRExpirable.
expireAt()
expireAtAsync()
RExpirableReactive.
expireAt()
RExpirableRx.
expireAt()
PFADDRHyperLogLog.
add()
addAsync()
addAll()
addAllAsync()
RHyperLogLogReactive.
add()

addAll()
RHyperLogLogRx.
add()

addAll()
PFCOUNTRHyperLogLog.
count()
countAsync()
countWith()
countWithAsync()
RHyperLogLogReactive.
count()
countWith()
RHyperLogLogRx.
count()
countWith()
PFMERGERHyperLogLog.
mergeWith()
mergeWithAsync()
RHyperLogLogReactive.
mergeWith()
RHyperLogLogRx.
mergeWith()
PINGNode.ping()
NodesGroup.pingAll()
--
PSUBSCRIBERPatternTopic.
addListener()
RPatternTopicReactive.
addListener()
RPatternTopicRx.
addListener()
PSETEXRBucket.
set()
setAsync()
RBucketReactive.
set()
RBucketRx.
set()
PTTLRExpirable.
remainTimeToLive()
remainTimeToLiveAsync()
RExpirableReactive.
remainTimeToLive()
RExpirableRx.
remainTimeToLive()
PUBLISHRTopic.
publish()
RTopicReactive.
publish()
RTopicRx.
publish()
PUBSUB NUMSUBRTopic.
countSubscribers()
countSubscribersAsync()
RTopicReactive.
countSubscribers()
RTopicRx.
countSubscribers()
PUNSUBSCRIBERPatternTopic.
removeListener()
RPatternTopicReactive.
removeListener()
RPatternTopicRx.
removeListener()
RANDOMKEYRKeys.
randomKey()
randomKeyAsync()
RKeysReactive.
randomKey()
RKeysRx.
randomKey()
RESTORERObject.
restore()
restoreAsync()
RObjectReactive.
restore()
RObjectRx.
restore()
RENAMERObject.
rename()
renameAsync()
RObjectReactive.
rename()
RObjectRx.
rename()
RPOPRDeque.
pollLast()
removeLast()
pollLastAsync()
removeLastAsync()
RDequeReactive.
pollLast()
removeLast()
RDequeRx.
pollLast()
removeLast()
RPOPLPUSHRDeque.
pollLastAndOfferFirstTo()
pollLastAndOfferFirstToAsync()
RDequeReactive.
pollLastAndOfferFirstTo()
RDequeRx.
pollLastAndOfferFirstTo()
RPUSHRList.
add()
addAsync()
RListReactive.
add()
RListRx.
add()
RPUSHXRDeque.
addLastIfExists()
addLastIfExistsAsync()
RListReactive.
addLastIfExists()
RListRx.
addLastIfExists()
SADDRSet.
add()
addAsync()
RSetReactive.
add()
RSetRx.
add()
SETRANGERBinaryStream.
getChannel().write()
RBinaryStreamReactive.
write()
RBinaryStreamRx.
write()
SCANRKeys.
getKeys()
RKeysReactive.
getKeys()
RKeysRx.
getKeys()
SCARDRSet.
size()
sizeAsync()
RSetReactive.
size()
RSetRx.
size()
script EXISTSRscript.
scriptExists()
scriptExistsAsync()
RscriptReactive.
scriptExists()
RscriptRx.
scriptExists()
script FLUSHRscript.
scriptFlush()
scriptFlushAsync()
RscriptReactive.
scriptFlush()
RscriptRx.
scriptFlush()
script KILLRscript.
scriptKill()
scriptKillAsync()
RscriptReactive.
scriptKill()
RscriptRx.
scriptKill()
script LOADRscript.
scriptLoad()
scriptLoadAsync()
RscriptReactive.
scriptLoad()
RscriptRx.
scriptLoad()
SDIFFSTORERSet.
diff()
diffAsync()
RSetReactive.
diff()
RSetRx.
diff()
SDIFFRSet.
readDiff()
readDiffAsync()
RSetReactive.
readDiff()
RSetRx.
readDiff()
SRANDMEMBERRSet.
random()
randomAsync()
RSetReactive.
random()
RSetRx.
random()
SELECTConfig.setDatabase()--
SETRBucket.
set()
setAsync()
RBucketReactive.
set()
RBucketRx.
set()
SETBITRBitSet.
set()
clear()
setAsync()
clearAsync()
RBitSetReactive.
set()
clear()
RBitSetRx.
set()
clear()
SETEXRBucket.
set()
setAsync()
RBucketReactive.
set()
RBucketRx.
set()
SETNXRBucket.
trySet()
trySetAsync()
RBucketReactive.
trySet()
RBucketRx.
trySet()
SISMEMBERRSet.
contains()
containsAsync()
RSetReactive.
contains()
RSetRx.
contains()
SINTERSTORERSet.
intersection()
intersectionAsync()
RSetReactive.
intersection()
RSetRx.
intersection()
SINTERRSet.
readIntersection()
readIntersectionAsync()
RSetReactive.
readIntersection()
RSetRx.
readIntersection()
SMEMBERSRSet.
readAll()
readAllAsync()
RSetReactive.
readAll()
RSetRx.
readAll()
SMOVERSet.
move()
moveAsync()
RSetReactive.
move()
RSetRx.
move()
SORTRList.
readSort()
sortTo()
readSortAsync()
sortToAsync()
RListReactive.
readSort()
sortTo()
RListRx.
readSort()
sortTo()
SPOPRSet.
removeRandom()
removeRandomAsync()
RSetReactive.
removeRandom()
RSetRx.
removeRandom()
SREMRSet.
remove()
removeAsync()
RSetReactive.
remove()
RSetRx.
remove()
SSCANRSet.
iterator()
RSetReactive.
iterator()
RSetRx.
iterator()
SUBSCRIBERTopic.
addListener()
RTopicReactive.
addListener()
RTopicRx.
addListener()
SUNIOnRSet.
readUnion()
readUnionAsync()
RSetReactive.
readUnion()
RSetRx.
readUnion()
SUNIOnSTORERSet.
union()
unionAsync()
RSetReactive.
union()
RSetRx.
union()
SWAPDBRKeys.
swapdb()
swapdbAsync()
RKeysReactive.
swapdb()
RKeysRx.
swapdb()
TTLRExpirable.
remainTimeToLive()
remainTimeToLiveAsync()
RExpirableReactive.
remainTimeToLive()
RExpirableRx.
remainTimeToLive()
TYPERKeys.
getType()
getTypeAsync()
RKeysReactive.
getType()
RKeysRx.
getType()
TOUCHRObject.
touch()
touchAsync()
RObjectReactive.
touch()
RObjectRx.
touch()
UNSUBSCRIBERTopic.
removeListener()
RTopicReactive.
removeListener()
RTopicRx.
removeListener()
UNlinkRObject.
unlink()
unlinkAsync()
RObjectReactive.
unlink()
RObjectRx.
unlink()
WAITBatchOptions.
syncSlaves()
BatchOptions.
syncSlaves()
BatchOptions.
syncSlaves()
ZADDRScoredSortedSet.
add()
addAsync()
RScoredSortedSetReactive.
add()
RScoredSortedSetRx.
add()
ZCARDRScoredSortedSet.
size()
sizeAsync()
RScoredSortedSetReactive.
size()
RScoredSortedSetRx.
size()
ZCOUNTRScoredSortedSet.
count()
countAsync()
RScoredSortedSetReactive.
count()
RScoredSortedSetRx.
count()
ZINCRBYRScoredSortedSet.
addScore()
addScoreAsync()
RScoredSortedSetReactive.
addScore()
RScoredSortedSetRx.
addScore()
ZREMRANGEBYRANKRScoredSortedSet.
removeRangeByRank()
removeRangeByRankAsync()
RScoredSortedSetReactive.
removeRangeByRank()
RScoredSortedSetRx.
removeRangeByRank()
ZREVRANGEBYLEXRLexSortedSet.
rangeReversed()
rangeReversedAsync()
RLexSortedSetReactive.
rangeReversed()
RLexSortedSetSetRx.
rangeReversed()
ZLEXCOUNTRLexSortedSet.
lexCount()
lexCountHead()
lexCountTail()
lexCountAsync()
lexCountHeadAsync()
lexCountTailAsync()
RLexSortedSetReactive.
lexCount()
lexCountHead()
lexCountTail()
RLexSortedSetRx.
lexCount()
lexCountHead()
lexCountTail()
ZRANGERScoredSortedSet.
valueRange()
valueRangeAsync()
RScoredSortedSetReactive.
valueRange()
RScoredSortedSetRx.
valueRange()
ZREVRANGERScoredSortedSet.
valueRangeReversed()
valueRangeReversedAsync()
RScoredSortedSetReactive.
valueRangeReversed()
RScoredSortedSetRx.
valueRangeReversed()
ZUNIOnSTORERScoredSortedSet.
union()
unionAsync()
RScoredSortedSetReactive.
union()
RScoredSortedSetRx.
union()
ZINTERSTORERScoredSortedSet.
intersection()
intersectionAsync()
RScoredSortedSetReactive.
intersection()
RScoredSortedSetRx.
intersection()
ZRANGEBYLEXRLexSortedSet.
range()
rangeHead()
rangeTail()
rangeAsync()
rangeHeadAsync()
rangeTailAsync()
RLexSortedSetReactive.
range()
rangeHead()
rangeTail()
RLexSortedSetRx.
range()
rangeHead()
rangeTail()
ZRANGEBYSCORERScoredSortedSet.
valueRange()
entryRange()
valueRangeAsync()
entryRangeAsync()
RScoredSortedSetReactive.
valueRange()
entryRange()
RScoredSortedSetRx.
valueRange()
entryRange()
TIMERedissonClient.
getNodesGroup().
getNode().time()
getClusterNodesGroup().
getNode().time()
--
ZRANKRScoredSortedSet.
rank()
rankAsync()
RScoredSortedSetReactive.
rank()
RScoredSortedSetRx.
rank()
ZREMRScoredSortedSet.
remove()
removeAll()
removeAsync()
removeAllAsync()
RScoredSortedSetReactive.
remove()
removeAll()
RScoredSortedSetRx.
remove()
removeAll()
ZREMRANGEBYLEXRLexSortedSet.
removeRange()
removeRangeHead()
removeRangeTail()
removeRangeAsync()
removeRangeHeadAsync()
removeRangeTailAsync()
RLexSortedSetReactive.
removeRange()
removeRangeHead()
removeRangeTail()
RLexSortedSetRx.
removeRange()
removeRangeHead()
removeRangeTail()
ZREMRANGEBYSCORERScoredSortedSet.
removeRangeByScore()
removeRangeByScoreAsync()
RScoredSortedSetReactive.
removeRangeByScore()
RScoredSortedSetRx.
removeRangeByScore()
ZREVRANGEBYSCORERScoredSortedSet.
valueRangeReversed()
entryRangeReversed()
valueRangeReversedAsync()
entryRangeReversedAsync()
RScoredSortedSetReactive.
entryRangeReversed()
valueRangeReversed()
RScoredSortedSetRx.
entryRangeReversed()
valueRangeReversed()
ZREVRANKRScoredSortedSet.
revRank()
revRankAsync()
RScoredSortedSetReactive.
revRank()
RScoredSortedSetRx.
revRank()
ZSCORERScoredSortedSet.
getScore()
getScoreAsync()
RScoredSortedSetReactive.
getScore()
RScoredSortedSetRx.
getScore()
ZPOPMAXRScoredSortedSet.
pollLast()
pollLastAsync()
RScoredSortedSetReactive.
pollLast()
RScoredSortedSetRx.
pollLast()
ZPOPMINRScoredSortedSet.
pollFirst()
pollFirstAsync()
RScoredSortedSetReactive.
pollFirst()
RScoredSortedSetRx.
pollFirst()
XACKRStream.
ack()
ackAsync()
RStreamReactive.
ack()
RStreamRx.
ack()
XADDRStream.
add()
addAsync()
RStreamReactive.
add()
RStreamRx.
add()
XCLAIMRStream.
claim()
claimAsync()
RStreamReactive.
claim()
RStreamRx.
claim()
XDELRStream.
remove()
removeAsync()
RStreamReactive.
remove()
RStreamRx.
remove()
XGROUPRStream.
createGroup()
removeGroup()
updateGroup()
createGroupAsync()
removeGroupAsync()
updateGroupAsync()
RStreamReactive.
createGroup()
removeGroup()
updateGroup()
RStreamRx.
createGroup()
removeGroup()
updateGroup()
XINFORStream.
getInfo()
listGroups()
listConsumers()
getInfoAsync()
listGroupsAsync()
listConsumersAsync()
RStreamReactive.
getInfo()
listGroups()
listConsumers()
RStreamRx.
getInfo()
listGroups()
listConsumers()
XLENRStream.
size()
sizeAsync()
RStreamReactive.
size()
RStreamRx.
size()
XPENDINGRStream.
listPending()
listPendingAsync()
RStreamReactive.
listPending()
RStreamRx.
listPending()
XRANGERStream.
range()
rangeAsync()
RStreamReactive.
range()
RStreamRx.
range()
XREADRStream.
read()
readAsync()
RStreamReactive.
read()
RStreamRx.
read()
XREADGROUPRStream.
readGroup()
readGroupAsync()
RStreamReactive.
readGroup()
RStreamRx.
readGroup()
XREVRANGERStream.
rangeReversed()
rangeReversedAsync()
RStreamReactive.
rangeReversed()
RStreamRx.
rangeReversed()
XTRIMRStream.
trim()
trimAsync()
RStreamReactive.
trim()
RStreamRx.
trim()
其他网址

Redisson最新版starter模式集成_明洋的专栏-CSDN博客_redisson-spring-boot-starter
最简单的spring-boot-starter-redisson发布啦! | 纳兰小筑

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/310589.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号