java 执行redis的部分方法

@Autowired 
    private RedisTemplate<String, Object> redisTemplate; 

    public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }
    protected RedisSerializer<String> getRedisSerializer(){
        return redisTemplate.getStringSerializer();
    }/**
     * 添加用户
     */
    @Override
    public boolean addUser(final UserVo user,final String sessionId) throws Exception {
        boolean result=redisTemplate.execute(new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection)
                    throws DataAccessException {
                RedisSerializer<String> serializer =getRedisSerializer();
                byte[] key = serializer.serialize(sessionId);
                byte[] user1=null;
                try {
                    user1 = SerializableUtils.toByteArray(user);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                connection.append(key, user1);
                return true;
            }
        });
        return result;
    }
    
    /**
     * 查询用户
     */
    @Override
    public UserVo getUserVo(final String string) throws Exception {
        UserVo result=redisTemplate.execute(new RedisCallback<UserVo>() {
            @Override
            public UserVo doInRedis(RedisConnection connection)
                    throws DataAccessException {
                RedisSerializer<String> serializer =getRedisSerializer();
                byte[] key = serializer.serialize(string);
                byte[] value = connection.get(key);
                if(value==null){
                    return null;}
                UserVo user=null;
                try {
                    user=(UserVo) SerializableUtils.fromByteArray(value);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                return user;
            }
        });    
        return result;
    }
    //添加字符串
    @Override
    public Boolean addString(final String key,final String value) throws Exception {
        boolean result=redisTemplate.execute(new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection)
                    throws DataAccessException {
                RedisSerializer<String> serializer =getRedisSerializer();
                
                byte[] k = serializer.serialize(key);
                byte[] v=null;
                try {
                    v = SerializableUtils.toByteArray(value);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                connection.append(k, v);
                return true;
            }
        });
    
        return result;
    }
    
    /**
     * 查询字符串
     */
    @Override
    public String getString(final String key) throws Exception {
        String result=redisTemplate.execute(new RedisCallback<String>() {
            @Override
            public String doInRedis(RedisConnection connection)
                    throws DataAccessException {
                RedisSerializer<String> serializer =getRedisSerializer();
                byte[] keys = serializer.serialize(key);
                byte[] value = connection.get(keys);
                if(value==null){
                    return null;
                }
                String str=null;
                try {
                    str=(String) SerializableUtils.fromByteArray(value);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                return str;
            }
        });    
        return result;
    }
    
    /**
     * 查询字符串
     */
    @Override
    public Set<String> getKeys(String pattern){
        Set<String> keys = redisTemplate.keys(pattern);
        return keys;
    }
    /**
     * 删除key
     */
    @Override
    public Boolean delete(final String key) {
        boolean result=redisTemplate.execute(new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection)
                    throws DataAccessException {
                RedisSerializer<String> serializer=getRedisSerializer();
                byte[] k = serializer.serialize(key);
                connection.del(k);
                return true;
            }
        });
        return result;
    }
//更新字符串
    @Override
    public Boolean updateString(final String key,final String value) {
        if(key==null){
            throw new NullPointerException("数据行不存在, key = " + key);
        }
        boolean result=redisTemplate.execute(new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection)
                    throws DataAccessException {
                RedisSerializer<String> serializer=getRedisSerializer();
                byte[] k = serializer.serialize(key);
                byte[] v=null;
                try {
                    v = SerializableUtils.toByteArray(value);
                    connection.set(k, v);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                return true;
            }
        });
        return result;
    }
//设置过期时间
    @Override
    public void setTime(final String key, final int liveTime) {
        redisTemplate.execute(new RedisCallback<Object>() {
            public Long doInRedis(RedisConnection connection) throws DataAccessException {
                if (liveTime > 0) {
                    RedisSerializer<String> serializer=getRedisSerializer();
                    byte[] k = serializer.serialize(key);
                    connection.expire(k, liveTime);
                }
                return 1L;
            }
        });
    }