import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.util.List;import com.dyuproject.protostuff.LinkedBuffer;import com.dyuproject.protostuff.ProtostuffIOUtil;import com.dyuproject.protostuff.Schema;import com.dyuproject.protostuff.runtime.RuntimeSchema;/** * 序列话工具 */public class ProtoStuffSerializerUtil {	/**	 * 序列化对象	 * @param obj	 * @return	 */	public static 
    
      byte[] serialize(T obj) {		if (obj == null) {			throw new RuntimeException("序列化对象(" + obj + ")!");		}		@SuppressWarnings("unchecked")		Schema
     
       schema = (Schema
      
       ) RuntimeSchema.getSchema(obj.getClass());		LinkedBuffer buffer = LinkedBuffer.allocate(1024 * 1024);		byte[] protostuff = null;		try {			protostuff = ProtostuffIOUtil.toByteArray(obj, schema, buffer);		} catch (Exception e) {			throw new RuntimeException("序列化(" + obj.getClass() + ")对象(" + obj + ")发生异常!", e);		} finally {			buffer.clear();		}		return protostuff;	}	/**	 * 反序列化对象	 * @param paramArrayOfByte	 * @param targetClass	 * @return	 */	public static 
       
         T deserialize(byte[] paramArrayOfByte, Class
        
          targetClass) {		if (paramArrayOfByte == null || paramArrayOfByte.length == 0) {			throw new RuntimeException("反序列化对象发生异常,byte序列为空!");		}		T instance = null;		try {			instance = targetClass.newInstance();		} catch (InstantiationException | IllegalAccessException e) {			throw new RuntimeException("反序列化过程中依据类型创建对象失败!", e);		}		Schema
         
           schema = RuntimeSchema.getSchema(targetClass); ProtostuffIOUtil.mergeFrom(paramArrayOfByte, instance, schema); return instance; } /** * 序列化列表 * @param objList * @return */ public static 
          
            byte[] serializeList(List
           
             objList) { if (objList == null || objList.isEmpty()) { throw new RuntimeException("序列化对象列表(" + objList + ")参数异常!"); } @SuppressWarnings("unchecked") Schema
            
              schema = (Schema
             
              ) RuntimeSchema.getSchema(objList.get(0).getClass()); LinkedBuffer buffer = LinkedBuffer.allocate(1024 * 1024); byte[] protostuff = null; ByteArrayOutputStream bos = null; try { bos = new ByteArrayOutputStream(); ProtostuffIOUtil.writeListTo(bos, objList, schema, buffer); protostuff = bos.toByteArray(); } catch (Exception e) { throw new RuntimeException("序列化对象列表(" + objList + ")发生异常!", e); } finally { buffer.clear(); try { if (bos != null) { bos.close(); } } catch (IOException e) { e.printStackTrace(); } } return protostuff; } /** * 反序列化列表 * @param paramArrayOfByte * @param targetClass * @return */ public static 
              
                List
               
                 deserializeList(byte[] paramArrayOfByte, Class
                
                  targetClass) { if (paramArrayOfByte == null || paramArrayOfByte.length == 0) { throw new RuntimeException("反序列化对象发生异常,byte序列为空!"); } Schema
                 
                   schema = RuntimeSchema.getSchema(targetClass); List
                  
                    result = null; try { result = ProtostuffIOUtil.parseListFrom(new ByteArrayInputStream(paramArrayOfByte), schema); } catch (IOException e) { throw new RuntimeException("反序列化对象列表发生异常!", e); } return result; }}