package com.jsh.erp.service.redis;
|
|
import com.jsh.erp.constants.BusinessConstants;
|
import com.jsh.erp.utils.StringUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.data.redis.core.ValueOperations;
|
import org.springframework.data.redis.serializer.RedisSerializer;
|
import org.springframework.data.redis.serializer.StringRedisSerializer;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.Set;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* Description
|
*
|
* @author jisheng hua
|
* @Date: 2021/1/28 18:10
|
*/
|
@Component
|
public class RedisService {
|
|
@Resource
|
public RedisTemplate redisTemplate;
|
|
public static final String ACCESS_TOKEN = "X-Access-Token";
|
|
@Autowired(required = false)
|
public void setRedisTemplate(RedisTemplate redisTemplate) {
|
RedisSerializer stringSerializer = new StringRedisSerializer();
|
redisTemplate.setKeySerializer(stringSerializer);
|
redisTemplate.setValueSerializer(stringSerializer);
|
redisTemplate.setHashKeySerializer(stringSerializer);
|
redisTemplate.setHashValueSerializer(stringSerializer);
|
this.redisTemplate = redisTemplate;
|
}
|
|
/**
|
* @author jisheng hua
|
* description:
|
* 从session中获取信息
|
*@date: 2021/1/28 18:10
|
* @Param: request
|
* @Param: key
|
* @return Object
|
*/
|
public Object getObjectFromSessionByKey(HttpServletRequest request, String key){
|
Object obj=null;
|
if(request==null){
|
return null;
|
}
|
String token = request.getHeader(ACCESS_TOKEN);
|
if(token!=null) {
|
//开启redis，用户数据放在redis中，从redis中获取
|
if(redisTemplate.opsForHash().hasKey(token,key)){
|
//redis中存在，拿出来使用
|
obj=redisTemplate.opsForHash().get(token,key);
|
redisTemplate.expire(token, BusinessConstants.MAX_SESSION_IN_SECONDS, TimeUnit.SECONDS);
|
}
|
}
|
return obj;
|
}
|
|
/**
|
* 获得缓存的基本对象。
|
*
|
* @param key 缓存键值
|
* @return 缓存键值对应的数据
|
*/
|
public <T> T getCacheObject(final String key)
|
{
|
ValueOperations<String, T> operation = redisTemplate.opsForValue();
|
return operation.get(key);
|
}
|
|
/**
|
* @author jisheng hua
|
* description:
|
* 将信息放入session或者redis中
|
*@date: 2021/1/28 18:10
|
* @Param: request
|
* @Param: key
|
* @Param: obj
|
* @return
|
*/
|
public void storageObjectBySession(String token, String key, Object obj) {
|
//开启redis，用户数据放到redis中
|
redisTemplate.opsForHash().put(token, key, obj.toString());
|
redisTemplate.expire(token, BusinessConstants.MAX_SESSION_IN_SECONDS, TimeUnit.SECONDS);
|
}
|
|
/**
|
* @author jisheng hua
|
* description:
|
* 将信息放入session或者redis中
|
* @date: 2024/5/28 20:10
|
* @return
|
*/
|
public void storageCaptchaObject(String verifyKey, String codeNum) {
|
//把验证码放到redis中
|
redisTemplate.opsForValue().set(verifyKey, codeNum, BusinessConstants.CAPTCHA_EXPIRATION, TimeUnit.MINUTES);
|
}
|
|
/**
|
* 删除单个对象
|
*
|
* @param key
|
*/
|
public boolean deleteObject(final String key)
|
{
|
return redisTemplate.delete(key);
|
}
|
|
/**
|
* @author jisheng hua
|
* description:
|
* 将信息从session或者redis中移除
|
*@date: 2021/1/28 18:10
|
* @Param: request
|
* @Param: key
|
* @Param: obj
|
* @return
|
*/
|
public void deleteObjectBySession(HttpServletRequest request, String key){
|
if(request!=null){
|
String token = request.getHeader(ACCESS_TOKEN);
|
if(StringUtil.isNotEmpty(token)){
|
//开启redis，用户数据放在redis中，从redis中删除
|
redisTemplate.opsForHash().delete(token, key);
|
}
|
}
|
}
|
|
/**
|
* @author jisheng hua
|
* 将信息从redis中移除，比对user和ip
|
* @param userId
|
* @param clientIp
|
*/
|
public void deleteObjectByUserAndIp(Long userId, String clientIp){
|
Set<String> tokens = redisTemplate.keys("*");
|
for(String token : tokens) {
|
Object userIdValue = redisTemplate.opsForHash().get(token, "userId");
|
Object clientIpValue = redisTemplate.opsForHash().get(token, "clientIp");
|
if(userIdValue!=null && clientIpValue!=null && userIdValue.equals(userId.toString()) && clientIpValue.equals(clientIp)) {
|
redisTemplate.opsForHash().delete(token, "userId");
|
}
|
}
|
}
|
}
|
