byte2Object()方法的改进

j2cache中byte2Object()使用的是jdk原生的序列化方案，网上有相关的序列化方案对比方案 ，研究了下  不妨推荐使用  https://github.com/flapdoodle-oss/de.flapdoodle.fast-serialization 试试  只需要使用FSTObjectOutput FSTObjectInput简单的替换,测试的数据性能相对来原生较好  以下是封装的简单的一个工具类。
-----------------------------------------------------------------------------------------------------------------------------------------

// Serialize
 /**
 * Serializes an <code>Object</code> to a byte array for
 * storage/serialization.
 *
 * @param obj the object to serialize to bytes
 * @return a byte[] with the converted Serializable
 * @throws JRedisCacheException (runtime) if the serialization fails
 */
 public static byte[] serialize(Serializable obj) {
 ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(512);
 serialize(obj, byteArrayOutputStream);
 return byteArrayOutputStream.toByteArray();
 }

/**
 * @param obj the object to serialize to bytes, may be null
 * @param byteArrayOutputStream the stream to write to, must not be null
 * @throws IllegalArgumentException if <code>outputStream</code> is <code>null</code>
 * @throws org.apache.commons.lang.SerializationException (runtime) if the serialization fails
 */
 private static void serialize(Serializable obj, ByteArrayOutputStream byteArrayOutputStream) {
 if (byteArrayOutputStream == null) {
 throw new IllegalArgumentException("The OutputStream must not be null");
 }
 FSTObjectOutput out = null;
 try {
 // stream closed in the finally
 out = new FSTObjectOutput(byteArrayOutputStream);
 out.writeObject(obj);
 out.flush();
 } catch (IOException ex) {
 throw new JRedisCacheException(ex);
 } finally {
 try {
 if (out != null) {
 out.close();
 out=null;
 }
 } catch (IOException ex) {
 // ignore close exception
 }
 }
 }
 // Deserialize
 //-----------------------------------------------------------------------
 /**
 * Deserializes a single <code>Object</code> from an array of bytes.
 *
 * @param objectData the serialized object, must not be null
 * @return the deserialized object
 * @throws IllegalArgumentException if <code>objectData</code> is <code>null</code>
 * @throws JRedisCacheException (runtime) if the serialization fails
 */
 public static Object deserialize(byte[] objectData) {
 if (objectData == null) {
 throw new IllegalArgumentException("The byte[] must not be null");
 }
 ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(objectData);
 return deserialize(byteArrayInputStream);
 }
 /**
 * Deserializes an <code>Object</code> from the specified stream.
 *
 * The stream will be closed once the object is written. This
 * avoids the need for a finally clause, and maybe also exception
 * handling, in the application code.
 *
 * The stream passed in is not buffered internally within this method.
 * This is the responsibility of your application if desired.
 *
 * @param byteArrayInputStream the serialized object input stream, must not be null
 * @return the deserialized object
 * @throws IllegalArgumentException if <code>inputStream</code> is <code>null</code>
 * @throws JRedisCacheException (runtime) if the serialization fails
 */
 private static Object deserialize(ByteArrayInputStream byteArrayInputStream) {
 if (byteArrayInputStream == null) {
 throw new IllegalArgumentException("The InputStream must not be null");
 }
 FSTObjectInput in = null;
 try {
 // stream closed in the finally
 in = new FSTObjectInput(byteArrayInputStream);
 return in.readObject();
 } catch (ClassNotFoundException ex) {
 throw new JRedisCacheException(ex);
 } catch (IOException ex) {
 throw new JRedisCacheException(ex);
 } finally {
 try {
 if (in != null) {
 in.close();
 in=null;
 }
 } catch (IOException ex) {
 // ignore close exception
 }
 }
 }

GVP 红薯/J2Cache

内容风险标识

评论 (14)

GVP红薯/J2Cache

内容风险标识