springboot中的springSession的存储和获取实现

2023-07-14 16:59:03 70

利用redis进行springSession的存储：

存储：

//在session中保存用户信息
HttpSessionsession=httpRequest.getSession(true);
session.setAttribute(Constants.SESSION_KEY_USER+userToken,user);
//存储sessionId
redisService.hmSet(Constants.SESSION_ID_KEY,userToken,session.getId());

获取：

StringsessionId=(String)redisService.hmGet(Constants.SESSION_ID_KEY,userToken);
Stringkey="spring:session:sessions:"+sessionId;
StringhashKey="sessionAttr:"+Constants.SESSION_KEY_USER+userToken;
T_useruser=(T_user)redisService.hmGet(key,hashKey);
redisService中的hmSet和hmGet的代码：

publicvoidhmSet(Stringkey,StringhashKey,Objectvalue){

redisTemplate.opsForHash().put(key,hashKey,value);
}



publicObjecthmGet(Stringkey,ObjecthashKey){
HashOperationshash=redisTemplate.opsForHash();
returnhash.get(key,hashKey);
}

详细代码：

packagecom.handsight.platform.fras.service.impl;

importjava.util.Collection;
importjava.util.List;
importjava.util.Map;
importjava.util.Set;
importjava.util.concurrent.TimeUnit;

importjavax.annotation.Resource;

importorg.springframework.data.redis.core.HashOperations;
importorg.springframework.data.redis.core.RedisTemplate;
importorg.springframework.data.redis.core.ZSetOperations.TypedTuple;
importorg.springframework.stereotype.Service;

importcom.handsight.platform.fras.constant.Constants;
importcom.handsight.platform.fras.mgt.pojo.T_user;
importcom.handsight.platform.fras.service.RedisService;

