SpringBoot整合Redis_Jedis版(二十)下

package top.yueshushu.learn.util;
import com.alibaba.fastjson.JSONObject;
/**
 * @ClassName:BeanUtil
 * @Description TODO
 * @Author zk_yjl
 * @Date 2021/9/22 15:18
 * @Version 1.0
 * @Since 1.0
 **/
public class BeanConvertUtil {
    /**
     * 将对象转换成普通的字符串
     * @date 2021/9/16 14:17
     * @author zk_yjl
     * @param value
     * @return java.lang.String
     */
    public static <T> String beanToString(T value) {
        if (value==null)
            return null;
        Class<?> aClass = value.getClass();
        if (aClass==int.class||aClass==Integer.class){
            return ""+value;
        }else if (aClass==String.class){
            return (String) value;
        }else if (aClass==long.class||aClass==Long.class){
            return ""+value;
        }else {
            return JSONObject.toJSONString(value);
        }
    }
    /**
     * 将字符串转换成相应的对象
     * @date 2021/9/16 14:17
     * @author zk_yjl
     * @param str
     * @param aClass
     * @return T
     */
    public static <T> T stringToBean(String str,Class<T> aClass) {
        if (str==null||str.length()<=0||aClass==null){
            return null;
        }
        if (aClass==int.class||aClass==Integer.class){
            return (T)Integer.valueOf(str);
        }else if (aClass==String.class){
            return (T)str;
        }else if (aClass==long.class||aClass==Long.class){
            return (T)Long.valueOf(str);
        }else {
            return JSONObject.parseObject(str,aClass);
        }
    }
}

package top.yueshushu.learn.service;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import top.yueshushu.learn.mapper.UserMapper;
import top.yueshushu.learn.pojo.User;
import top.yueshushu.learn.util.BeanConvertUtil;
import top.yueshushu.learn.util.RedisUtil;
import java.util.ArrayList;
import java.util.List;
/**
 * @ClassName:UserServiceImpl
 * @Description TODO
 * @Author 岳建立
 * @Date 2021/4/24 20:05
 * @Version 1.0
 **/
@Service
@Log4j2
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private RedisUtil redisUtil;
    @Value("${spring.redis.database:0}")
    private int redisDB;
    private static final String KEY_PRE="user_";
    @Override
    public void addUser(User user) {
        userMapper.addUser(user);
        log.info("将用户编号为{}放置到缓存里面",user.getId());
        //放置单个缓存
        redisUtil.set(KEY_PRE+user.getId(), BeanConvertUtil.beanToString(user),redisDB);
        //更新全部的缓存信息
        resetAllCache();
    }
    @Override
    public void updateUser(User user) {
        userMapper.updateUser(user);
        log.info("将用户编号为{}更新到缓存里面",user.getId());
        //设置新的缓存
        redisUtil.set(KEY_PRE+user.getId(),BeanConvertUtil.beanToString(user),redisDB);
        //更新全部的缓存信息
        resetAllCache();
    }
    @Override
    public void deleteUser(int id) {
        userMapper.deleteById(id);
        log.info("将用户编号为{}从缓存中移除",id);
        redisUtil.del(KEY_PRE+id);
        //更新全部的缓存信息
        resetAllCache();
    }
    @Override
    public User findById(int id) {
        log.info("先从缓存中查询用户编号为{} 是否存在",id);
        User user=BeanConvertUtil.stringToBean(redisUtil.get(KEY_PRE+id,redisDB),User.class);
        if(user!=null){
            log.info(">>>>>>>>>>使用的是缓存中的数据");
            return user;
        }
        log.info(">>>>>>>>>>>从数据库中查询，并放置到缓存中");
        user= userMapper.findById(id);
        redisUtil.set(KEY_PRE+id,BeanConvertUtil.beanToString(user),redisDB);
        return user;
    }
    @Override
    public List<User> findAll() {
        log.info("先从缓存中查询用户列表是否存在");
        List<String> userStringList= (List<String>) redisUtil.lrange(KEY_PRE+"ALL",0,-1,redisDB);
        List<User> userList=new ArrayList<>();
        if(!CollectionUtils.isEmpty(userStringList)){
            log.info(">>>>>>>>>>使用的是缓存中的数据");
            for(String userString:userStringList){
                userList.add(BeanConvertUtil.stringToBean(userString,User.class));
            }
            return userList;
        }
        log.info(">>>>>>>>>>>从数据库中查询，并放置到缓存中");
        userList= userMapper.findAll();
        for(User user:userList){
            redisUtil.lpush(redisDB,KEY_PRE+"ALL",BeanConvertUtil.beanToString(user));
        }
        return userList;
    }
    //重新全部的缓存信息
    private void resetAllCache() {
        //先删除
        redisUtil.del(KEY_PRE+"ALL");
        //再重新赋值值
       List<User> userList= userMapper.findAll();
        for(User user:userList){
            redisUtil.lpush(redisDB,KEY_PRE+"ALL",BeanConvertUtil.beanToString(user));
        }
    }
}