redis 저장 대상 의 방법 비교 분석

9176 단어 redis기억대상
redis 저장 대상 의 방법 비교
질문 배경:
원래 프로젝트 안 은 모두 직접 redis 저장 대상 의 json 데이터 로 빈번 한 직렬 화 와 반 직렬 화가 필요 합 니 다.나중에 프로젝트 중의 redis 저장 대상 을 hash 대상 으로 저장 하 는 것 을 고려 했 습 니 다.그러나 얻 은 후에 편리 하지 않 은 set get 작업 은 매우 아 픕 니 다.어떻게 해 야 이 문 제 를 해결 할 수 있 습 니까?
1.1 직접 저장 대상 의 json
redis 를 저장 할 때 fastJSon 이나 jackJSon 또는 Gson 으로 대상 을 json 데이터 로 정렬 한 다음 에 직접 저장 합 니 다.key 는 사용자 id 와 openid 를 표시 하고 value 는 대상 의 json 데이터 입 니 다.

public String get(String key) {
Object value = redisTemplate.boundValueOps(key).get();
return (String) value;
}
public void set(String key, String json) {
if (json == null) {
return;
}
redisTemplate.boundValueOps(key).set(json);
}
장점:직렬 화 와 반 직렬 화가 필요 하지만 대상 을 직접 조작 할 수 있 는 방법 으로 편리 하고 빠르다.
단점:직렬 화 와 반 직렬 화,그리고 하나의 필드 를 수정 해 야 합 니 다.전체 json 을 가 져 와 야 합 니 다.수정 후 직렬 화 저장,공간 낭비,시간 낭비,효율 이 낮 습 니 다.
1.2 redis hash key field value 저장 소 사용
key 는 메 인 키 를 대표 합 니 다.예 를 들 어 사용자 id 나 openId,value 는 map 로 각 필드 의 속성 과 값 에 대응 합 니 다.

단일 필드 저장

public void hset(String key, String field, String obj) {
redisTemplate.boundHashOps(key).put(field,obj);
}
전체 저장:

public void hSetMap(String key,Map<Object,Object> map){
redisTemplate.boundHashOps(key).putAll(map);
}
장점:저장 자가 편리 하고 메모리 공간 을 절약 할 수 있 으 며 하나의 필드 를 직접 수정 할 수 있 으 며 전체 대상 을 얻 지 않 아 도 효율 이 높다.
단점:value 를 가 져 온 후 map 입 니 다.편리 하 게 직접 호출(set get)처리 할 수 없습니다.수 동 map.get(filed)또는 map.pt(field,value)이 필요 합 니 다.
1.3 redis hash 저장 대상 의 조작 편의 성 문 제 를 어떻게 해결 합 니까?
사실은 map 와 pojo 의 전환 문제 에 대해 인터넷 에서 반 사 를 이용 한 전환 방법 을 제 시 했 지만 전환 과 반전 을 더 했다.이것 은 직렬 화 와 반 직렬 화 문제 와 마찬가지 로 효율 문 제 는 직접적 으로 사용 하 는 것 을 가리 키 지 못 하고 고민 하 며 여러 번 생각 하 는 것 이 좋 겠 다.나중에 생각해 보 자.아니면 네티즌 들 이 어떤 해결 방법 이 있 는 지.잘 부탁드립니다!
Redis 저장 대상 의 세 가지 방식
1.대상 을 직렬 화한 후 Redis 에 저장
서열 화학 기구 류 실현

