Kryo的基本简单使用

序列化和反序列化的概念

序列化:把对象转换为字节序列的过程称为对象的序列化；
反序列化:把字节序列恢复为对象的过程称为对象的反序列化。

对象的序列化主要有两种用途：

把对象的字节序列永久地保存到硬盘上，通常存放在一个文件中；
在网络上传送对象的字节序列。

在很多应用中，需要对某些对象进行序列化，让它们离开内存空间，入住物理硬盘，以便长期保存。比如最常见的是Web服务器中的Session对象，当有 10万用户并发访问，就有可能出现10万个Session对象，内存可能吃不消，于是Web容器就会把一些seesion先序列化到硬盘中，等要用了，再把保存在硬盘中的对象还原到内存中。当两个进程在进行远程通信时，彼此可以发送各种类型的数据。无论是何种类型的数据，都会以二进制序列的形式在网络上传送。发送方需要把这个Java对象转换为字节序列，才能在网络上传送；接收方则需要把字节序列再恢复为Java对象。

Kryo的序列化实例
1.引入包

<dependencies><dependency><groupId>com.esotericsoftware</groupId><artifactId>kryo</artifactId><version>3.0.3</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version></dependency></dependencies>

2. 简单的使用
实体类

package com.hwqh.customerkafka.entity;public class User {int id;String name;int age;public User() {}public User(int id, String name, int age) {this.id = id;this.name = name;this.age = age;}@Overridepublic String toString() {return "User{" +"id=" + id +", name='" + name + '\'' +", age=" + age +'}';}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}
}

序列化

 @Testpublic void output() throws FileNotFoundException {User user = new User();user.setId(100);user.setName("测试数据");Kryo kryo = new Kryo();Output output = null;try {output = new Output(new FileOutputStream("user.bin"));kryo.writeObject(output, user);}catch (Exception e){e.printStackTrace();}finally {output.close();}}

kryo反序列化

 @Testpublic void input() throws FileNotFoundException {Kryo kryo = new Kryo();Input input=null;try {input = new Input(new FileInputStream("user.bin"));User user = kryo.readObject(input, User.class);System.out.println(user);}catch (Exception e){e.printStackTrace();}finally {input.close();}}

二、JDK类库中的序列化API

ObjectOutputStream代表对象输出流，它的writeObject(Object
obj)方法可对参数指定的obj对象进行序列化，把得到的字节序列写到一个目标输出流中。
ObjectInputStream代表对象输入流，它的readObject()方法从一个源输入流中读取字节序列，再把它们反序列化为一个对象，并将其返回。

举个栗子
实体类

import java.io.Serializable;  public class Person implements Serializable {  private static final long serialVersionUID = 4603642343377807741L;  private int age;  private String name;  private String sex;  public int getAge() {  return age;  }  public void setAge(int age) {  this.age = age;  }  public String getName() {  return name;  }  public void setName(String name) {  this.name = name;  }  public String getSex() {  return sex;  }  public void setSex(String sex) {  this.sex = sex;  }
}

序列化测试类

import java.io.*;
import java.text.MessageFormat;  public class TestObjSerializeAndDeserialize {  public static void main(String[] args) throws Exception {  SerializePerson();//序列化Person对象  Person p = DeserializePerson();//反序列Perons对象  System.out.println(MessageFormat.format("name={0},age={1},sex={2}",  p.getName(), p.getAge(), p.getSex()));  }  private static void SerializePerson() throws FileNotFoundException, IOException {  Person person = new Person();  person.setName("gacl");  person.setAge(25);  person.setSex("男");  // ObjectOutputStream 对象输出流，将Person对象存储到E盘的Person.txt文件中，完成对Person对象的序列化操作  ObjectOutputStream oo = new ObjectOutputStream(new FileOutputStream(new File("E:/Person.txt")));  oo.writeObject(person);  System.out.println("Person对象序列化成功！");  oo.close();  }  private static Person DeserializePerson() throws Exception, IOException {  ObjectInputStream ois = new ObjectInputStream(new FileInputStream(new File("E:/Person.txt")));  Person person = (Person) ois.readObject();  System.out.println("Person对象反序列化成功！");  return person;  }  }

Kryo的基本简单使用相关推荐

高性能的序列化与反序列化：kryo的简单使用
前言:kryo是个高效的java序列化/反序列化库,目前Twitter.yahoo.Apache.strom等等在使用该技术,比如Apache的spark.hive等大数据领域用的较多. 为什么使用k ...
《Spark 官方文档》Spark配置（一）
Spark配置 Spark有以下三种方式修改配置: Spark properties (Spark属性)可以控制绝大多数应用程序参数,而且既可以通过 SparkConf 对象来设置,也可以通过Java ...
Spark性能调优系列：Spark参数配置大全（官网资料）
Spark参数配置大全 Spark提供了三个位置来配置系统 Spark属性控制大多数应用程序参数,可以使用SparkConf对象或Java系统属性来设置. 通过conf/spark-env.sh每个节 ...
spark-参数配置总结
Spark属性控制大多数应用程序设置,并为每个应用程序单独配置.这些属性可以直接在传递给你的SparkConf上设置 SparkContext.SparkConf允许您通过该set()方法配置一些常 ...
基于kryo序列化方案的memcached-session-manager多memcached...
为什么80%的码农都做不了架构师?>>> 上次基于Java IO的序列化方案配置了memcached-session-manager,但是性能不好,现在先简单配置成基于kryo ...
Flink 流式计算在节省资源方面的简单分析
本文由小米的王加胜同学分享,文章介绍了 Apache Flink 在小米的发展,从 Spark Streaming 迁移到 Flink ,在调度计算与调度数据.Mini batch 与 streami ...
在Dubbo中使用高效的Java序列化（Kryo和FST）
作者:沈理文档版权: Apache 2.0许可证署名-禁止演绎完善中-- TODO 生成可点击的目录目录序列化漫谈启用Kryo和FST 注册被序列化类无参构造函数和Serializabl ...
kryo java_优化Java序列化– Java，XML，JSON，Kryo，POF
kryo java 也许我很天真,但是我一直认为Java序列化肯定是将Java对象序列化为二进制形式的最快,最有效的方法. 毕竟Java是第7个主要发行版,所以这不是新技术,而且由于每个JDK似乎都比 ...
优化Java序列化– Java，XML，JSON，Kryo，POF
也许我很天真,但是我一直认为Java序列化肯定是将Java对象序列化为二进制形式的最快,最有效的方法. 毕竟Java是第7个主要发行版,所以这不是新技术,并且由于每个JDK似乎都比上一个快,因此我错误 ...

Kryo的基本简单使用

Kryo的基本简单使用相关推荐

最新文章

热门文章