转载

对象序列化

在分布式系统，任何数据都要转化为二进制流在网络上进行传输，在面向对象设计中，我们经常会面临如何将定义好的对象发送到远端的问题，换言之，问题精确为发送方如何将对象转化为二进制流，接收方如何将二进制数据流转化为对象。将对象转换为二进制流的过程称之为对象序列化，反之将二进制流恢复为对象的过程称为反序列化。

目前成熟的解决方案包括： Google的protocal Buffer， Java内置的序列化，Hessian等，以及JSON和XMl。Protol Buffer性能优异，缺点需要编写proto文件，无法直接使用Java等中的对象。Hessian相比于ProtolBuffer效率稍低，但是对其他语言的支持优良，且性能稳定，比Java的内置序列化机制要高。Java的序列化机制不需要引入第三方包，使用简单，在对效率要求不是很高的情况下，可以考虑使用。

本文重点讲解一下Java内置的序列化方式和基于Java的Hessian序列化方式，代码实施如下所示

Java的内置序列化code实施代码

 public byte[] Serialize(Object object) {  ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();  try {   ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteArrayOutputStream);   //将对象写入到字节数组中进行序列化   objectOutputStream.writeObject(object);   return byteArrayOutputStream.toByteArray();  } catch (IOException e) {   e.printStackTrace();  }  return null; } public Object deSerialize(byte[] bytes) {  //将二进制数组导入字节数据流中  ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);  try {   //将字节数组流转化为对象   ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream);   return objectInputStream.readObject();  } catch (IOException e) {   e.printStackTrace();  } catch (ClassNotFoundException e) {   e.printStackTrace();  }  return null; }

基于Hession的序列化实施代码

使用Hession进行序列化，需要引入Hessian包，maven添加如下依赖：

 <dependency>     <groupId>com.caucho</groupId>     <artifactId>hessian</artifactId>     <version>4.0.38</version> </dependency>

 public byte[] Serialize(Object object) {  ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();  //Hession的序列化  HessianOutput hessianOutput = new HessianOutput(byteArrayOutputStream);  try {   hessianOutput.writeObject(object);   return byteArrayOutputStream.toByteArray();  } catch (IOException e) {   e.printStackTrace();  }  return null; } public Object deSerialize(byte[] bytes) {  ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);  HessianInput hessianInput = new HessianInput(byteArrayInputStream);  try {   return hessianInput.readObject();  } catch (IOException e) {   e.printStackTrace();  }  return null; }

代码测试

测试代码如下所示，分别对上面两种方式进行junit测试，使用的测试对象Employee实现Serializable接口。

@Test public void should_serialize_and_deserizlie_when_apply_java_serialize() throws Exception {  //given  SerialSample serialSample=new SerialSample();  Employee employee=new Employee("xiaoya",1);  //when  byte[] serialize = serialSample.Serialize(employee);  Employee result = (Employee) serialSample.deSerialize(serialize);  //then  assertThat(result,is(employee)); }

@Test public void should_serialize_and_deserizlie_object_when_apply_hession_serialize() throws Exception {  //when  HessionSample hessionSample = new HessionSample();  Employee employee = new Employee("xiaoya", 1);  //given  byte[] serialize = hessionSample.Serialize(employee);  Employee result = (Employee) hessionSample.deSerialize(serialize);  //then  assertThat(result, is(employee)); }