~chenjiahe/hx_common.git

fwq

2022-10-27 60883147218577a3aa81127f628616d623402699

提交 \| 用户 \| age
f3ad4b	1	package com.hx.redis;
C	2
0cbabb	3	import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
f3ad4b	4	import org.springframework.data.redis.core.RedisTemplate;
C	5	import org.springframework.stereotype.Component;
	6
	7	import javax.annotation.Resource;
4a0446	8	import java.util.List;
fb3acc	9	import java.util.Map;
f3ad4b	10	import java.util.concurrent.TimeUnit;
C	11
	12
041c40	13	/**
C	14	* 文件处理工具
	15	*
f3ad4b	16	* @author wangrenhuang
C	17	* @Date 2021-10-19
	18	*/
	19	@Component
	20	public class RedisUtil {
	21	/**
	22	* [redis]
	23	*/
	24	@Resource
	25	private RedisTemplate<String, Object> redisTemplate;
	26
0cbabb	27	/**
C	28	* 切换数据库
	29	* @param dataNumber 数据库编号
	30	*/
	31	public void setDataBase(int dataNumber) {
	32	LettuceConnectionFactory connectionFactory = (LettuceConnectionFactory) redisTemplate.getConnectionFactory();
	33	if (connectionFactory != null && dataNumber != connectionFactory.getDatabase()) {
	34	connectionFactory.setDatabase(dataNumber);
	35	this.redisTemplate.setConnectionFactory(connectionFactory);
	36	connectionFactory.resetConnection();
	37	}
	38	}
f3ad4b	39
C	40	/**
	41	* [判断key是否存在]
041c40	42	*
f3ad4b	43	* @param key 键
C	44	* @return true 存在 false不存在
	45	*/
	46	public boolean hasKey(String key) {
	47	try {
	48	return redisTemplate.hasKey(key);
	49	} catch (Exception e) {
	50	return false;
	51	}
	52	}
	53
	54	/**
	55	* [普通缓存获取]
041c40	56	*
f3ad4b	57	* @param key 键
C	58	* @return 值
	59	*/
	60	public Object get(String key) {
	61	return key == null ? null : redisTemplate.opsForValue().get(key);
	62	}
041c40	63
f3ad4b	64	/**
C	65	* [普通缓存删除]
041c40	66	*
f3ad4b	67	* @param key 键
C	68	* @return 值
	69	*/
	70	public boolean delete(String key) {
	71	try {
	72	Boolean aBoolean = redisTemplate.hasKey(key);
	73	return aBoolean == false ? true : redisTemplate.delete(key);
041c40	74	} catch (Exception e) {
f3ad4b	75	return false;
C	76	}
	77	}
041c40	78
f3ad4b	79	/**
C	80	* [普通缓存放入]
041c40	81	*
C	82	* @param key 键
f3ad4b	83	* @param value 值
C	84	* @return true成功 false失败
	85	*/
	86	public boolean set(String key, Object value) {
	87	try {
	88	redisTemplate.opsForValue().set(key, value);
	89	return true;
	90	} catch (Exception e) {
	91	return false;
	92	}
	93	}
	94
	95
	96	/**
	97	* 普通缓存放入并设置时间
041c40	98	*
C	99	* @param key 键
f3ad4b	100	* @param value 值
041c40	101	* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
f3ad4b	102	* @return true成功 false 失败
C	103	*/
	104	public boolean set(String key, Object value, long time) {
	105	try {
	106	if (time > 0) {
	107	redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
	108	} else {
	109	set(key, value);
	110	}
	111	return true;
	112	} catch (Exception e) {
	113	e.printStackTrace();
	114	return false;
	115	}
	116	}
	117
041c40	118	/**
C	119	* 26
	120	* 指定缓存失效时间
	121	* 27
	122	*
	123	* @param key 键
	124	* 28
	125	* @param time 时间(秒)
	126	* 29
	127	* @return 30
	128	*/
	129
	130	public boolean expire(String key, long time) {
	131	try {
	132	if (time > 0) {
	133	redisTemplate.expire(key, time, TimeUnit.SECONDS);
	134	}
	135	return true;
	136	} catch (Exception e) {
	137	e.printStackTrace();
	138	return false;
	139
	140	}
	141
	142	}
	143
f3ad4b	144
fb3acc	145	/**
Z	146	* hash 删除操作
	147	*
	148	* @param key 键
	149	* @param valueKey 值
	150	* @return true成功 false 失败
	151	*/
	152	public boolean hashDel(String key, Object... valueKey) {
	153	try {
	154	redisTemplate.opsForHash().delete(key,valueKey);
	155	return true;
	156	} catch (Exception e) {
	157	e.printStackTrace();
	158	return false;
	159	}
	160	}
	161
	162	/**
	163	* hash 设置hashMapt操作
	164	*
	165	* @param key 键
	166	* @return true成功 false 失败
	167	*/
	168	public boolean hashSetMap(String key, Map<String,Object> map) {
	169	try {
	170	redisTemplate.opsForHash().putAll(key, map);
	171	return true;
	172	} catch (Exception e) {
	173	e.printStackTrace();
	174	return false;
	175	}
	176	}
	177
	178	/**
	179	* hash 设置单个hashMap操作
	180	*
	181	* @param key 键
	182	* @return true成功 false 失败
	183	*/
	184	public boolean hashSet(String hashKey, String key, Object value) {
	185	try {
	186	redisTemplate.opsForHash().put(hashKey,key,value);
	187	return true;
	188	} catch (Exception e) {
	189	e.printStackTrace();
	190	return false;
	191	}
	192	}
db287a	193
Z	194	/**
	195	* hash 获取整个hashKey数据
	196	*
	197	* @param hashKey 键
	198	* @return true成功 false 失败
	199	*/
	200	public Map<Object, Object> hashGetAll(String hashKey) {
	201	try {
	202	return redisTemplate.opsForHash().entries(hashKey);
	203	} catch (Exception e) {
	204	e.printStackTrace();
	205	return null;
	206	}
	207	}
	208
	209	/**
	210	* hash 获取单个hashKey
	211	*
	212	* @param hashKey 键
	213	* @return true成功 false 失败
	214	*/
8fcea5	215	public Object hashGet(String hashKey,Object key) {
db287a	216	try {
Z	217	return redisTemplate.opsForHash().get(hashKey,key);
	218	} catch (Exception e) {
	219	e.printStackTrace();
	220	return null;
	221	}
	222	}
	223
8fcea5	224	/**
F	225	* list 新增-左插入
	226	*
	227	* @param listKey 键
	228	* @return true成功 false 失败
	229	*/
	230	public Object leftPush(String listKey,Object value) {
	231	try {
	232	return redisTemplate.opsForList().leftPush(listKey,value);
	233	} catch (Exception e) {
	234	e.printStackTrace();
	235	return null;
	236	}
	237	}
	238
	239	/**
	240	* list 新增-左插入(存在才插入)
	241	*
	242	* @param listKey 键
	243	* @return true成功 false 失败
	244	*/
	245	public Object leftPushIfPresent(String listKey,Object value) {
	246	try {
	247	return redisTemplate.opsForList().leftPushIfPresent(listKey,value);
	248	} catch (Exception e) {
	249	e.printStackTrace();
	250	return null;
	251	}
	252	}
	253
	254	/**
	255	* list 新增-右插入(存在才插入)
	256	*
	257	* @param listKey 键
	258	* @return true成功 false 失败
	259	*/
	260	public Object rightPushIfPresent(String listKey,Object value) {
	261	try {
	262	return redisTemplate.opsForList().rightPushIfPresent(listKey,value);
	263	} catch (Exception e) {
	264	e.printStackTrace();
	265	return null;
	266	}
	267	}
	268
	269	/**
	270	* list 新增-右插入
	271	*
	272	* @param listKey 键
	273	* @return true成功 false 失败
	274	*/
	275	public Object rightPush(String listKey,Object value) {
	276	try {
	277	return redisTemplate.opsForList().rightPush(listKey,value);
	278	} catch (Exception e) {
	279	e.printStackTrace();
	280	return null;
	281	}
	282	}
	283
	284	/**
	285	* list 弹出-左
	286	*
	287	* @param listKey 键
	288	* @return true成功 false 失败
	289	*/
	290	public Object leftPop(String listKey) {
	291	try {
	292	return redisTemplate.opsForList().leftPop(listKey);
	293	} catch (Exception e) {
	294	e.printStackTrace();
	295	return null;
	296	}
	297	}
	298
	299	/**
	300	* list 弹出-右
	301	*
	302	* @param listKey 键
	303	* @return true成功 false 失败
	304	*/
	305	public Object rightPop(String listKey) {
	306	try {
	307	return redisTemplate.opsForList().rightPop(listKey);
	308	} catch (Exception e) {
	309	e.printStackTrace();
	310	return null;
	311	}
	312	}
	313
	314	/**
a8e37f	315	* list 获取索引下的值
8fcea5	316	*
F	317	* @param key 键
	318	* @param index 索引
	319	* @return true成功 false 失败
	320	*/
	321	public Object listGet(String key, long index) {
	322	try {
	323	return redisTemplate.opsForList().index(key,index);
	324	} catch (Exception e) {
	325	e.printStackTrace();
	326	return null;
	327	}
	328	}
	329
	330	/**
a8e37f	331	* list 获取索引下的值
F	332	*
	333	* @param key 键
	334	* @param start 开始位置 0是开始位置
	335	* @param end 结束位置,-1返回所有
	336	* @return true成功 false 失败
	337	*/
4a0446	338	public List<Object> listGetRange(String key, long start , long end) {
a8e37f	339	try {
F	340	return redisTemplate.opsForList().range(key, start, end);
	341	} catch (Exception e) {
	342	e.printStackTrace();
	343	return null;
	344	}
	345	}
	346
	347	/**
8fcea5	348	* list 获取长度
F	349	*
	350	* @param listKey 键
	351	* @return true成功 false 失败
	352	*/
	353	public Object listSize(String listKey) {
	354	try {
	355	return redisTemplate.opsForList().size(listKey);
	356	} catch (Exception e) {
	357	e.printStackTrace();
	358	return null;
	359	}
	360	}
	361
	362	/**
	363	* list 删除
	364	*
	365	* @param listKey 键
	366	* @param index index=0, 删除所有值等于value的元素; index>0, 从头部开始删除第一个值等于value的元素; index<0, 从尾部开始删除第一个值等于value的元素
	367	* @param value 删除的值
	368	* @return true成功 false 失败
	369	*/
	370	public Object listRemove(String listKey,long index,Object value) {
	371	try {
	372	return redisTemplate.opsForList().remove(listKey, index, value);
	373	} catch (Exception e) {
	374	e.printStackTrace();
	375	return null;
	376	}
	377	}
	378
ff803d	379	/**
F	380	* @param key 键
	381	* @param value 值
	382	* @param timeOut 时间
	383	* @param unit 时间单位
	384	*/
	385	public Boolean setIfAbsent(String key, Object value, long timeOut, TimeUnit unit) {
	386	try {
	387	return redisTemplate.opsForValue().setIfAbsent(key, value, timeOut, unit);
	388	} catch (Exception e) {
	389	e.printStackTrace();
	390	return null;
	391	}
	392	}
	393
fb3acc	394	}