Jak używać obiektu java jako wartości w Redis

Question

Jestem całkiem nowy dla Redis.

Pobrałem Jedisa i dodałem do mojej ścieżki klas. Ale nie zapewnia sposobu przechowywania obiektu java jako "wartości"

Czy czegoś brakuje, czy Jedis nie zapewnia sposobu przechowywania obiektu Java jako wartości?

dzięki, -Venkat

Answer 1

nie istnieje bezpośredni sposób - mogą być wykonywane tylko poprzez szeregowanie i przechowywanie otrzymanej bajt tablicy. Pls polecają http://static.springsource.org/spring-data/redis/docs/1.0.x/api/org/springframework/data/redis/serializer/package-summary.html, jeśli chcesz użyć sprężyny.

Cheers Muthu

Answer 2

Zapisywanie obiektu Java jako wartość nie jest Redis sposób robienia rzeczy, chociaż można osiągnąć, co chcesz za pomocą serializacji.

Zobacz tę odpowiedź za Jedis autorów: https://stackoverflow.com/a/12355876/2237351

Answer 3

można łatwo zrobić z Redis ram opartych na Javie - Redisson:

RBucket<AnyObject> bucket = redisson.getBucket("anyObject"); 
// set an object 
bucket.set(new AnyObject()); 
// get an object 
AnyObject myObject = bucket.get(); 

// supports some useful functions like: 
bucket.trySet(object); 
bucket.compareAndSet(oldObject, newObject); 
AnyObject prevObject = bucket.getAndSet(new AnyObject()); 

Obsługuje serializacji i pracować z połączenia, dzięki czemu nie trzeba za każdym razem radzić sobie z tym, kiedy musisz wysłać obiekt do Redis. Redisson robi to za Ciebie. Pracuj z Redis, jak zwykłeś pracować z obiektami Java.

Obsługuje wiele popularnych kodeków (Jackson JSON, Avro, Smile, CBOR, MsgPack, Kryo, FST, LZ4, Snappy i JDK Serialization).

Answer 4

Jak mówi powyżej, nie ma bezpośredni sposób to zrobić, ale można wdrożyć siebie (przykład poniżej użycie fastjson zrobić serializacji, można wybrać samemu):

public static <T extends Serializable> T putObject(String key, T value, int expireTimeSecs) { 
    if (expireTimeSecs < 0) { 
     throw new IllegalArgumentException(String.format("Illegal expireTimeSecs = %s", expireTimeSecs)); 
    } 
    try (Jedis jedis = POOL.getResource()) { 
     String code; 
     if (expireTimeSecs == 0) { 
      code = jedis.set(key, JSON.toJSONString(value)); 
     } else { 
      code = jedis.setex(key, expireTimeSecs, JSON.toJSONString(value)); 
     } 
     if (!"OK".equalsIgnoreCase(code)) { 
      throw new CacheException("Put object to redis failed!"); 
     } 
    } 
    return value; 
} 

public static <T extends Serializable> T putObject(String key, T value) { 
    return putObject(key, value, 0); 
} 


public static <T extends Serializable> T getObject(String key, Class<T> clazz) { 
    try (Jedis jedis = POOL.getResource()) { 
     return JSON.parseObject(jedis.get(key), clazz); 
    } 
} 

public static Object getObject(String key) { 
    try (Jedis jedis = POOL.getResource()) { 
     return JSON.parse(jedis.get(key)); 
    } 
}