/**
*@authorCarey2018年1月23日
*
*redis操作工具类
*/
@Service
publicclassRedisServiceImplimplementsRedisService{


@Resource(name="FrasRedisTemplate")
privateRedisTemplateredisTemplate;

publicRedisTemplategetInstance(){
returnredisTemplate;
}

/**
*
*判断key是否存在
*
*@paramkey
*@return
*/
@Override
publicbooleanhasKey(Stringkey){
returnredisTemplate.hasKey(key);
}

/**
*设置String类型key-value
*
*@paramkey
*@paramvalue
*/
@Override
publicvoidset(Stringkey,Stringvalue){
redisTemplate.opsForValue().set(key,value);
}

/**
*获取String类型key-value
*
*@paramkey
*@return
*/
@Override
publicStringget(Stringkey){
return(String)redisTemplate.opsForValue().get(key);
}

/**
*设置String类型key-value并添加过期时间(毫秒单位)
*
*@paramkey
*@paramvalue
*@paramtime过期时间,毫秒单位
*/
@Override
publicvoidsetForTimeMS(Stringkey,Stringvalue,longtime){
redisTemplate.opsForValue().set(key,value,time,TimeUnit.MILLISECONDS);
}

/**
*设置String类型key-value并添加过期时间(分钟单位)
*
*@paramkey
*@paramvalue
*@paramtime过期时间,分钟单位
*/
publicvoidsetForTimeMIN(Stringkey,Stringvalue,longtime){
redisTemplate.opsForValue().set(key,value,time,TimeUnit.MINUTES);
}

/**
*设置String类型key-value并添加过期时间(分钟单位)
*
*@paramkey
*@paramvalue
*@paramtime过期时间,分钟单位
*/
publicvoidsetForTimeCustom(Stringkey,Stringvalue,longtime,TimeUnittype){
redisTemplate.opsForValue().set(key,value,time,type);
}

/**
*如果key存在则覆盖,并返回旧值.如果不存在,返回null并添加
*
*@paramkey
*@paramvalue
*@return
*/
publicStringgetAndSet(Stringkey,Stringvalue){
return(String)redisTemplate.opsForValue().getAndSet(key,value);
}

/**
*批量添加key-value(重复的键会覆盖)
*
*@paramkeyAndValue
*/
publicvoidbatchSet(MapkeyAndValue){
redisTemplate.opsForValue().multiSet(keyAndValue);
}

/**
*批量添加key-value只有在键不存在时,才添加map中只要有一个key存在,则全部不添加
*
*@paramkeyAndValue
*/
publicvoidbatchSetIfAbsent(MapkeyAndValue){
redisTemplate.opsForValue().multiSetIfAbsent(keyAndValue);
}

/**
*对一个key-value的值进行加减操作,如果该key不存在将创建一个key并赋值该number如果key存在,但value
*不是长整型,将报错
*
*@paramkey
*@paramnumber
*/
publicLongincrement(Stringkey,longnumber){
returnredisTemplate.opsForValue().increment(key,number);
}

/**
*对一个key-value的值进行加减操作,如果该key不存在将创建一个key并赋值该number如果key存在,但value不是
*纯数字,将报错
*
*@paramkey
*@paramnumber
*/
publicDoubleincrement(Stringkey,doublenumber){
returnredisTemplate.opsForValue().increment(key,number);
}

/**
*给一个指定的key值附加过期时间
*
*@paramkey
*@paramtime
*@paramtype
*@return
*/
publicbooleanexpire(Stringkey,longtime,TimeUnittype){
returnredisTemplate.boundValueOps(key).expire(time,type);
}

/**
*移除指定key的过期时间
*
*@paramkey
*@return
*/
publicbooleanpersist(Stringkey){
returnredisTemplate.boundValueOps(key).persist();
}

/**
*获取指定key的过期时间
*
*@paramkey
*@return
*/
publicLonggetExpire(Stringkey){
returnredisTemplate.boundValueOps(key).getExpire();
}

/**
*修改key
*
*@paramkey
*@return
*/
publicvoidrename(Stringkey,StringnewKey){
redisTemplate.boundValueOps(key).rename(newKey);
}

/**
*删除key-value
*@paramkey
*@return
*/
@Override
publicvoiddelete(Stringkey){
redisTemplate.delete(key);
}

//hash操作

/**
*添加Hash键值对
*
*@paramkey
*@paramhashKey
*@paramvalue
*/
publicvoidput(Stringkey,StringhashKey,Stringvalue){
redisTemplate.opsForHash().put(key,hashKey,value);
}

/**
*批量添加hash的键值对有则覆盖,没有则添加
*
*@paramkey
*@parammap
*/
publicvoidputAll(Stringkey,Mapmap){
redisTemplate.opsForHash().putAll(key,map);
}

/**
*添加hash键值对.不存在的时候才添加
*
*@paramkey
*@paramhashKey
*@paramvalue
*@return
*/
publicbooleanputIfAbsent(Stringkey,StringhashKey,Stringvalue){
returnredisTemplate.opsForHash().putIfAbsent(key,hashKey,value);
}

/**
*删除指定hash的HashKey
*
*@paramkey
*@paramhashKeys
*@return删除成功的数量
*/
publicLongdelete(Stringkey,String...hashKeys){
returnredisTemplate.opsForHash().delete(key,hashKeys);
}

/**
*给指定hash的hashkey做增减操作
*
*@paramkey
*@paramhashKey
*@paramnumber
*@return
*/
publicLongincrement(Stringkey,StringhashKey,longnumber){
returnredisTemplate.opsForHash().increment(key,hashKey,number);
}

/**
*给指定hash的hashkey做增减操作
*
*@paramkey
*@paramhashKey
*@paramnumber
*@return
*/
publicDoubleincrement(Stringkey,StringhashKey,Doublenumber){
returnredisTemplate.opsForHash().increment(key,hashKey,number);
}

/**
*获取指定key下的hashkey
*
*@paramkey
*@paramhashKey
*@return
*/
publicObjectgetHashKey(Stringkey,StringhashKey){
returnredisTemplate.opsForHash().get(key,hashKey);
}

/**
*获取key下的所有hashkey和value
*
*@paramkey
*@return
*/
publicMapgetHashEntries(Stringkey){
returnredisTemplate.opsForHash().entries(key);
}

/**
*验证指定key下有没有指定的hashkey
*
*@paramkey
*@paramhashKey
*@return
*/
publicbooleanhashKey(Stringkey,StringhashKey){
returnredisTemplate.opsForHash().hasKey(key,hashKey);
}

/**
*获取key下的所有hashkey字段名
*
*@paramkey
*@return
*/
publicSet

springboot中的springSession的存储和获取实现

热门推荐

随机推荐