protobuf对象与JSON相互转换 - ToB企服应用市场:ToB评测及商务社交产业平台

<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
<version>3.19.1</version>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java-util</artifactId>
<version>3.19.1</version>
</dependency>

复制代码

// 接收数据反序列化：将字节数据转化为对象数据。
UserProtoBuf.User user = UserProtoBuf.User.parseFrom(byteData);
// 1、proto 对象转 Json
//获取 Printer对象用于生成JSON字符串
JsonFormat.Printer printer = JsonFormat.printer();
String userJsonStr = printer.print(user);

复制代码

// 创建 proto 对象
UserProtoBuf.User.Builder userBuilder = UserProtoBuf.User.newBuilder();
// 2、Json 转 proto 对象
//获取 Parser对象用于解析JSON字符串
JsonFormat.Parser parser = JsonFormat.parser();
parser.merge(userJsonStr2, userBuilder);

复制代码

syntax = "proto3";
//生成 proto java文件名(一般指定，文件名+自定义。如果不指定，默认时文件名+OuterClass)
option java_outer_classname = "UserProtoBuf";
message User {
int32 age = 1;
int64 timestamp = 2;
bool enabled = 3;
float height = 4;
double weight = 5;
string userName = 6;
string Full_Address = 7;
}

复制代码

import com.google.protobuf.util.JsonFormat;
public class UserTest {
public static void main(String[] args) throws Exception {
// 将数据序列化
byte[] byteData = getClientPush();
System.out.println("获取到字节数据：byteData长度=" + byteData.length);
System.out.println("===========");
/**
* 接收数据反序列化：将字节数据转化为对象数据。
*/
UserProtoBuf.User user = UserProtoBuf.User.parseFrom(byteData);
System.out.println("==== get获取 user信息：=======");
System.out.println("user信息： \n" + user);
System.out.println("------------------");
System.out.println("getAge= " + user.getAge());
System.out.println("getTimestamp= " + user.getTimestamp());
System.out.println("getEnabled= " + user.getEnabled());
System.out.println("getHeight= " + user.getHeight());
System.out.println("getWeight= " + user.getWeight());
System.out.println("getUserName= " + user.getUserName());
System.out.println("getFullAddress= " + user.getFullAddress());
/**
* proto 对象转 Json互转
*/
// 1、proto 对象转 Json
String userJsonStr = JsonFormat.printer()
//.includingDefaultValueFields() // 表示 Json输出包含默认值（显示和隐式赋默认值）的字段。
.print(user);
System.out.println("=====1、proto对象转 Json字符串：======");
System.out.println("userJsonStr= " + userJsonStr);
// 2、Json 转 proto 对象
String userJsonStr2 = "{\n" +
" "age":18,\n" +
" "timestamp":"1698377283315",\n" +
" "enabled":false,\n" +
" "height":1.8,\n" +
" "weight":66.76,\n" +
" "userName":"赵云"\n" +
"}";
// 创建 proto 对象
UserProtoBuf.User.Builder userBuilder = UserProtoBuf.User.newBuilder();
JsonFormat.parser()
//.ignoringUnknownFields() // 表示如果 json 串中存在的属性，proto 对象中不存在，则进行忽略，否则会抛出 InvalidProtocolBufferException异常
.merge(userJsonStr2, userBuilder);
UserProtoBuf.User user1 = userBuilder.build();
System.out.println("=====2、Json 转 proto 对象：======");
System.out.println("user1信息： \n" + user1);
System.out.println("------------------");
}
/**
* 模拟发送方，将数据序列化后发送
*
* @return
*/
private static byte[] getClientPush() {
// 按照定义的数据结构，创建一个对象。
UserProtoBuf.User.Builder user = UserProtoBuf.User.newBuilder();
user.setAge(18);
user.setTimestamp(System.currentTimeMillis());
user.setEnabled(false);
//user.setEnabled(true);
//user.setHeight(1.88F);
user.setWeight(66.76D);
user.setUserName("赵云");
//user.setFullAddress("王者-打野");
/**
* 发送数据序列化：将对象数据转化为字节数据输出
*/
UserProtoBuf.User userBuild = user.build();
byte[] bytes = userBuild.toByteArray();
return bytes;
}
}

复制代码