大战熟女丰满人妻av-荡女精品导航-岛国aaaa级午夜福利片-岛国av动作片在线观看-岛国av无码免费无禁网站-岛国大片激情做爰视频

專注Java教育14年 全國咨詢/投訴熱線:400-8080-105
動力節點LOGO圖
始于2009,口口相傳的Java黃埔軍校
首頁 hot資訊 Redis緩存原理與實現

Redis緩存原理與實現

更新時間:2022-05-07 09:28:09 來源:動力節點 瀏覽1526次

截止到目前為止,在redis教程的文檔和實現里面并沒有針對object對象緩存的方法,然而,在我們的實際開發需要中,在很多時候我們是需要進行對象緩存的,并且可以正確的讀取出來! 

在官方提供的方法中,我們找到了有這么一個操作方法:

jedis.set(byte[], byte[])

看這個方法,是進行字節碼操作的,這讓我們很容易想到在一些遠程方法調用中,我們傳遞對象同樣傳遞的是字節碼,是不是可以參考呢?

首先,既然需要對對象進行字節操作,即可寫和可讀的操作,為了保證這個原則,那么緩存對象需要實現Serializable 接口,進行序列化和反序列化!

涉及到的知識點:

1.Serializable (接口,實現此接口的對象可以進行序列化)

2.ByteArrayOutputStream,ObjectOutputStream 對象轉換為字節碼輸出流

3.ByteArrayInputStream ,ObjectInputStream 字節碼轉換為對象的輸入流

了解了如上三點知識后,我們就可以對對象進行緩存操作了!

示例代碼如下,包括了對象緩存和List對象數組緩存,需要聲明的是,放入list數組中的對象同樣需要實現Serializable 接口:

public class ObjectsTranscoder extends SerializeTranscoder {
    @SuppressWarnings("unchecked")
    @Override
    public byte[] serialize(Object value) {
        if (value == null) {
            throw new NullPointerException("Can't serialize null");
        }
        byte[] result = null;
        ByteArrayOutputStream bos = null;
        ObjectOutputStream os = null;
        try {
            bos = new ByteArrayOutputStream();
            os = new ObjectOutputStream(bos);
            os.writeObject(value);
            os.close();
            bos.close();
            result = bos.toByteArray();
        } catch (IOException e) {
            throw new IllegalArgumentException("Non-serializable object", e);
        } finally {
            close(os);
            close(bos);
        }
        return result;
    }
    @SuppressWarnings("unchecked")
    @Override
    public Object deserialize(byte[] in) {
        Object result = null;
        ByteArrayInputStream bis = null;
        ObjectInputStream is = null;
        try {
            if (in != null) {
                bis = new ByteArrayInputStream(in);
                is = new ObjectInputStream(bis);
                result =  is.readObject();
                is.close();
                bis.close();
            }
        } catch (IOException e) {
            logger.error(String.format("Caught IOException decoding %d bytes of data",
                    in == null ? 0 : in.length) + e);
        } catch (ClassNotFoundException e) {
            logger.error(String.format("Caught CNFE decoding %d bytes of data",
                    in == null ? 0 : in.length) + e);
        } finally {
            close(is);
            close(bis);
        }
        return result;
    }
}

對象的轉換示例如上代碼:

數組緩存代碼:

public class ListTranscoder<M extends Serializable> extends SerializeTranscoder {
    @SuppressWarnings("unchecked")
    public List<M> deserialize(byte[] in) {
        List<M> list = new ArrayList<>();
        ByteArrayInputStream bis = null;
        ObjectInputStream is = null;
        try {
            if (in != null) {
                bis = new ByteArrayInputStream(in);
                is = new ObjectInputStream(bis);
                while (true) {
                    M m = (M)is.readObject();
                    if (m == null) {
                        break;
                    }
                    list.add(m);
                }
                is.close();
                bis.close();
            }
        } catch (IOException e) {
            logger.error(String.format("Caught IOException decoding %d bytes of data",
                    in == null ? 0 : in.length) + e);
        } catch (ClassNotFoundException e) {
            logger.error(String.format("Caught CNFE decoding %d bytes of data",
                    in == null ? 0 : in.length) + e);
        }  finally {
            close(is);
            close(bis);
        }
        return  list;
    }
    @SuppressWarnings("unchecked")
    @Override
    public byte[] serialize(Object value) {
        if (value == null)
            throw new NullPointerException("Can't serialize null");
        List<M> values = (List<M>) value;
        byte[] results = null;
        ByteArrayOutputStream bos = null;
        ObjectOutputStream os = null;
        try {
            bos = new ByteArrayOutputStream();
            os = new ObjectOutputStream(bos);
            for (M m : values) {
                os.writeObject(m);
            }
            // os.writeObject(null);
            os.close();
            bos.close();
            results = bos.toByteArray();
        } catch (IOException e) {
            throw new IllegalArgumentException("Non-serializable object", e);
        } finally {
            close(os);
            close(bos);
        }

        return results;
    }


}

通過以上操作即可以實現對象的緩存和讀取了!如果大家想了解更多相關知識,不妨來關注一下動力節點的Java在線學習,里面的課程內容從入門到精通,細致全面,很適合沒有基礎的小伙伴學習,希望對大家能夠有所幫助哦。

提交申請后,顧問老師會電話與您溝通安排學習

免費課程推薦 >>
技術文檔推薦 >>
主站蜘蛛池模板: 天天插天天射天天操 | 18禁片一级毛片视频播放免费看 | 免费国产黄线在线观看视频 | 一级欧美日韩 | chinese国产xxxx中国 | 国产美女亚洲精品久久久毛片 | 综合色综合 | 亚洲国产精品一区二区三区 | 欧美成人另类 | 中文字幕久久网 | 中日韩欧美中文字幕毛片 | 亚洲国产一区在线 | 一本本久综合久久爱 | 国产一区在线视频观看 | 日日狠狠| 成 人 黄 色 大 片全部 | 久久香蕉国产线看观看精品蕉 | 国产欧美日韩网站 | 欧美亚洲国产另类在线观看 | 香蕉视频在线免费 | 美女视频免费在线观看 | 在线看片91| 久久99热久久精品动漫 | 亚洲精品日韩一区二区 | 国产天天在线 | 天天操夜夜拍 | 久久精品福利 | 日韩欧美国产高清 | 91手机在线 | 日韩欧美精品在线视频 | 视频播放在线观看精品视频 | 久久久噜噜噜久久网 | 中国毛片免费看 | 热99精品只有里视频最新 | 国产高清在线精品一区二区三区 | 精品久久久久久久久久香蕉 | 免费国产视频 | 国产精品久久在线观看 | 久久九九久精品国产 | 九九影视理伦片 | 亚洲午夜久久久精品影院视色 |