RedisTemplate的简单使用

逃离我推掉我的手 2022-06-13 09:59 192阅读 0赞

1. 配置

2. 定义一个对象

public class User implements Serializable {
    
        private Integer id;
        private String name;
    
        
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
    }

3.编写user的操作接口userDao和实现类UserDaoImpl

public interface UserDao {
        void save(User user);
        User read(User user);
    }

public class UserDaoImpl implements UserDao {
    
        private RedisTemplate<Serializable, Serializable> template;
    
        public RedisTemplate<Serializable, Serializable> getTemplate() {
            return template;
        }
    
        public void setTemplate(RedisTemplate<Serializable, Serializable> template) {
            this.template = template;
        }
    
        public User read(final User user) {
    //        User user2 = (User) template.execute(new RedisCallback<Object>() {
    //            @Override
    //            public User doInRedis(RedisConnection connection)throws DataAccessException {
    //                byte[] key = template.getStringSerializer().serialize("id"+user.getId());
    //                if(connection.exists(key)){
    //                    byte[] value = connection.get(key);
    //                    String name = template.getStringSerializer().deserialize(value);
    //                    User user1 = new User();
    //                    user1.setName(name);
    //                    return user1;
    //                }
    //                return null;
    //            }
    //        });
            ValueOperations<Serializable, Serializable> opsForValue = template.opsForValue();
            User user2 = (User) opsForValue.get(user.getId());
            return user2;
            
    
        }
    
        public void save(final User user) {
    //        template.execute(new RedisCallback<Object>() {
    //            public Object doInRedis(RedisConnection connection) throws DataAccessException {
    //                connection.set(template.getStringSerializer().serialize("id"+user.getId()), template.getStringSerializer().serialize(user.getName()));
    //                return null;
    //            }
    //        });
            
            ValueOperations<Serializable, Serializable> opsForValue = template.opsForValue();
            opsForValue.set(user.getId(), user);
        }
    
    }

这里注释部分是另一种方法，也是可以的，自定义对象需要序列化  template.getStringSerializer().serialize("xxx");  
  
  
注释中connection方法很多例如：  
  
  
connection.mGet(keys);//byte\[\]... keys  
connection.mSet(tuple);//Map<byte\[\], byte\[\]> tuple  
connection.lSet(key, index, value);//byte\[\] key, long index, byte\[\] value  
connection.lRange(key, begin, end);//byte\[\] key, long begin, long end)  
......

4.  其他hash，set，zset，list的操作

//添加一个 key 
            ValueOperations<String, Object> value = redisTemplate.opsForValue();
            value.set("lp", "hello word");
            //获取 这个 key 的值
            System.out.println(value.get("lp"));
            //添加 一个 hash集合
            HashOperations<String, Object, Object>  hash = redisTemplate.opsForHash();
            Map<String,Object> map = new HashMap<String,Object>();
            map.put("name", "lp");
            map.put("age", "26");
            hash.putAll("lpMap", map);
            //获取 map
            System.out.println(hash.entries("lpMap"));
            //添加 一个 list 列表
            ListOperations<String, Object> list = redisTemplate.opsForList();
            list.rightPush("lpList", "lp");
            list.rightPush("lpList", "26");
            //输出 list
            System.out.println(list.range("lpList", 0, 1));
            //添加 一个 set 集合
            SetOperations<String, Object> set = redisTemplate.opsForSet();
            set.add("lpSet", "lp");
            set.add("lpSet", "26");
            set.add("lpSet", "178cm");
            //输出 set 集合
            System.out.println(set.members("lpSet"));
            //添加有序的 set 集合
            ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
            zset.add("lpZset", "lp", 0);
            zset.add("lpZset", "26", 1);
            zset.add("lpZset", "178cm", 2);
            //输出有序 set 集合
            System.out.println(zset.rangeByScore("lpZset", 0, 2));