首先要在pom.xml里添加Protobuf的jar包

1. <dependency>
2. <groupId>com.dyuproject.protostuff </groupId>
3. <artifactId>protostuff-core </artifactId>
4. <version>1.0.8 </version>
5. </dependency>
7. <dependency>
8. <groupId>com.dyuproject.protostuff </groupId>
9. <artifactId>protostuff-runtime </artifactId>
10. <version>1.0.8 </version>
11. </dependency>

序列化的实体类User.java（不需要实现Serializable接口）

1. package com.serialize.entity;
3. public class User {
4. private String id;
5. private String username;
6. private String password;
8. public User() {
9. }
10. public User(String id, String username, String password) {
11. this.id = id;
12. this.username = username;
13. this.password = password;
14. }
15. public String getId() {
16. return id;
17. }
18. public void setId(String id) {
19. this.id = id;
20. }
21. public String getUsername() {
22. return username;
23. }
24. public void setUsername(String username) {
25. this.username = username;
26. }
27. public String getPassword() {
28. return password;
29. }
30. public void setPassword(String password) {
31. this.password = password;
32. }
33. @Override
34. public String toString() {
35. return "User [id=" + id + ", username=" + username + ", password="
36. + password + "]";
37. }
40. }

1. package com.serialize.utils;
3. import com.dyuproject.protostuff.LinkedBuffer;
4. import com.dyuproject.protostuff.ProtobufIOUtil;
5. import com.dyuproject.protostuff.runtime.RuntimeSchema;
7. public class SerializeUtils{
8. public static <T> byte[] serialize(T t,Class<T> clazz) {
9. return ProtobufIOUtil.toByteArray(t, RuntimeSchema.createFrom(clazz),
10. LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE));
11. }
12. public static <T> T deSerialize(byte[] data,Class<T> clazz) {
13. RuntimeSchema<T> runtimeSchema = RuntimeSchema.createFrom(clazz);
14. T t = runtimeSchema.newMessage();
15. ProtobufIOUtil.mergeFrom(data, t, runtimeSchema);
16. return t;
17. }
18. }

1. package com.serialize;
3. import com.serialize.entity.User;
4. import com.serialize.utils.SerializeUtils;
6. public class App {
7. public static void main(String[] args) {
8. User user= new User( "1", "xiaobao", "123456");
9. System.out.println( "序列化");
10. byte[] data = SerializeUtils.serialize(user,User.class);
11. for ( byte b : data) {
12. System.out.print(b);
13. }
14. System.out.println();
15. System.out.println( "反序列化");
16. User user2 = SerializeUtils.deSerialize(data,User.class);
17. System.out.println(user2);
18. }
19. }