StreamHandler (redis-spring-boot-starter-码云(gitee.com))

java.lang.Object
- wiki.xsx.core.handler.StreamHandler

All Implemented Interfaces:: RedisHandler

public final class StreamHandler
extends Object
implements RedisHandler

流助手

Since:: 1.8
Author:: xsx

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class StreamHandler.StreamDataType
流数据类型

Nested Classes
Modifier and Type	Class and Description
`static class`	`StreamHandler.StreamDataType` 流数据类型

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`Long`	`ack(String key, String groupName, String... recordIds)` 确认条目
`org.springframework.data.redis.connection.stream.RecordId`	`add(org.springframework.data.redis.connection.stream.Record record)` 添加条目
`org.springframework.data.redis.connection.stream.RecordId`	`add(String key, Map<String,Object> value)` 添加条目
`org.springframework.data.redis.connection.stream.RecordId`	`add(String key, Object value)` 添加条目
`Object`	`claim(String key, String groupName, String consumerName, long timeout, String... recordIds)` 获取所有权
`void`	`createGroup(String key, org.springframework.data.redis.connection.stream.ReadOffset readOffset, String groupName)` 创建消费者组
`void`	`createGroup(String key, String groupName)` 创建消费者组
`<T> T`	`get(Class<T> resultType, String key, String recordId)` 获取条目
`Map<String,Object>`	`get(String key, String recordId)` 获取条目
`org.springframework.data.redis.core.RedisTemplate<String,Object>`	`getRedisTemplate()` 获取spring redis模板
`Map<String,Object>`	`pending(String key, String groupName)` 待处理条目
`List<Map<String,Object>>`	`pending(String key, String groupName, int count)` 待处理条目
`List<Map<String,Object>>`	`pending(String key, String groupName, String consumerName, int count)` 待处理条目
`<T> Map<String,T>`	`range(Class<T> resultType, String key)` 获取条目
`<T> Map<String,T>`	`range(Class<T> resultType, String key, int count)` 获取条目
`<T> Map<String,T>`	`range(Class<T> resultType, String key, String minRecordId, String maxRecordId)` 获取条目
`<T> Map<String,T>`	`range(Class<T> resultType, String key, String minRecordId, String maxRecordId, int count)` 获取条目
`Map<String,Map<String,Object>>`	`range(String key)` 获取条目
`Map<String,Map<String,Object>>`	`range(String key, int count)` 获取条目
`Map<String,Map<String,Object>>`	`range(String key, String minRecordId, String maxRecordId)` 获取条目
`Map<String,Map<String,Object>>`	`range(String key, String minRecordId, String maxRecordId, int count)` 获取条目
`<T> Map<String,T>`	`read(Class<T> resultType, Map<String,String> keyRecordIdMap)` 读取条目
`<T> Map<String,T>`	`read(Class<T> resultType, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, Map<String,String> keyRecordIdMap)` 读取条目
`<T> Map<String,T>`	`read(Class<T> resultType, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String key, String... recordIds)` 读取条目
`<T> Map<String,T>`	`read(Class<T> resultType, String key, String... recordIds)` 读取条目
`Map<String,Object>`	`read(Map<String,String> keyRecordIdMap)` 读取条目
`Map<String,Object>`	`read(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, Map<String,String> keyRecordIdMap)` 读取条目
`Map<String,Object>`	`read(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String key, String... recordIds)` 读取条目
`Map<String,Object>`	`read(String key, String... recordIds)` 读取条目
`<T> Map<String,T>`	`readByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, Map<String,String> keyRecordIdMap)` 读取条目
`<T> Map<String,T>`	`readByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, Map<String,String> keyRecordIdMap)` 读取条目
`<T> Map<String,T>`	`readByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String key, String... recordIds)` 读取条目
`<T> Map<String,T>`	`readByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, String key, String... recordIds)` 读取条目
`Map<String,Object>`	`readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, Map<String,String> keyRecordIdMap)` 读取条目
`Map<String,Object>`	`readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, Map<String,String> keyRecordIdMap)` 读取条目
`Map<String,Object>`	`readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String key, String... recordIds)` 读取条目
`Map<String,Object>`	`readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, String key, String... recordIds)` 读取条目
`<T> Map<String,T>`	`readEarliest(Class<T> resultType, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最早)
`<T> Map<String,T>`	`readEarliest(Class<T> resultType, String... keys)` 读取条目(最早)
`Map<String,Object>`	`readEarliest(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最早)
`Map<String,Object>`	`readEarliest(String... keys)` 读取条目(最早)
`<T> Map<String,T>`	`readEarliestByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最早)
`<T> Map<String,T>`	`readEarliestByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, String... keys)` 读取条目(最早)
`Map<String,Object>`	`readEarliestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最早)
`Map<String,Object>`	`readEarliestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, String... keys)` 读取条目(最早)
`<T> Map<String,T>`	`readLatest(Class<T> resultType, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最新)
`<T> Map<String,T>`	`readLatest(Class<T> resultType, String... keys)` 读取条目(最新)
`Map<String,Object>`	`readLatest(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最新)
`Map<String,Object>`	`readLatest(String... keys)` 读取条目(最新)
`<T> Map<String,T>`	`readLatestByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最新)
`<T> Map<String,T>`	`readLatestByConsumer(Class<T> resultType, org.springframework.data.redis.connection.stream.Consumer consumer, String... keys)` 读取条目(最新)
`Map<String,Object>`	`readLatestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, org.springframework.data.redis.connection.stream.StreamReadOptions readOptions, String... keys)` 读取条目(最新)
`Map<String,Object>`	`readLatestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer, String... keys)` 读取条目(最新)
`Long`	`remove(String key, String... recordIds)` 移除条目
`Boolean`	`removeConsumer(String key, String groupName, String consumerName)` 移除消费者
`Boolean`	`removeGroup(String key, String groupName)` 移除消费者组
`<T> Map<String,T>`	`reverseRange(Class<T> resultType, String key)` 获取条目(反向)
`<T> Map<String,T>`	`reverseRange(Class<T> resultType, String key, int count)` 获取条目(反向)
`<T> Map<String,T>`	`reverseRange(Class<T> resultType, String key, String maxRecordId, String minRecordId)` 获取条目(反向)
`<T> Map<String,T>`	`reverseRange(Class<T> resultType, String key, String maxRecordId, String minRecordId, int count)` 获取条目(反向)
`Map<String,Map<String,Object>>`	`reverseRange(String key)` 获取条目(反向)
`Map<String,Map<String,Object>>`	`reverseRange(String key, int count)` 获取条目(反向)
`Map<String,Map<String,Object>>`	`reverseRange(String key, String maxRecordId, String minRecordId)` 获取条目(反向)
`Map<String,Map<String,Object>>`	`reverseRange(String key, String maxRecordId, String minRecordId, int count)` 获取条目(反向)
`Long`	`size(String key)` 条目数量
`Long`	`trim(String key, long count)` 裁剪条目(保留最新)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

size
```
public Long size(String key)
```
条目数量

Parameters:

key - 键

Returns:

返回条目数量

Since:

redis 5.0.0

See Also:

Redis Documentation: XLEN

add

public org.springframework.data.redis.connection.stream.RecordId add(String key,
                                                                     Map<String,Object> value)

添加条目

Parameters:: key - 键; value - 元素字典
Returns:: 返回 RecordId 对象
Since:: redis 5.0.0
See Also:: Redis Documentation: XADD

add

public org.springframework.data.redis.connection.stream.RecordId add(String key,
                                                                     Object value)

添加条目

Parameters:: key - 键; value - 元素
Returns:: 返回 RecordId 对象
Since:: redis 5.0.0
See Also:: Redis Documentation: XADD

add

public org.springframework.data.redis.connection.stream.RecordId add(org.springframework.data.redis.connection.stream.Record record)

添加条目

Parameters:: record - 条目
Returns:: 返回 RecordId 对象
Since:: redis 5.0.0
See Also:: Redis Documentation: XADD

trim
```
public Long trim(String key,
                 long count)
