Java高性能序列化工具Kryo詳情
概述
Kryo 是一個快速序列化/反序列化工具，依賴于字節(jié)碼生成機(jī)制（底層使用了 ASM 庫)，因此在序列化速度上有一定的優(yōu)勢，但正因如此，其使用也只能限制在基于 JVM 的語言上。
和 Hessian 類似，Kryo 序列化出的結(jié)果，是其自定義的、獨(dú)有的一種格式。由于其序列化出的結(jié)果是二進(jìn)制的，也即 byte[]，因此像 Redis 這樣可以存儲二進(jìn)制數(shù)據(jù)的存儲引擎是可以直接將 Kryo 序列化出來的數(shù)據(jù)存進(jìn)去。當(dāng)然你也可以選擇轉(zhuǎn)換成 String 的形式存儲在其他存儲引擎中（性能有損耗）。
基礎(chǔ)用法
介紹了這么多，接下來我們就來看看 Kryo 的基礎(chǔ)用法吧。其實對于序列化框架來說，API 基本都差不多，畢竟入?yún)⒑统鰠⑼ǔ６际谴_定的（需要序列化的對象/序列化的結(jié)果）。在使用 Kryo 之前，我們需要引入相應(yīng)的依賴。
<dependency> <groupId>com.esotericsoftware</groupId> <artifactId>kryo</artifactId> <version>5.2.0</version> </dependency>
基本使用如下所示：
import com.esotericsoftware.kryo.Kryo;
import com.esotericsoftware.kryo.io.Input;
import com.esotericsoftware.kryo.io.Output;
import java.io.*;
public class HelloKryo {
static public void main(String[] args) throws Exception {
Kryo kryo = new Kryo();
kryo.register(SomeClass.class);
SomeClass object = new SomeClass();
object.value = "Hello Kryo!";
Output output = new Output(new FileOutputStream("file.bin"));
kryo.writeObject(output, object);
output.close();
Input input = new Input(new FileInputStream("file.bin"));
SomeClass object2 = kryo.readObject(input, SomeClass.class);
input.close();
System.out.println(object2.value);
}
static public class SomeClass {
String value;
}
}Kryo 類會自動執(zhí)行序列化。Output 類和 Input 類負(fù)責(zé)處理緩沖字節(jié)，并寫入到流中。如果序列化前和序列化后類的字段不一致，反序列化會失敗。
Kryo 的序列化
作為一個靈活的序列化框架，Kryo 并不關(guān)心讀寫的數(shù)據(jù)，作為開發(fā)者，你可以隨意使用 Kryo 提供的那些開箱即用的序列化器。
Kryo 的注冊
和很多其他的序列化框架一樣，Kryo 為了提供性能和減小序列化結(jié)果體積，提供注冊的序列化對象類的方式。在注冊時，會為該序列化類生成 int ID，后續(xù)在序列化時使用 int ID 唯一標(biāo)識該類型。
注冊的方式如下：
kryo.register(SomeClass.class);
或者
kryo.register(SomeClass.class,?1);
可以明確指定注冊類的 int ID，但是該 ID 必須大于等于 0。如果不提供，內(nèi)部將會使用 int++的方式維護(hù)一個有序的 int ID 生成。
Kryo 的序列化器
Kryo 支持多種序列化器，通過源碼我們可窺知一二
雖然 Kryo 提供的序列化器可以讀寫大多數(shù)對象，但開發(fā)者也可以輕松的制定自己的序列化器。篇幅限制，這里就不展開說明了，僅以默認(rèn)的序列化器為例。
對象引用
在新版本的 Kryo 中，默認(rèn)情況下是不啟用對象引用的。這意味著如果一個對象多次出現(xiàn)在一個對象圖中，它將被多次寫入，并將被反序列化為多個不同的對象。
舉個例子，當(dāng)開啟了引用屬性，每個對象第一次出現(xiàn)在對象圖中，會在記錄時寫入一個 varint，用于標(biāo)記。當(dāng)此后有同一對象出現(xiàn)時，只會記錄一個 varint，以此達(dá)到節(jié)省空間的目標(biāo)。此舉雖然會節(jié)省序列化空間，但是是一種用時間換空間的做法，會影響序列化的性能，這是因為在寫入/讀取對象時都需要進(jìn)行追蹤。
開發(fā)者可以使用 kryo 自帶的 setReferences 方法來決定是否啟用 Kryo 的引用功能。
public class KryoReferenceDemo {
public static void main(String[] args) throws FileNotFoundException {
Kryo kryo = new Kryo();
kryo.register(User.class);
kryo.register(Account.class);
User user = new User();
user.setUsername("alvin");
Account account = new Account();
account.setAccountNo("10000");
// 循環(huán)引用
user.setAccount(account);
account.setUser(user);
// 這里需要設(shè)置為true，才不會報錯
kryo.setReferences(true);
Output output = new Output(new FileOutputStream("kryoreference.bin"));
kryo.writeObject(output, user);
output.close();
Input input = new Input(new FileInputStream("kryoreference.bin"));
User object2 = kryo.readObject(input, User.class);
input.close();
System.out.println(object2.getUsername());
System.out.println(object2.getAccount().getAccountNo());
}
public static class User {
private String username;
private Account account;
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public Account getAccount() {
return account;
}
public void setAccount(Account account) {
this.account = account;
}
}
public static class Account {
private String accountNo;
private String amount;
private User user;
public String getAccountNo() {
return accountNo;
}
public void setAccountNo(String accountNo) {
this.accountNo = accountNo;
}
public String getAmount() {
return amount;
}
public void setAmount(String amount) {
this.amount = amount;
}
public User getUser() {
return user;
}
public void setUser(User user) {
this.user = user;
}
}
}如果序列化前的setReferences(false)， 后面設(shè)置setReferences(true)進(jìn)行反序列化，會失敗。
線程不安全
Kryo 不是線程安全的。每個線程都應(yīng)該有自己的 Kryo 對象、輸入和輸出實例。
因此在多線程環(huán)境中，可以考慮使用 ThreadLocal 或者對象池來保證線程安全性。
ThreadLocal + Kryo 解決線程不安全
ThreadLocal 是一種典型的犧牲空間來換取并發(fā)安全的方式，它會為每個線程都單獨(dú)創(chuàng)建本線程專用的 kryo 對象。對于每條線程的每個 kryo 對象來說，都是順序執(zhí)行的，因此天然避免了并發(fā)安全問題。創(chuàng)建方法如下：
static?private?final?ThreadLocal<Kryo>?kryos?=?new?ThreadLocal<Kryo>() {
??protected?Kryo?initialValue() {
? ? ?Kryo?kryo?=?new?Kryo();
? ? ?// 在此處配置kryo對象的使用示例，如循環(huán)引用等
? ? ?return?kryo;
? };
};
Kryo?kryo?=?kryos.get();之后，僅需要通過 kryos.get() 方法從線程上下文中取出對象即可使用。
對象池 + Kryo 解決線程不安全
「池」是一種非常重要的編程思想，連接池、線程池、對象池等都是
「復(fù)用」思想的體現(xiàn)，通過將創(chuàng)建的“對象”保存在某一個“容器”中，以便后續(xù)反復(fù)使用，避免創(chuàng)建、銷毀的產(chǎn)生的性能損耗，以此達(dá)到提升整體性能的作用。
Kryo 對象池原理也是如此。Kryo 框架自帶了對象池的實現(xiàn)，整個使用過程不外乎創(chuàng)建池、從池中獲取對象、歸還對象三步，以下為代碼實例。
// Pool constructor arguments: thread safe, soft references, maximum capacity
Pool<Kryo>?kryoPool?=?new?Pool<Kryo>(true,?false,?8) {
??protected?Kryo?create?() {
? ? ?Kryo?kryo?=?new?Kryo();
? ? ?// Kryo 配置
? ? ?return?kryo;
? }
};
// 獲取池中的Kryo對象
Kryo?kryo?=?kryoPool.obtain();
// 將kryo對象歸還到池中
kryoPool.free(kryo);創(chuàng)建 Kryo 池時需要傳入三個參數(shù)，其中第一個參數(shù)用于指定是否在 Pool 內(nèi)部使用同步，如果指定為 true，則允許被多個線程并發(fā)訪問。第三個參數(shù)適用于指定對象池的大小的，這兩個參數(shù)較容易理解，因此重點(diǎn)來說一下第二個參數(shù)。
如果將第二個參數(shù)設(shè)置為 true，Kryo 池將會使用 java.lang.ref.SoftReference 來存儲對象。這允許池中的對象在 JVM 的內(nèi)存壓力大時被垃圾回收。Pool clean 會刪除所有對象已經(jīng)被垃圾回收的軟引用。當(dāng)沒有設(shè)置最大容量時，這可以減少池的大小。當(dāng)池子有最大容量時，沒有必要調(diào)用 clean，因為如果達(dá)到了最大容量，Pool free 會嘗試刪除一個空引用。
創(chuàng)建完 Kryo 池后，使用 kryo 就變得異常簡單了，只需調(diào)用 kryoPool.obtain() 方法即可，使用完畢后再調(diào)用 kryoPool.free(kryo) 歸還對象，就完成了一次完整的租賃使用。
理論上，只要對象池大小評估得當(dāng)，就能在占用極小內(nèi)存空間的情況下完美解決并發(fā)安全問題。如果想要封裝一個 Kryo 的序列化方法，可以參考如下的代碼
public?static?byte[]?serialize(Object?obj) {
? ?Kryo?kryo?=?kryoPool.obtain();
? ?// 使用 Output 對象池會導(dǎo)致序列化重復(fù)的錯誤（getBuffer返回了Output對象的buffer引用）
? ?try?(Output?opt?=?new?Output(1024,?-1)) {
? ? ? ?kryo.writeClassAndObject(opt,?obj);
? ? ? ?opt.flush();
? ? ? ?return?opt.getBuffer();
? }finally?{
? ? ? ?kryoPool.free(kryo);
? }
}小結(jié)
相較于 JDK 自帶的序列化方式，Kryo 的性能更快，并且由于 Kryo 允許多引用和循環(huán)引用，在存儲開銷上也更小。只不過，雖然 Kryo 擁有非常好的性能，但其自身卻舍去了很多特性，例如線程安全、對序列化對象的字段修改等。雖然這些弊端可以通過 Kryo 良好的擴(kuò)展性得到一定的滿足，但是對于開發(fā)者來說仍然具有一定的上手難度，不過這并不能影響其在 Java 中的地位。
到此這篇關(guān)于Java高性能序列化工具Kryo詳情的文章就介紹到這了,更多相關(guān) Java Kryo序列化內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
SpringBoot啟動多數(shù)據(jù)源找不到合適的驅(qū)動類問題
這篇文章主要介紹了SpringBoot啟動多數(shù)據(jù)源找不到合適的驅(qū)動類問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-01-01
這篇文章主要介紹了springboot指定profiles啟動失敗問題及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-04-04
這篇文章主要為大家詳細(xì)介紹了Java實現(xiàn)簡單酒店管理系統(tǒng)，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-05-05
這篇文章主要為大家介紹了JAVA中簡單的for循環(huán)異常踩坑避雷詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-07-07
本文主要介紹了IDEA修改生成jar包名字的兩種方法實現(xiàn),通過簡單的步驟,您可以修改項目名稱并在打包時使用新的名稱,具有一定的參考價值,感興趣的可以了解下2023-08-08
Java的Struts框架中的if/else標(biāo)簽使用詳解
這篇文章主要介紹了Java的Struts框架中的if/else標(biāo)簽使用詳解,Struts是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-12-12
對于一個正整數(shù)而言，長度是n，如果它的各位上的數(shù)字的n次方之和正好等于它本身，那么我們稱這樣的數(shù)為自冪數(shù),下面使用JAVA實現(xiàn)這個方法2014-03-03
這篇文章主要介紹了基于request獲取訪問者真實IP代碼示例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-10-10
static關(guān)鍵字有何魔法？竟讓Spring Boot搞出那么多靜態(tài)內(nèi)部類(推薦)
這篇文章主要介紹了static關(guān)鍵字有何魔法？竟讓Spring Boot搞出那么多靜態(tài)內(nèi)部類,本文通過實例代碼圖文相結(jié)合給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-07-07
springboot X-Accel-Redirect 大文件下載實現(xiàn)
本文主要介紹了springboot X-Accel-Redirect 大文件下載實現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06