Class RedisService

java.lang.Object
com.bytedesk.core.redis.RedisService

@Service public class RedisService extends Object
  • Field Details

    • redisTemplate

      @Autowired private org.springframework.data.redis.core.RedisTemplate<String,String> redisTemplate
  • Constructor Details

    • RedisService

      public RedisService()
  • Method Details

    • push

      public void push(String key, String value, long ttl)
    • isMessageExists

      public boolean isMessageExists(String messageUid)
      检查消息是否已存在(用于去重)
      Parameters:
      messageUid - 消息UID
      Returns:
      true if exists, false otherwise
    • setMessageExists

      public void setMessageExists(String messageUid, long ttl)
      设置消息存在标记(用于去重)
      Parameters:
      messageUid - 消息UID
      ttl - 过期时间(秒),建议设置为24小时
    • removeMessageExists

      public void removeMessageExists(String messageUid)
      删除消息存在标记
      Parameters:
      messageUid - 消息UID
    • getMessageExists

      public String getMessageExists(String messageUid)
      获取消息存在标记的值
      Parameters:
      messageUid - 消息UID
      Returns:
      消息标记值,如果不存在返回null
    • isAutoReplyProcessed

      public boolean isAutoReplyProcessed(String messageUid)
      检查自动回复消息是否已处理(用于去重)
      Parameters:
      messageUid - 消息UID
      Returns:
      true if already processed, false otherwise
    • setAutoReplyProcessed

      public void setAutoReplyProcessed(String messageUid, long ttl)
      设置自动回复消息已处理标记(用于去重)
      Parameters:
      messageUid - 消息UID
      ttl - 过期时间(秒),建议设置为24小时
    • removeAutoReplyProcessed

      public void removeAutoReplyProcessed(String messageUid)
      删除自动回复消息已处理标记
      Parameters:
      messageUid - 消息UID
    • getAutoReplyProcessed

      public String getAutoReplyProcessed(String messageUid)
      获取自动回复消息已处理标记的值
      Parameters:
      messageUid - 消息UID
      Returns:
      处理标记值,如果不存在返回null