```
裁剪条目(保留最新)

Parameters:

key - 键

count - 保留数量

Returns:

返回被裁剪的数量

Since:

redis 5.0.0

See Also:

Redis Documentation: XTRIM

remove
```
public Long remove(String key,
                   String... recordIds)
```
移除条目

Parameters:

key - 键

recordIds - 条目id列表

Returns:

返回被删除的数量

Since:

redis 5.0.0

See Also:

Redis Documentation: XDEL

createGroup
```
public void createGroup(String key,
                        String groupName)
```
创建消费者组

Parameters:

key - 键

groupName - 消费者组名称

Since:

redis 5.0.0

See Also:

Redis Documentation: XGROUP CREATE

createGroup

public void createGroup(String key,
                        org.springframework.data.redis.connection.stream.ReadOffset readOffset,
                        String groupName)

创建消费者组

Parameters:: key - 键; readOffset - 偏移量; groupName - 消费者组名称
Since:: redis 5.0.0
See Also:: Redis Documentation: XGROUP CREATE

removeGroup
```
public Boolean removeGroup(String key,
                           String groupName)
```
移除消费者组

Parameters:

key - 键

groupName - 消费者组名称

Returns:

返回布尔值，成功true，失败false

Since:

redis 5.0.0

See Also:

Redis Documentation: XGROUP DESTROY

removeConsumer
```
public Boolean removeConsumer(String key,
                              String groupName,
                              String consumerName)
