程序包 com.sie.mbm.mom.framework.cache

类 LogCacheHelper

java.lang.Object

com.sie.mbm.mom.framework.cache.LogCacheHelper

public class LogCacheHelper
extends Object

RedisHelper类

字段概要

字段

修饰符和类型	字段	说明
private final ICacheHelper	iCacheHelper
private static final AtomicLong	INSERT_COUNTER
private static ICacheHelper	INSTANCE
(专用程序包) static final int	MAX_LOG_COUNT
private static final ExecutorService	singleThreadExecutor
private static final int	TRIM_EVERY_N_INSERTS

构造器概要

构造器

构造器	说明
LogCacheHelper()

方法概要

修饰符和类型	方法	说明
static void	convertAndSend(String channel, Object message)	发送消息
static boolean	del(String key)	删除给定键
static Object	get(String key)	获取给定键的值
static org.springframework.data.redis.core.Cursor<String>	getScan(org.springframework.data.redis.core.ScanOptions options)	查询所有key
void	init()
static void	lpush(String key, Object value)	在列表的左侧添加元素
static void	set(String key, Object value, long timeout)	设置键值对，并设置过期时间

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

INSTANCE

private static ICacheHelper INSTANCE

iCacheHelper

private final ICacheHelper iCacheHelper

singleThreadExecutor

private static final ExecutorService singleThreadExecutor

MAX_LOG_COUNT

static final int MAX_LOG_COUNT

另请参阅:

• 常量字段值

TRIM_EVERY_N_INSERTS

private static final int TRIM_EVERY_N_INSERTS

另请参阅:

• 常量字段值

INSERT_COUNTER

private static final AtomicLong INSERT_COUNTER

构造器详细资料

LogCacheHelper

public LogCacheHelper()

方法详细资料

init

@PostConstruct
public void init()

lpush

public static void lpush(String key,
 Object value)

在列表的左侧添加元素

参数:

key - 列表名

value - 元素值

set

public static void set(String key,
 Object value,
 long timeout)

设置键值对，并设置过期时间

参数:

key - Redis键

value - 值

timeout - 过期时间，以秒为单位

del

public static boolean del(String key)

删除给定键

参数:

key - Redis键

返回:

删除操作是否成功

get

public static Object get(String key)

获取给定键的值

参数:

key - Redis键

返回:

值

getScan

public static org.springframework.data.redis.core.Cursor<String> getScan(org.springframework.data.redis.core.ScanOptions options)

查询所有key

参数:

options - Redis键

返回:

查询所有key

convertAndSend

public static void convertAndSend(String channel,
 Object message)

发送消息

参数:

channel - 频道

message - 消息