Redis存儲對象

兩種方式(序列化和json字符串)

一、序列化

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;
    }
}
1

獲取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);//最大連接數(shù)
            config.setMaxIdle(MAX_IDLE);//最大空閑連接數(shù)
            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 = -3210884885888888713L;
    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());
    }

}

二：使用fastjson將對象轉(zhuǎn)為json字符串后存儲

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());
}

Redis是一個開源的Key-Value數(shù)據(jù)緩存，和Memcached類似。

Redis多種類型的value，包括string(字符串)、list(鏈表)、set(集合)、zset(sorted set --有序集合)和hash（哈希類型）。

Jedis 是 Redis 官方首選的 Java 客戶端開發(fā)包。

//連接redis ，redis的默認(rèn)端口是6379
Jedis  jedis = new Jedis ("localhost",6379); 
//驗證密碼，如果沒有設(shè)置密碼這段代碼省略
jedis.auth("password"); 
jedis.connect();//連接
jedis.disconnect();//斷開連接

Set<String> keys = jedis.keys("*"); //列出所有的key
Set<String> keys = jedis.keys("key"); //查找特定的key

//移除給定的一個或多個key,如果key不存在,則忽略該命令. 
jedis.del("key1");
jedis.del("key1","key2","key3","key4","key5");
//移除給定key的生存時間(設(shè)置這個key永不過期)
jedis.persist("key1"); 

//檢查給定key是否存在
jedis.exists("key1"); 
//將key改名為newkey,當(dāng)key和newkey相同或者key不存在時,返回一個錯誤
jedis.rename("key1", "key2");

//返回key所儲存的值的類型。 
//none(key不存在),string(字符串),list(列表),set(集合),zset(有序集),hash(哈希表) 
jedis.type("key1");
//設(shè)置key生存時間，當(dāng)key過期時，它會被自動刪除。 
jedis.expire("key1", 5);//5秒過期 
 
//字符串值value關(guān)聯(lián)到key。 
jedis.set("key1", "value1"); 
//將值value關(guān)聯(lián)到key，并將key的生存時間設(shè)為seconds(秒)。 
jedis.setex("foo", 5, "haha"); 

//清空所有的key
jedis.flushAll();

//返回key的個數(shù) 
jedis.dbSize();

//哈希表key中的域field的值設(shè)為value。 
jedis.hset("key1", "field1", "field1-value"); 
jedis.hset("key1", "field2", "field2-value"); 

Map map = new HashMap(); 
map.put("field1", "field1-value"); 
map.put("field2", "field2-value"); 
jedis.hmset("key1", map); 
//返回哈希表key中給定域field的值 
jedis.hget("key1", "field1");

//返回哈希表key中給定域field的值(多個)
List list = jedis.hmget("key1","field1","field2"); 
for(int i=0;i<list.size();i++){ 
   System.out.println(list.get(i)); 
} 
//返回哈希表key中所有域和值
Map<String,String> map = jedis.hgetAll("key1"); 
for(Map.Entry entry: map.entrySet()) { 
   System.out.print(entry.getKey() + ":" + entry.getValue() + "\t"); 
} 

//刪除哈希表key中的一個或多個指定域
jedis.hdel("key1", "field1");
jedis.hdel("key1", "field1","field2");

//查看哈希表key中，給定域field是否存在。 
jedis.hexists("key1", "field1");
//返回哈希表key中的所有域
jedis.hkeys("key1");
//返回哈希表key中的所有值
jedis.hvals("key1");
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • redis存儲對象的兩種方式 最近工作閑來無聊，寫寫博客打發(fā)時間，說到redis存儲對象，我有著自己的小實驗，來驗...
    彼岸花開_7881閱讀 10,845評論 0贊 2
  • NOSQL類型簡介鍵值對：會使用到一個哈希表，表中有一個特定的鍵和一個指針指向特定的數(shù)據(jù)，如redis，volde...
    MicoCube閱讀 4,160評論 2贊 27
  • Redis的內(nèi)存優(yōu)化 聲明：本文內(nèi)容來自《Redis開發(fā)與運維》一書第八章，如轉(zhuǎn)載請聲明。 Redis所有的數(shù)據(jù)都...
    meng_philip123閱讀 19,071評論 2贊 29
  • 參考來源 Redis的內(nèi)存優(yōu)化 Redis所有的數(shù)據(jù)都在內(nèi)存中，而內(nèi)存又是非常寶貴的資源。對于如何優(yōu)化內(nèi)存使用一直...
    秦漢郵俠閱讀 1,370評論 0贊 2
  • 1 Redis介紹1.1 什么是NoSql為了解決高并發(fā)、高可擴(kuò)展、高可用、大數(shù)據(jù)存儲問題而產(chǎn)生的數(shù)據(jù)庫解決方...
    克魯?shù)吕?/span>閱讀 5,725評論 0贊 36

友情鏈接更多精彩內(nèi)容