```
移除消费者

Parameters:

key - 键

groupName - 消费者组名称

consumerName - 消费者名称

Returns:

返回布尔值，成功true，失败false

Since:

redis 5.0.0

See Also:

Redis Documentation: XGROUP DELCONSUMER

ack
```
public Long ack(String key,
                String groupName,
                String... recordIds)
```
确认条目

Parameters:

key - 键

groupName - 消费者组名称

recordIds - 条目id列表

Returns:

返回成功确认的消息数

Since:

redis 5.0.0

See Also:

Redis Documentation: XACK

claim

public Object claim(String key,
                    String groupName,
                    String consumerName,
                    long timeout,
                    String... recordIds)

获取所有权

Parameters:: key - 键; groupName - 消费者组名称; consumerName - 消费者名称; timeout - 消息空闲时间; recordIds - 条目id列表
Returns:: 返回条目

pending
```
public Map<String,Object> pending(String key,
                                  String groupName)
```
待处理条目

Parameters:

key - 键

groupName - 消费者组名称

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XPENDING

pending

public List<Map<String,Object>> pending(String key,
                                        String groupName,
                                        int count)

待处理条目

Parameters:: key - 键; groupName - 消费者组名称; count - 返回数量
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XPENDING

pending

public List<Map<String,Object>> pending(String key,
                                        String groupName,
                                        String consumerName,
                                        int count)

待处理条目

Parameters:: key - 键; groupName - 消费者组名称; consumerName - 消费者名称; count - 返回数量
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XPENDING

readEarliest
```
public Map<String,Object> readEarliest(String... keys)
```
读取条目(最早)

Parameters:

keys - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

readEarliest
```
public <T> Map<String,T> readEarliest(Class<T> resultType,
                                      String... keys)
```
读取条目(最早)

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

keys - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

readEarliest

public Map<String,Object> readEarliest(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                       String... keys)

读取条目(最早)

Parameters:: readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

readEarliest

public <T> Map<String,T> readEarliest(Class<T> resultType,
                                      org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                      String... keys)

读取条目(最早)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

readLatest
```
public Map<String,Object> readLatest(String... keys)
```
读取条目(最新)

Parameters:

keys - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

readLatest
```
public <T> Map<String,T> readLatest(Class<T> resultType,
                                    String... keys)
```
读取条目(最新)

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

keys - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

readLatest

public Map<String,Object> readLatest(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                     String... keys)

读取条目(最新)

Parameters:: readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

readLatest

public <T> Map<String,T> readLatest(Class<T> resultType,
                                    org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                    String... keys)

读取条目(最新)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

read
```
public Map<String,Object> read(String key,
                               String... recordIds)
```
读取条目

Parameters:

key - 键

recordIds - 条目id列表

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

read

public <T> Map<String,T> read(Class<T> resultType,
                              String key,
                              String... recordIds)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

read

public Map<String,Object> read(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                               String key,
                               String... recordIds)

读取条目

Parameters:: readOptions - 读取选项; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

read

public <T> Map<String,T> read(Class<T> resultType,
                              org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                              String key,
                              String... recordIds)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; readOptions - 读取选项; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

read
```
public Map<String,Object> read(Map<String,String> keyRecordIdMap)
```
读取条目

Parameters:

keyRecordIdMap - 键与条目id字典

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

read
```
public <T> Map<String,T> read(Class<T> resultType,
                              Map<String,String> keyRecordIdMap)
