Package com.bytedesk.core.redis
Class RedisService
java.lang.Object
com.bytedesk.core.redis.RedisService
-
Field Summary
FieldsModifier and TypeFieldDescription -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiongetAutoReplyProcessed
(String messageUid) 获取自动回复消息已处理标记的值getMessageExists
(String messageUid) 获取消息存在标记的值boolean
isAutoReplyProcessed
(String messageUid) 检查自动回复消息是否已处理(用于去重)boolean
isMessageExists
(String messageUid) 检查消息是否已存在(用于去重)void
void
removeAutoReplyProcessed
(String messageUid) 删除自动回复消息已处理标记void
removeMessageExists
(String messageUid) 删除消息存在标记void
setAutoReplyProcessed
(String messageUid, long ttl) 设置自动回复消息已处理标记(用于去重)void
setMessageExists
(String messageUid, long ttl) 设置消息存在标记(用于去重)
-
Field Details
-
redisTemplate
-
-
Constructor Details
-
RedisService
public RedisService()
-
-
Method Details
-
push
-
isMessageExists
检查消息是否已存在(用于去重)- Parameters:
messageUid
- 消息UID- Returns:
- true if exists, false otherwise
-
setMessageExists
设置消息存在标记(用于去重)- Parameters:
messageUid
- 消息UIDttl
- 过期时间(秒),建议设置为24小时
-
removeMessageExists
删除消息存在标记- Parameters:
messageUid
- 消息UID
-
getMessageExists
获取消息存在标记的值- Parameters:
messageUid
- 消息UID- Returns:
- 消息标记值,如果不存在返回null
-
isAutoReplyProcessed
检查自动回复消息是否已处理(用于去重)- Parameters:
messageUid
- 消息UID- Returns:
- true if already processed, false otherwise
-
setAutoReplyProcessed
设置自动回复消息已处理标记(用于去重)- Parameters:
messageUid
- 消息UIDttl
- 过期时间(秒),建议设置为24小时
-
removeAutoReplyProcessed
删除自动回复消息已处理标记- Parameters:
messageUid
- 消息UID
-
getAutoReplyProcessed
获取自动回复消息已处理标记的值- Parameters:
messageUid
- 消息UID- Returns:
- 处理标记值,如果不存在返回null
-