关于如何使用Kryo完成序列化和反序列化

　　基于kryo完成序列化和反序列化1。Kryo的使用
　　Step01：定义mail类：packagecom。java。serializable；importjava。io。Serializable；importjava。util。Date；publicclassMailimplementsSerializable｛privatestaticfinallongserialVersionUID6599166688654530165L；privateIntegerid；privateStringtitle；privateStringcontent；privateDatecreatedTime；publicIntegergetId（）｛returnid；｝publicvoidsetId（Integerid）｛this。idid；｝publicStringgetTitle（）｛returntitle；｝publicvoidsetTitle（Stringtitle）｛this。titletitle；｝publicStringgetContent（）｛returncontent；｝publicvoidsetContent（Stringcontent）｛this。contentcontent；｝publicDategetCreatedTime（）｛returncreatedTime；｝publicvoidsetCreatedTime（DatecreatedTime）｛this。createdTimecreatedTime；｝OverridepublicStringtoString（）｛returnMail〔idid，titletitle，contentcontent，createdTimecreatedTime〕；｝｝
　　Step02：添加依赖dependencygroupIdcom。esotericsoftwaregroupIdkryoartifactIdversion5。0。0RC4versiondependency
　　Step03：编写测试类packagecom。java。serializable；importjava。util。Date；importorg。apache。tomcat。util。http。fileupload。ByteArrayOutputStream；importcom。esotericsoftware。kryo。Kryo；importcom。esotericsoftware。kryo。io。Input；importcom。esotericsoftware。kryo。io。Output；publicclassTestSerializable06｛publicstaticvoidmain（String〔〕args）｛MailmnewMail（）；m。setId（100）；m。setTitle（test）；m。setContent（thisistestcontent）；m。setCreatedTime（newDate（））；基于Kryo框架将对象序列化KryokryonewKryo（）；将默认类的自动注册功能关闭（默认会将类全名序列化）kryo。setRegistrationRequired（false）；kryo。register（Mail。class）；kryo。register（Date。class）；ByteArrayOutputStreambos内置可扩容数组newByteArrayOutputStream（）；OutputoutputnewOutput（bos）；kryo。writeObject（output，m）；写入null时会报错output。close（）；System。out。println（序列化ok）；基于Kryo框架将对象反序列化byte〔〕databos。toByteArray（）；InputinputnewInput（data）；Mailm2kryo。readObject（input，Mail。class）；读出null时会报错input。close（）；System。out。println（m2）；｝｝
　　结果：序列化okMail〔id100，titletest，contentthisistestcontent，createdTimeMonNov1114：15：35CST2019〕2。工具类
　　可将如上序列化方法进行封装，写到序列化工具类中，例如：publicclassKryoSerializer｛privatestaticfinalThreadLocalKryokryoLocalThreadLocal。withInitial（（）｛KryokryonewKryo（）；kryo。setReferences（true）；检测循环依赖，默认值为true，避免版本变化显式设置kryo。setRegistrationRequired（false）；默认值为true，避免版本变化显式设置（（DefaultInstantiatorStrategy）kryo。getInstantiatorStrategy（））。setFallbackInstantiatorStrategy（newStdInstantiatorStrategy（））；设定默认的实例化器returnkryo；｝）；publicbyte〔〕serialize（Objectobj）｛KryokryogetKryo（）；ByteArrayOutputStreambyteArrayOutputStreamnewByteArrayOutputStream（）；OutputoutputnewOutput（byteArrayOutputStream）；kryo。writeClassAndObject（output，obj）；output。close（）；returnbyteArrayOutputStream。toByteArray（）；｝publicTTdeserialize（byte〔〕bytes）｛KryokryogetKryo（）；InputinputnewInput（newByteArrayInputStream（bytes））；return（T）kryo。readClassAndObject（input）；｝privateKryogetKryo（）｛returnkryoLocal。get（）；｝｝
　　编写测试类：packagecom。java。serializable；importjava。io。IOException；importjava。util。Date；publicclassTestSerializable07｛publicstaticvoidmain（String〔〕args）throwsIOException｛MailmnewMail（）；m。setId（100）；m。setTitle（test）；m。setContent（thisistestcontent）；m。setCreatedTime（newDate（））；基于Kryo框架将对象序列化byte〔〕arrayKryoSerializer。serializable（m）；System。out。println（序列化OK，array。lengtharray。length）；基于Kryo框架将对象反序列化Mailm2KryoSerializer。deserialization（array，Mail。class）；System。out。println（m2）；｝｝
　　运行结果：序列化OK，array。length49Mail〔id100，titletest，contentthisistestcontent，createdTimeMonNov1118：04：03CST2019〕3。两种读写方式
　　根据是否写入class类型分为两种方式，这里特别指出这里的的class指的是读写对象的class，如果读写的是有嵌套类型对象，则不管采用哪种方式，子类型class都会序列化。3。1只写实例信息知道class且对象不为nullkryo。writeObject（output，someObject）；。。。SomeClasssomeObjectkryo。readObject（input，SomeClass。class）；知道class且对象可能为nullkryo。writeObjectOrNull（output，someObject）；。。。SomeClasssomeObjectkryo。readObjectOrNull（input，SomeClass。class）；3。2同时写入class类型和实例信息（RPC场景）
　　class未知且对象可能为null，但这种场景，会多占用空间。这种方式是我们在RPC中应当使用的方式kryo。writeClassAndObject（output，object）；。。。Objectobjectkryo。readClassAndObject（input）；if（objectinstanceofSomeClass）｛。。。｝4。相关配置
　　register类注册
　　kryo支持通过类注册，注册会给每一个class一个int类型的Id相关联，这显然比类名称高效，但同时要求反序列化的时候的Id必须与序列化过程中一致。这意味着注册的顺序非常重要。kryo。register（SomeClassA。class）；kryo。register（SomeClassB。class）；
　　但是由于现实原因，同样的代码，同样的Class在不同的机器上注册编号任然不能保证一致，所以多机器部署时候反序列化可能会出现问题。
　　所以kryo默认会开启类注册（version：5。0。2），可以通过kryo。setRegistrationRequired（false）关闭，关闭后Kryo会根据类型去loadClass关联kryo。setRegistrationRequired（false）；一般设置为false解决线程不安全
　　由于Kryo线程不安全，意味着每次序列化和反序列化时都需要实例化一次，或借助ThreadLocal来维护以保证其线程安全。privatestaticfinalThreadLocalKryokryosnewThreadLocalKryo（）｛protectedKryoinitialValue（）｛KryokryonewKryo（）；configurekryoinstance，customizesettingsreturnkryo；｝；｝；Somewhereelse，useKryoKryokkryos。get（）；。。。
　　或者使用kryo提供的pool：publicKryoPoolnewKryoPool（）｛returnnewKryoPool。Builder（（）｛finalKryokryonewKryo（）；kryo。setInstantiatorStrategy（newKryo。DefaultInstantiatorStrategy（newStdInstantiatorStrategy（）））；returnkryo；｝）。softReferences（）。build（）；｝