```
读取条目

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

keyRecordIdMap - 键与条目id字典

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREAD

read

public Map<String,Object> read(org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                               Map<String,String> keyRecordIdMap)

读取条目

Parameters:: readOptions - 读取选项; keyRecordIdMap - 键与条目id字典
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

read

public <T> Map<String,T> read(Class<T> resultType,
                              org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                              Map<String,String> keyRecordIdMap)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; readOptions - 读取选项; keyRecordIdMap - 键与条目id字典
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREAD

readEarliestByConsumer

public Map<String,Object> readEarliestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                                 String... keys)

读取条目(最早)

Parameters:: consumer - 消费者对象; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readEarliestByConsumer

public <T> Map<String,T> readEarliestByConsumer(Class<T> resultType,
                                                org.springframework.data.redis.connection.stream.Consumer consumer,
                                                String... keys)

读取条目(最早)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readEarliestByConsumer

public Map<String,Object> readEarliestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                                 org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                                 String... keys)

读取条目(最早)

Parameters:: consumer - 消费者对象; readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readEarliestByConsumer

public <T> Map<String,T> readEarliestByConsumer(Class<T> resultType,
                                                org.springframework.data.redis.connection.stream.Consumer consumer,
                                                org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                                String... keys)

读取条目(最早)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readLatestByConsumer

public Map<String,Object> readLatestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                               String... keys)

读取条目(最新)

Parameters:: consumer - 消费者对象; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readLatestByConsumer

public <T> Map<String,T> readLatestByConsumer(Class<T> resultType,
                                              org.springframework.data.redis.connection.stream.Consumer consumer,
                                              String... keys)

读取条目(最新)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readLatestByConsumer

public Map<String,Object> readLatestByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                               org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                               String... keys)

读取条目(最新)

Parameters:: consumer - 消费者对象; readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readLatestByConsumer

public <T> Map<String,T> readLatestByConsumer(Class<T> resultType,
                                              org.springframework.data.redis.connection.stream.Consumer consumer,
                                              org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                              String... keys)

读取条目(最新)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; readOptions - 读取选项; keys - 键
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public Map<String,Object> readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                         String key,
                                         String... recordIds)

读取条目

Parameters:: consumer - 消费者对象; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public <T> Map<String,T> readByConsumer(Class<T> resultType,
                                        org.springframework.data.redis.connection.stream.Consumer consumer,
                                        String key,
                                        String... recordIds)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public Map<String,Object> readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                         org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                         String key,
                                         String... recordIds)

读取条目

Parameters:: consumer - 消费者对象; readOptions - 读取选项; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public <T> Map<String,T> readByConsumer(Class<T> resultType,
                                        org.springframework.data.redis.connection.stream.Consumer consumer,
                                        org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                        String key,
                                        String... recordIds)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; readOptions - 读取选项; key - 键; recordIds - 条目id列表
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public Map<String,Object> readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                         Map<String,String> keyRecordIdMap)

读取条目

Parameters:: consumer - 消费者对象; keyRecordIdMap - 键与条目id字典
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public <T> Map<String,T> readByConsumer(Class<T> resultType,
                                        org.springframework.data.redis.connection.stream.Consumer consumer,
                                        Map<String,String> keyRecordIdMap)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; keyRecordIdMap - 键与条目id字典
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public Map<String,Object> readByConsumer(org.springframework.data.redis.connection.stream.Consumer consumer,
                                         org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                         Map<String,String> keyRecordIdMap)

读取条目

Parameters:: consumer - 消费者对象; keyRecordIdMap - 键与条目id字典
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

readByConsumer

public <T> Map<String,T> readByConsumer(Class<T> resultType,
                                        org.springframework.data.redis.connection.stream.Consumer consumer,
                                        org.springframework.data.redis.connection.stream.StreamReadOptions readOptions,
                                        Map<String,String> keyRecordIdMap)

读取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; consumer - 消费者对象; keyRecordIdMap - 键与条目id字典
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREADGROUP

get
```
public Map<String,Object> get(String key,
                              String recordId)
```
获取条目

Parameters:

key - 键

recordId - 条目id

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XRANGE

get
```
public <T> T get(Class<T> resultType,
                 String key,
                 String recordId)
```
获取条目

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

key - 键

recordId - 条目id

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XRANGE

range
```
public Map<String,Map<String,Object>> range(String key)
```
获取条目

Parameters:

key - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XRANGE

range
```
public <T> Map<String,T> range(Class<T> resultType,
                               String key)
```
获取条目

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

key - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XRANGE

range
```
public Map<String,Map<String,Object>> range(String key,
                                            int count)
```
获取条目

Parameters:

key - 键

count - 返回数量

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XRANGE

range
```
public <T> Map<String,T> range(Class<T> resultType,
                               String key,
                               int count)
