三種序列化方式存取redis的方法

常見的的序列化反序列方式的效率：

protoBuf(PB) > fastjson > jackson > hessian > xstream > java

數據來自於：https://github.com/eishay/jvm-serializers/wiki

因此我選擇了java方式、jackson方式、fastjson方式、pb方式作了封裝並測試，測試結果以下：

jackson、pb、fastjson差不太多，jackson稍好些，java方式很是慢不推薦，jackson是springboot自帶的json序列化工具，因此推薦這種方式作redis對象存取。

下面是四種實現方式：

java自帶序列化

序列化工具方法

　　/** * 序列化 * * @param object * @return
         */
        public static byte[] serialize(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) { throw new RuntimeException(e.getMessage(), e); } } /** * 反序列化 * * @param bytes * @return
         */
        public static Object unserialize(byte[] bytes) { ByteArrayInputStream bais = null; try { // 反序列化
                bais = new ByteArrayInputStream(bytes); ObjectInputStream ois = new ObjectInputStream(bais); return ois.readObject(); } catch (Exception e) { throw new RuntimeException(e.getMessage(), e); } }

redisUtils

　　
　　@Autowired

　　private StringRedisTemplate redisTemplate;

　　/** * 以二進制序列化方式向redis保存對象 2019 * * @param key * @param value */
    public void setObj(String key, Object value) { final byte[] vbytes = SerializeUtil.serialize(value); redisTemplate.execute(new RedisCallback() { @Override public Object doInRedis(RedisConnection connection) throws DataAccessException { // connection.set(redisTemplateSer.getStringSerializer().serialize(key), vbytes);
 connection.set(SerializeUtil.serialize(key), vbytes); return null; } }); } /** * 以二進制序列化方式從redis獲取對象 2019 * * @param key * @param <T> * @return
     */
    public <T> T getObj(String key) { return redisTemplate.execute(new RedisCallback<T>() { @Override public T doInRedis(RedisConnection connection) throws DataAccessException { // byte[] keyByte = redisTemplateSer.getStringSerializer().serialize(key);
                byte[] keyByte = SerializeUtil.serialize(key); if (connection.exists(keyByte)) { byte[] valuebytes = connection.get(keyByte); @SuppressWarnings("unchecked") T value = (T) SerializeUtil.unserialize(valuebytes); return value; } return null; } }); }

Jackson、fastjson

序列化工具方法

/** * jackson序列化反序列化工具 */
        private static ObjectMapper objectMapper = new ObjectMapper(); public static <T> String obj2String(T obj) { if (obj == null) { return null; } try { return obj instanceof String ? (String) obj : objectMapper.writeValueAsString(obj); } catch (Exception e) { e.printStackTrace(); return null; } } //字符串轉對象
        public static <T> T string2Obj(String str, Class<T> clazz) { if (StringUtils.isEmpty(str) || clazz == null) { return null; } try { return clazz.equals(String.class) ? (T) str : objectMapper.readValue(str, clazz); } catch (IOException e) { e.printStackTrace(); return null; } } // /** // * fastjson序列化反序列化工具 // */ // public static <T> String obj2String(T obj) { // return JSON.toJSONString(obj); // } //
//        //字符串轉對象 // public static <T> T string2Obj(String str, Class<T> clazz) { // return JSON.parseObject(str,clazz); // }

redisUtils

　　/** * 以JSON序列化方式向redis保存對象 推薦這種用法速度快 2019 * @param key * @param value */
    public void setObjJson(String key,Object value){ redisTemplate.opsForValue().set(key,SerializeUtil.obj2String(value)); } /** * 以JSON序列化方式從redis獲取對象 推薦這種用法速度快 2019 * @param key * @param clazz * @param <T> * @return
     */
    public <T> T getObjJson(String key,Class<T> clazz){ String strValue = redisTemplate.opsForValue().get(key); if(!StringUtils.isEmpty(strValue)){ T value = SerializeUtil.string2Obj(strValue,clazz); return value; } return null; }

ProtoBuf方式

maven依賴

<!-- protostuff -->
        <dependency>
            <groupId>io.protostuff</groupId>
            <artifactId>protostuff-core</artifactId>
            <version>1.4.0</version>
        </dependency>
        <dependency>
            <groupId>io.protostuff</groupId>
            <artifactId>protostuff-runtime</artifactId>
            <version>1.4.0</version>
        </dependency>

序列化工具方法

　　　　/** * protobuf序列化工具 */
        public static <T> byte[] serializePb(T o) { Schema schema = RuntimeSchema.getSchema(o.getClass()); return ProtobufIOUtil.toByteArray(o, schema, LinkedBuffer.allocate(256)); } public static <T> T unserializePb(byte[] bytes, Class<T> clazz) { T obj = null; try { obj = clazz.newInstance(); Schema schema = RuntimeSchema.getSchema(obj.getClass()); ProtostuffIOUtil.mergeFrom(bytes, obj, schema); } catch (InstantiationException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } return obj; }

redisUtils，pb方式若是是嵌套對象會有必定問題（這塊回頭再研究一下），而且須要序列化的成員變量須要添加@Tag(7)註解，如：

@Data public class SimplePojo { @Tag(1) private String a; @Tag(2) private String b; @Tag(3) private String c;

　　/** * 以pb序列化方式向redis保存對象 2019 * * @param key * @param value */
    public void setObjPb(String key, Object value) { final byte[] vbytes = SerializeUtil.serializePb(value); redisTemplate.execute(new RedisCallback() { @Override public Object doInRedis(RedisConnection connection) throws DataAccessException { connection.set(SerializeUtil.serializePb(key), vbytes); return null; } }); } /** * 以pb序列化方式從redis獲取對象 2019 * * @param key * @param <T> * @return
     */
    public <T> T getObjPb(String key,Class<T> clazz) { return redisTemplate.execute(new RedisCallback<T>() { @Override public T doInRedis(RedisConnection connection) throws DataAccessException { byte[] keyByte = SerializeUtil.serializePb(key); if (connection.exists(keyByte)) { byte[] valuebytes = connection.get(keyByte); @SuppressWarnings("unchecked") T value = (T) SerializeUtil.unserializePb(valuebytes,clazz); return value; } return null; } }); }

Fork From GIT

更詳細的的源碼詳見：https://gitee.com/zxporz/redistest/blob/master/src/main/java/org/zxp/redis/utils/RedisUtil.java

歡迎fork