package?com.topsec.trd;

import?java.io.ByteArrayOutputStream;
import?java.io.File;
import?java.io.IOException;
import?java.util.ArrayList;
import?java.util.List;

import?org.apache.avro.file.DataFileReader;
import?org.apache.avro.file.DataFileWriter;
import?org.apache.avro.file.SeekableByteArrayInput;
import?org.apache.avro.generic.GenericDatumReader;
import?org.apache.avro.generic.GenericRecord;
import?org.apache.avro.io.DatumReader;
import?org.apache.avro.io.DatumWriter;
import?org.apache.avro.specific.SpecificDatumReader;
import?org.apache.avro.specific.SpecificDatumWriter;
import?org.junit.Test;
/**
?*?java?-jar?lib/avro-tools-1.7.7.jar?compile?schema?src/main/resource/student.avsc?src/main/java
?*?@author?Vincent.LJ
?*
?*/
public?class?AVRO?{
	private?final?static?int?TIMES?=?10000000;
	?public?static?void?main（String[]?args）?throws?IOException?{
		?long?start?=?System.currentTimeMillis（）;
//		?for（int?i?=?0;?i?//			?deserializeAsBytes（）;
//		?}
		?
		?deserializeAsBytes（）;
		?long?end?=?System.currentTimeMillis（）;
		?System.out.println（“Avro?total?time?\t“?+?（end?-start））;
	?}
	?
	?@Test
	?public?void?serialize?（）?throws?IOException?{
		?
		?for（int?i?=?0;?i?			?StudentAvro?student?=?new?StudentAvro（）;
			?student.setName（“張-“?+?i）;
			?student.setSex（“女“）;
			?student.setAge（18?+?i）;
			?
			?DatumWriter??userDatumWriter?=?new??SpecificDatumWriter（StudentAvro.class）;
			?DataFileWriter??dataFileWriter?=?new??DataFileWriter（userDatumWriter）;
			?dataFileWriter.create（student.getSchema（）?new?File（“student/student“+?i?+“.avro“））;
			?dataFileWriter.append（student）;
			?dataFileWriter.close（）;
		?}
	?}
	?
	?public?static?byte?[]?serializeAsBytes（）?throws?IOException?{
		?StudentAvro?student?=?new?StudentAvro（）;
		?student.setName（“小明“）;
		?student.setSex（“女“）;
		?student.setAge（18）;
		?List?interests?=?new?ArrayList（）;
		?interests.add（“吃飯“）;
		?interests.add（“睡覺“）;
		?interests.add（“打豆豆“）;
		?student.setInteret（interests）;
		?ByteArrayOutputStream?baos?=?new?ByteArrayOutputStream（）;
		?DatumWriter??userDatumWriter?=?new??SpecificDatumWriter（StudentAvro.class）;
		?DataFileWriter??dataFileWriter?=?new??DataFileWriter（userDatumWriter）;
		?dataFileWriter.create（student.getSchema（）?baos）;
		?dataFileWriter.append（student）;
		?dataFileWriter.close（）;
		?return?baos.toByteArray（）;
	?}
	?
	?public?static?byte?[]?serializeAsBytes（int?times）?throws?IOException?{
		?ByteArrayOutputStream?baos?=?new?ByteArrayOutputStream（）;
		?DatumWriter??userDatumWriter?=?new??SpecificDatumWriter（StudentAvro.class）;
		?DataFileWriter??dataFileWriter?=?new??DataFileWriter（userDatumWriter）;
		?dataFileWriter.create（new?StudentAvro（）.getSchema（）?baos）;
		?for（int?i?=?0;?i?