Protostuff使用案例2018.5.17版权声明：本文是博主chszs的原创文章，未经博主许可不得转载。 1、Maven依赖的JAR软件包dependencygroupidio.proto stuff/groupidartifactidprotostuff-core/artifactidversion1.5.9/verstidon 部署的ependencydependencygroupidio.proto stuff/groupidartifactidprotostuff-runtime/artifactidversion1.5.9/version/dependencydependencygroupidio.proto stuff/groupidartifactidprotostuff-API/artifactidversion1.5.9/version/dependendion
package demo.protostuff； import java.util.List； 公共类用户{私有第一个名称； 私有字符串最后名称； 隐私字符串电子邮件； 私有监听器friends； 私有列表卡； 公共用户()公共用户(字符串电子邮件) { this.email=email； //gettersandsetterspublicstringgetfirstname () {返回第一名； } publicvoidsetfirstname (string first name ) { this.firstName=firstName； } public String getLastName () { return lastName； } publicvoidsetlastname (string last name ) { this.lastName=lastName； }公共字符串get email (() { return email； } publicvoidsetemail (字符串电子邮件) { this.email=email； }公共监听器get friends (() { return friends； } publicvoidsetfriends (listuser friends ) { this.friends=friends； }公共列表car getcars () { return cars； }publicvoidsetcars(listcarcars ) { this.cars=cars； } @Override public String toString () return'user ) ' ' firstname=''firstname''、last name=' ' last name 'email } car.javapackagedemo.proto stuff； 公共类颜色{私有类颜色； 私有字符串car _ name； 隐私集成器隐私； 公共字符串getcolor () { return color； } public void setcolor (字符串颜色) { this.color=color； }公共字符串getc
ar_name() { return car_name; } public void setCar_name(String car_name) { this.car_name = car_name; } public Integer getPrice() { return price; } public void setPrice(Integer price) { this.price = price; } public Car(String car_name) { super(); this.car_name = car_name; } public Car() { super(); } @Override public String toString() { return "Car [color=" + color + ", car_name=" + car_name + ", price=" + price + "]"; }} 3、主程序类这里是App.java
package demo.protostuff;import java.util.ArrayList;import java.util.List;import io.protostuff.LinkedBuffer;import io.protostuff.ProtostuffIOUtil;import io.protostuff.runtime.RuntimeSchema;public class App { private static RuntimeSchema<User> schema = RuntimeSchema.createFrom(User.class); public static void main(String[] args) { User user1 = new User(); user1.setEmail("10000@qq.com"); user1.setFirstName("zhang"); user1.setLastName("sanfeng"); List<User> users = new ArrayList<>(); users.add(new User("20000@qq.com")); user1.setFriends(users); Car car1 = new Car("宾利"); Car car2 = new Car("法拉利"); List<Car> cars = new ArrayList<>(); cars.add(car1); cars.add(car2); user1.setCars(cars); byte[] bytes = ProtostuffIOUtil.toByteArray(user1, schema, LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE)); User user2 = schema.newMessage(); ProtostuffIOUtil.mergeFrom(bytes, user2, schema); System.out.println(user2); System.out.println(); // 使用自定义的工具类 byte[] bytes1 = ProtostuffUtil.serializer(user1); User newUser = ProtostuffUtil.deserializer(bytes1, User.class); System.out.println(newUser); }}程序说明：
RuntimeSchema类用于在运行时从Java实体对象中生成所需的模式SchemaProtostuffIOUtil是一个工具类，用于对消息或对象进行序列化/反序列化LinkedBuffer是一个缓冲区类，它封装了字节数组并具有对下一个缓冲区的引用以便能动态增加容量。执行程序，输出如下：
User{firstName=’zhang’, lastName=’sanfeng’, email=’10000@qq.com’, friends=[User{firstName=’null’, lastName=’null’, email=’20000@qq
.com’, friends=null, cars=null}], cars=[Car [color=null, car_name=宾利, price=null], Car [color=null, car_name=法拉利, price=null]]}
User{firstName=’zhang’, lastName=’sanfeng’, email=’10000@qq.com’, friends=[User{firstName=’null’, lastName=’null’, email=’20000@qq
.com’, friends=null, cars=null}], cars=[Car [color=null, car_name=宾利, price=null], Car [color=null, car_name=法拉利, price=null]]}
这里是ProtostuffUtil.java
package demo.protostuff;import java.util.Map;import java.util.concurrent.ConcurrentHashMap;import io.protostuff.LinkedBuffer;import io.protostuff.ProtostuffIOUtil;import io.protostuff.Schema;import io.protostuff.runtime.RuntimeSchema;public class ProtostuffUtil { private static Map<Class<?>, Schema<?>> cachedSchema = new ConcurrentHashMap<Class<?>, Schema<?>>(); private static <T> Schema<T> getSchema(Class<T> clazz) { @SuppressWarnings("unchecked") Schema<T> schema = (Schema<T>) cachedSchema.get(clazz); if (schema == null) { schema = RuntimeSchema.getSchema(clazz); if (schema != null) { cachedSchema.put(clazz, schema); } } return schema; } /** * 将对象序列化 * @param obj 对象 * @return */ public static <T> byte[] serializer(T obj) { @SuppressWarnings("unchecked") Class<T> clazz = (Class<T>) obj.getClass(); LinkedBuffer buffer = LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE); try { Schema<T> schema = getSchema(clazz); return ProtostuffIOUtil.toByteArray(obj, schema, buffer); } catch (Exception e) { throw new IllegalStateException(e.getMessage(), e); } finally { buffer.clear(); } } /** * 将字节数组数据反序列化 * @param data 字节数组 * @param clazz 对象 * @return */ public static <T> T deserializer(byte[] data, Class<T> clazz) { try { T obj = clazz.newInstance(); Schema<T> schema = getSchema(clazz); ProtostuffIOUtil.mergeFrom(data, obj, schema); return obj; } catch (Exception e) { throw new IllegalStateException(e.getMessage(), e); } }}