Protostuff序列化和反序列化

超、凢脫俗 2023-05-29 06:26 12阅读 0赞

## Protostuff ##

Protostuff在序列化和反序列化的速度上是非常快的，在要求速度简洁快速可以使用此框架，相比protobuffer使用起来简单方便

## Protostuff工具类 ##

public class SerializationUtil {
    
        private static Map<Class<?>, Schema<?>> cachedSchema = new ConcurrentHashMap<Class<?>, Schema<?>>();
    
        private static Objenesis objenesis = new ObjenesisStd(true);
    
        private SerializationUtil() {
        }
    
        /**
         * 获取类的schema
         *
         * @param cls cls
         * @return Schema
         */
        @SuppressWarnings("unchecked")
        private static <T> Schema<T> getSchema(Class<T> cls) {
            Schema<T> schema = (Schema<T>) cachedSchema.get(cls);
            if (schema == null) {
                schema = RuntimeSchema.createFrom(cls);
                cachedSchema.put(cls, schema);
            }
            return schema;
        }
    
        /**
         * 序列化（对象 -> 字节数组）
         */
        @SuppressWarnings("unchecked")
        public static <T> byte[] serialize(T obj) {
            Class<T> cls = (Class<T>) obj.getClass();
            LinkedBuffer buffer = LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE);
            try {
                Schema<T> schema = getSchema(cls);
                //序列化
                return ProtostuffIOUtil.toByteArray(obj, schema, buffer);
            } catch (Exception e) {
                throw new IllegalStateException(e.getMessage(), e);
            } finally {
                buffer.clear();
            }
        }
    
        /**
         * 反序列化（字节数组 -> 对象）
         */
        public static <T> T deserialize(byte[] data, Class<T> cls) {
            try {
                /*
                 * 如果一个类没有参数为空的构造方法时候，那么你直接调用newInstance方法试图得到一个实例对象的时候是会抛出异常的
                 * 通过ObjenesisStd可以完美的避开这个问题
                 * */
                //实例化
                T message = objenesis.newInstance(cls);
                //获取类的schema
                Schema<T> schema = getSchema(cls);
                ProtostuffIOUtil.mergeFrom(data, message, schema);
                return message;
            } catch (Exception e) {
                throw new IllegalStateException(e.getMessage(), e);
            }
        }
    }

## maven依赖 ##

<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>