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) 获取消息存在标记的值booleanisAutoReplyProcessed(String messageUid) 检查自动回复消息是否已处理(用于去重)booleanisMessageExists(String messageUid) 检查消息是否已存在(用于去重)voidvoidremoveAutoReplyProcessed(String messageUid) 删除自动回复消息已处理标记voidremoveMessageExists(String messageUid) 删除消息存在标记voidsetAutoReplyProcessed(String messageUid, long ttl) 设置自动回复消息已处理标记(用于去重)voidsetMessageExists(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
-