public class SerializeUtil {
    /*
     *    
     * */
    public static byte[] serizlize(Object object){
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        try {
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            oos.writeObject(object);
            byte[] bytes = baos.toByteArray();
            return bytes;
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if(baos != null){
                    baos.close();
                }
                if (oos != null) {
                    oos.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
        return null;
    }
    /*
     *     
     * */
    public static Object deserialize(byte[] bytes){
        ByteArrayInputStream bais = null;
        ObjectInputStream ois = null; 
        try{
            bais = new ByteArrayInputStream(bytes);
            ois = new ObjectInputStream(bais);
            return ois.readObject();
        }catch(Exception e){
            e.printStackTrace();
        }finally {
            try {
 
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
        return null;
    }
}
jedis 인 스 턴 스 가 져 오기

public class RedisConnection {
    private static String HOST = "127.0.0.1";
    private static int PORT = 6379;
    private static int MAX_ACTIVE = 1024;
    private static int MAX_IDLE = 200;
    private static int MAX_WAIT = 10000;
 
    private static JedisPool jedisPool = null;
 
    /*
     *    redis   
     * */
    private static void initPool(){
        try {
            JedisPoolConfig config = new JedisPoolConfig();
            config.setMaxTotal(MAX_ACTIVE);//     
            config.setMaxIdle(MAX_IDLE);//       
            config.setMaxWaitMillis(MAX_WAIT);//             
 
            jedisPool = new JedisPool(config, HOST, PORT);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    /*
     *   jedis  
     * */
    public synchronized static Jedis getJedis() {
        try {
            if(jedisPool == null){
                initPool();
            }
            Jedis jedis = jedisPool.getResource();
            jedis.auth("redis");//  
            return jedis;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}
redis 조작 클래스

public class RedisOps {
    public static void set(String key,String value){
        Jedis jedis = RedisConnection.getJedis();
        jedis.set(key, value);
        jedis.close();
    }
    public static String get(String key){
        Jedis jedis = RedisConnection.getJedis();
        String value = jedis.get(key);
        jedis.close();
        return value;
    }
    public static void setObject(String key,Object object){
        Jedis jedis = RedisConnection.getJedis();
        jedis.set(key.getBytes(), SerializeUtil.serizlize(object));
        jedis.close();
    }
    public static Object getObject(String key){
        Jedis jedis = RedisConnection.getJedis();
        byte[] bytes = jedis.get(key.getBytes());
        jedis.close();
        return SerializeUtil.deserialize(bytes);
    }
}
사용자 개체

public class User implements Serializable{
    private static final long serialVersionUID = -3210884885630038713L;
    private int id;
    private String name;
    public User(){
 
    }
    public User(int id,String name){
        this.id = id;
        this.name = name;
    }
    //setter getter  
}
테스트

public class RedisTest {
 
    @Test
    public void testString(){
        RedisOps.set("user:1", "sisu");
        String user = RedisOps.get("user:1");
        Assert.assertEquals("sisu", user);
    }
 
    @Test
    public void testObject(){
        RedisOps.setObject("user:2",new User(2,"lumia"));
        User user = (User)RedisOps.getObject("user:2");
        Assert.assertEquals("lumia", user.getName());
    } 
}
2.대상 을 FastJSON 으로 JSON 문자열 로 변환 하여 저장
redis 조작 클래스

public class RedisOps {
    public static void setJsonString(String key,Object object){
        Jedis jedis = RedisConnection.getJedis();
        jedis.set(key, JSON.toJSONString(object));
        jedis.close();
    }
    public static Object getJsonObject(String key,Class clazz){
        Jedis jedis = RedisConnection.getJedis();
        String value = jedis.get(key);
        jedis.close();
        return JSON.parseObject(value,clazz);
    }
}
테스트

 @Test
    public void testObject2(){
        RedisOps.setJsonString("user:3", new User(3,"xiaoming"));
        User user = (User)RedisOps.getJsonObject("user:3",User.class);
        Assert.assertEquals("xiaoming", user.getName());
    }
3.대상 을 Hash 데이터 형식 으로 저장 합 니 다.
redis 조작 클래스

public class RedisOps {
    public static void hSet(String key,String value){
        Jedis jedis = RedisConnection.getJedis();
        jedis.hSet(key, value);
        jedis.close();
    }
    public static String hGet(String key){
        Jedis jedis = RedisConnection.getJedis();
        String value = jedis.hGet(key);
        jedis.close();
        return value;
    }
}
테스트

 @Test
    public void testObject3(){
     // 
        RedisOps.hSet("user:3","id","3");
        RedisOps.hSet("user:3","name","xiaoming");
        
        // 
        String id =  RedisOps..hGet("user:3","id");
        String name = RedisOps.hGet("user:3","name");
        Assert.assertEquals("3", id);
        Assert.assertEquals("xiaoming", name);        
    }
이상 은 개인 적 인 경험 이 므 로 여러분 에 게 참고 가 되 기 를 바 랍 니 다.여러분 들 도 저 희 를 많이 응원 해 주시 기 바 랍 니 다.

좋은 웹페이지 즐겨찾기