如何将gRPC返回的protobuf DynamicMessage转为可取值的JSON类对象？

以下是几种实用的解析转换方案，可让你按字段获取DynamicMessage中的值：

方案一：利用DynamicMessage原生API直接取值 #

DynamicMessage本身提供了基于FieldDescriptor的字段访问能力，核心是通过消息描述符定位字段：

// 假设dynamicMsg是你的DynamicMessage实例
MessageDescriptor msgDescriptor = dynamicMsg.getDescriptorForType();

// 获取顶层字段field1的描述符
FieldDescriptor field1Desc = msgDescriptor.findFieldByName("field1");
if (field1Desc != null && dynamicMsg.hasField(field1Desc)) {
    // 获取field1对应的嵌套DynamicMessage
    DynamicMessage field1Value = (DynamicMessage) dynamicMsg.getField(field1Desc);
    
    // 获取field1下key1的值
   FieldDescriptor key1Desc = field1Value.getDescriptorForType().findFieldByName("key1");
    String key1Value = (String) field1Value.getField(key1Desc);
}

// 同理获取field2下的嵌套字段
FieldDescriptor field2Desc = msgDescriptor.findFieldByName("field2");
if (field2Desc != null && dynamicMsg.hasField(field2Desc)) {
    DynamicMessage field2Value = (DynamicMessage) dynamicMsg.getField(field2Desc);
    FieldDescriptor key3Desc = field2Value.getDescriptorForType().findFieldByName("key3");
    DynamicMessage key3Value = (DynamicMessage) field2Value.getField(key3Desc);
    String nestedVal1 = (String) key3Value.getField(key3Value.getDescriptorForType().findFieldByName("netsed_key_1"));
}

适用场景：不需要额外转换，希望直接基于Protobuf原生API操作的场景。

方案二：转换为JSON格式访问 #

借助Protobuf官方的JsonFormat工具，将DynamicMessage转换为JSON字符串或JsonObject，之后用熟悉的JSON方式取值：

import com.google.protobuf.util.JsonFormat;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;

// 转换为JSON字符串
String jsonStr = JsonFormat.printer().print(dynamicMsg);

// 解析为JsonObject并取值
JsonObject jsonObj = JsonParser.parseString(jsonStr).getAsJsonObject();
String field1Key1 = jsonObj.getAsJsonObject("field1").get("key1").getAsString();
String field2Key3NestedVal1 = jsonObj.getAsJsonObject("field2")
        .getAsJsonObject("key3")
        .get("netsed_key_1")
        .getAsString();

适用场景：熟悉JSON操作，需要快速转换为通用格式的场景。

方案三：转换为强类型POJO（若有Proto定义） #

如果你有对应的.proto文件，可以先生成对应的Java实体类，再将DynamicMessage合并到实体类中：

// 假设YourGeneratedMessage是根据proto生成的类
YourGeneratedMessage.Builder builder = YourGeneratedMessage.newBuilder();
JsonFormat.parser().merge(jsonStr, builder); // 或者直接mergeFrom
YourGeneratedMessage pojo = builder.build();

// 直接通过getter方法取值
String key1 = pojo.getField1().getKey1();
String nestedVal1 = pojo.getField2().getKey3().getNetsedKey1();

如果没有现成的Proto定义，也可以先转JSON，再用Jackson/Gson将JSON转成自定义POJO或Map：

import com.fasterxml.jackson.databind.ObjectMapper;

ObjectMapper mapper = new ObjectMapper();
Map<String, Object> dataMap = mapper.readValue(jsonStr, Map.class);
String key1 = (String) ((Map) dataMap.get("field1")).get("key1");

适用场景：需要强类型对象，便于后续业务逻辑处理的场景。

方案四：递归转换为嵌套Map结构 #

自己实现递归工具方法，将DynamicMessage转换为嵌套的Map<String, Object>，通过键名直接取值：

import com.google.protobuf.DynamicMessage;
import com.google.protobuf.Descriptors.FieldDescriptor;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class DynamicMessageUtils {
    public static Map<String, Object> toMap(DynamicMessage msg) {
        Map<String, Object> resultMap = new HashMap<>();
        for (FieldDescriptor field : msg.getDescriptorForType().getFields()) {
            if (!msg.hasField(field)) continue;
            
            Object fieldValue = msg.getField(field);
            if (fieldValue instanceof DynamicMessage) {
                // 嵌套消息递归转换
                resultMap.put(field.getName(), toMap((DynamicMessage) fieldValue));
            } else if (fieldValue instanceof List) {
                // 处理重复字段（Protobuf repeated类型）
                List<Object> list = new ArrayList<>();
                for (Object item : (List<?>) fieldValue) {
                    if (item instanceof DynamicMessage) {
                        list.add(toMap((DynamicMessage) item));
                    } else {
                        list.add(item);
                    }
                }
                resultMap.put(field.getName(), list);
            } else {
                // 基础类型直接存入
                resultMap.put(field.getName(), fieldValue);
            }
        }
        return resultMap;
    }
}

// 使用示例
Map<String, Object> dataMap = DynamicMessageUtils.toMap(dynamicMsg);
String key1 = (String) ((Map) dataMap.get("field1")).get("key1");
String nestedVal2 = (String) ((Map) ((Map) dataMap.get("field2")).get("key4")).get("netsed_key_2");

适用场景：需要灵活的键值对访问，且不想依赖第三方JSON工具的场景。

内容的提问来源于stack exchange，提问作者GlidingSwords997