```
获取条目

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

key - 键

count - 返回数量

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XRANGE

range

public Map<String,Map<String,Object>> range(String key,
                                            String minRecordId,
                                            String maxRecordId)

获取条目

Parameters:: key - 键; minRecordId - 最小条目id; maxRecordId - 最大条目id
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XRANGE

range

public <T> Map<String,T> range(Class<T> resultType,
                               String key,
                               String minRecordId,
                               String maxRecordId)

获取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; key - 键; minRecordId - 最小条目id; maxRecordId - 最大条目id
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XRANGE

range

public Map<String,Map<String,Object>> range(String key,
                                            String minRecordId,
                                            String maxRecordId,
                                            int count)

获取条目

Parameters:: key - 键; minRecordId - 最小条目id; maxRecordId - 最大条目id; count - 返回数量
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XRANGE

range

public <T> Map<String,T> range(Class<T> resultType,
                               String key,
                               String minRecordId,
                               String maxRecordId,
                               int count)

获取条目

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; key - 键; minRecordId - 最小条目id; maxRecordId - 最大条目id; count - 返回数量
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XRANGE

reverseRange
```
public Map<String,Map<String,Object>> reverseRange(String key)
```
获取条目(反向)

Parameters:

key - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREVRANGE

reverseRange
```
public <T> Map<String,T> reverseRange(Class<T> resultType,
                                      String key)
```
获取条目(反向)

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

key - 键

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREVRANGE

reverseRange
```
public Map<String,Map<String,Object>> reverseRange(String key,
                                                   int count)
```
获取条目(反向)

Parameters:

key - 键

count - 返回数量

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREVRANGE

reverseRange
```
public <T> Map<String,T> reverseRange(Class<T> resultType,
                                      String key,
                                      int count)
```
获取条目(反向)

Type Parameters:

T - 返回类型

Parameters:

resultType - 返回类型

key - 键

count - 返回数量

Returns:

返回条目字典

Since:

redis 5.0.0

See Also:

Redis Documentation: XREVRANGE

reverseRange

public Map<String,Map<String,Object>> reverseRange(String key,
                                                   String maxRecordId,
                                                   String minRecordId)

获取条目(反向)

Parameters:: key - 键; maxRecordId - 最大条目id; minRecordId - 最小条目id
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREVRANGE

reverseRange

public <T> Map<String,T> reverseRange(Class<T> resultType,
                                      String key,
                                      String maxRecordId,
                                      String minRecordId)

获取条目(反向)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; key - 键; maxRecordId - 最大条目id; minRecordId - 最小条目id
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREVRANGE

reverseRange

public Map<String,Map<String,Object>> reverseRange(String key,
                                                   String maxRecordId,
                                                   String minRecordId,
                                                   int count)

获取条目(反向)

Parameters:: key - 键; maxRecordId - 最大条目id; minRecordId - 最小条目id; count - 返回数量
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREVRANGE

reverseRange

public <T> Map<String,T> reverseRange(Class<T> resultType,
                                      String key,
                                      String maxRecordId,
                                      String minRecordId,
                                      int count)

获取条目(反向)

Type Parameters:: T - 返回类型
Parameters:: resultType - 返回类型; key - 键; maxRecordId - 最大条目id; minRecordId - 最小条目id; count - 返回数量
Returns:: 返回条目字典
Since:: redis 5.0.0
See Also:: Redis Documentation: XREVRANGE

getRedisTemplate

public org.springframework.data.redis.core.RedisTemplate<String,Object> getRedisTemplate()

获取spring redis模板

Returns:: 返回对象模板

Class StreamHandler

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

size

add

add

add

trim

remove

createGroup

createGroup

removeGroup

removeConsumer

ack

claim

pending

pending

pending

readEarliest

readEarliest

readEarliest

readEarliest

readLatest

readLatest

readLatest

readLatest

read

read

read

read

read

read

read

read

readEarliestByConsumer

readEarliestByConsumer

readEarliestByConsumer

readEarliestByConsumer

readLatestByConsumer

readLatestByConsumer

readLatestByConsumer

readLatestByConsumer

readByConsumer

readByConsumer

readByConsumer

readByConsumer

readByConsumer

readByConsumer

readByConsumer

readByConsumer

get

get

range

range

range

range

range

range

range

range

reverseRange

reverseRange

reverseRange

reverseRange

reverseRange

reverseRange

reverseRange

reverseRange

getRedisTemplate