dubbo序列化问题（三）子类覆盖父类字段hession反序列化获取不到

朱雀 2022-04-06 10:46 364阅读 0赞

在进行dubbo开发中遇到一个问题，当是用hession2进行序列化时，子类和父类有相同的字段时，hession2反序列化获取不到该字段数据，如下：

  1. import java.io.Serializable;
  2. import java.util.Date;
  4. public class User implements Serializable{
  6.     /**
  7.      * 
  8.      */
  9.     private static final long serialVersionUID = 1L;
  10.     private String userId;
  11.     private String userName;
  12.     private Date addDate;
  13.     public String getUserId() {
  14.         return userId;
  15.     }
  16.     public void setUserId(String userId) {
  17.         this.userId = userId;
  18.     }
  19.     public String getUserName() {
  20.         return userName;
  21.     }
  22.     public void setUserName(String userName) {
  23.         this.userName = userName;
  24.     }
  25.     public Date getAddDate() {
  26.         return addDate;
  27.     }
  28.     public void setAddDate(Date addDate) {
  29.         this.addDate = addDate;
  30.     }
  33. }
  37. import java.util.Date;
  39. public class ChildrenUser extends User {
  41.     /**
  42.      * 
  43.      */
  44.     private static final long serialVersionUID = 1L;
  46.     private String userId;
  48.     private Date addDate;
  50.     public String getUserId() {
  51.         return userId;
  52.     }
  54.     public void setUserId(String userId) {
  55.         this.userId = userId;
  56.     }
  58.     public Date getAddDate() {
  59.         return addDate;
  60.     }
  62.     public void setAddDate(Date addDate) {
  63.         this.addDate = addDate;
  64.     }
  66.     @Override
  67.     public String toString() {
  68.         return "ChildrenUser [userId=" + userId + ", addDate=" + addDate + "]";
  69.     }
  71. }

测试程序如下：

  1. import java.io.ByteArrayInputStream;
  2. import java.io.ByteArrayOutputStream;
  3. import java.io.IOException;
  4. import java.util.Date;
  6. import com.alibaba.com.caucho.hessian.io.Hessian2Input;
  7. import com.alibaba.com.caucho.hessian.io.Hessian2Output;
  8. import com.pinganwj.clinic.api.demo.domain.ChildrenUser;
  9. import com.pinganwj.clinic.api.demo.domain.User;
  12. public class TestHessionLite1 {
  15.     public static void main(String[] args) throws IOException {
  16.         User user=new ChildrenUser();
  17.         user.setAddDate(new Date());
  18.         user.setUserId("123");
  19.         user.setUserName("呵呵");
  20.         byte[] aa=TestHessionLite1.serialize(user);
  21.         Object mm=TestHessionLite1.deserialize(aa);
  22.         System.out.println(mm.toString());
  24.     }
  26.     public static byte[] serialize(Object obj) throws IOException{  
  27.          ByteArrayOutputStream os = new ByteArrayOutputStream(); 
  28.          Hessian2Output ho = new Hessian2Output(os);  
  29.          byte[] cc = null;
  30.         try {
  31.             if(obj==null) throw new NullPointerException();  
  32.             ho.writeObject(obj);
  33.             ho.flushBuffer();
  34.             cc=os.toByteArray();  
  35.         } catch (Exception e) {
  36.             e.printStackTrace();
  37.         }finally{
  38.             ho.close();
  39.         }
  40.         return cc;  
  42.     } 
  44.     public static Object deserialize(byte[] by) throws IOException{ 
  45.         try {
  46.             if(by==null) throw new NullPointerException();  
  47.             ByteArrayInputStream is = new ByteArrayInputStream(by);
  48.             Hessian2Input hi = new Hessian2Input(is);  
  49.             return hi.readObject();  
  50.         } catch (Exception e) {
  51.             e.printStackTrace();
  52.         }
  53.         return null;
  55.     }  
  56. }

运行该测试程序，输出如下

  1. ChildrenUser [userId=null, addDate=null]

然后我再是用kryo来进行序列化，

  1. import java.io.ByteArrayInputStream;
  2. import java.io.ByteArrayOutputStream;
  3. import java.io.IOException;
  4. import java.io.Serializable;
  5. import java.util.Date;
  7. import org.apache.commons.codec.binary.Base64;
  9. import com.esotericsoftware.kryo.Kryo;
  10. import com.esotericsoftware.kryo.io.Input;
  11. import com.esotericsoftware.kryo.io.Output;
  12. import com.esotericsoftware.kryo.serializers.JavaSerializer;
  13. import com.pinganwj.clinic.api.demo.domain.ChildrenUser;
  14. import com.pinganwj.clinic.api.demo.domain.User;
  16. public class TestKryo1 {
  18.     public static void main(String[] args) {
  20.         User user=new ChildrenUser();
  21.         user.setAddDate(new Date());
  22.         user.setUserId("123");
  23.         user.setUserName("呵呵");
  24.         String aa=TestKryo1.serialize(user);
  25.         Object mm=TestKryo1.deserialize(aa,User.class);
  26.         System.out.println(mm.toString());
  27.     }
  28.     private static <T extends Serializable> String serialize(T obj) {
  29.         Kryo kryo = new Kryo();
  30.         kryo.setReferences(false);
  31.         kryo.register(obj.getClass(), new JavaSerializer());
  33.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  34.         Output output = new Output(baos);
  35.         kryo.writeClassAndObject(output, obj);
  36.         output.flush();
  37.         output.close();
  39.         byte[] b = baos.toByteArray();
  40.         try {
  41.             baos.flush();
  42.             baos.close();
  43.         } catch (IOException e) {
  44.             e.printStackTrace();
  45.         }
  47.         return new String(new Base64().encode(b));
  48.     }
  50.     @SuppressWarnings("unchecked")
  51.     private static <T extends Serializable> T deserialize(String obj,
  52.             Class<T> clazz) {
  53.         Kryo kryo = new Kryo();
  54.         kryo.setReferences(false);
  55.         kryo.register(clazz, new JavaSerializer());
  57.         ByteArrayInputStream bais = new ByteArrayInputStream(
  58.                 new Base64().decode(obj));
  59.         Input input = new Input(bais);
  60.         return (T) kryo.readClassAndObject(input);
  61.     }
  62. }

输出结果如下：

  1. ChildrenUser [userId=123, addDate=Fri Aug 25 00:28:45 CST 2017]

输出正确。

这个是hession2的一个坑，经过查看源码Hessian2Input类中的readObjectInstance方法

他将父类的属性都读取了

46aa6187-3b55-328e-bc56-c21c7e399abc.png

而每次第一次能读取到值，然后第二次读取就是null，都被覆盖了，所以输出都是null。

所以解决方案就是去掉子类中的字段或者父类中的字段，或者改用kryo等其他序列化方式。

发表评论

表情：
评论列表 （有 0 条评论，364人围观）

还没有评论，来说两句吧...

相关阅读

    相关 序列化，反序列化

    序列化： 对象的序列化主要有两种用途： 　　1） 把对象的字节序列永久地保存到硬盘上，通常存放在一个文件中； 　　2） 在网络上传送对象的字节序列。 　　

    系统管理员系统管理员/ 0 赞/ 542 阅读