proto3.任何人都无法掩盖JSON

Question

发送

我的proto

service GraphService {
  rpc insertGraphData (InsertRequest) returns (google.protobuf.StringValue) {}
}

message InsertRequest {
  string tagName = 1;
  map<string, google.protobuf.Any> tagProperties = 2;
}

当我使用proto3将像以下我的客户端请求实体

InsertRequest.newBuilder()
                .setTagName("facebook")
                .putTagProperties("userName", Any.newBuilder().setValue(ByteString.copyFrom("zzz", StandardCharsets.UTF_8)).build())
                .build()

时，我的graphRpcService这样的praghrpcservice

@GrpcService
@Slf4j
@RequiredArgsConstructor
public class GraphRpcService extends GraphServiceGrpc.GraphServiceImplBase {

    @Override
    public void insertGraphData(InsertRequest request, StreamObserver<StringValue> responseObserver) {
        StreamObserverDelegate.build(responseObserver).execute(()->{
       InsertRequest insertRequest = toJava(request, A.class);
//...
            return null;
        });
    }

    public static <T> T toJava(Message sourceMessage, Class<T> clazz) {
        if (sourceMessage != null) {
            try {
                return JSON.parseObject(JsonFormat.printer().includingDefaultValueFields().print(sourceMessage), clazz);
            } catch (InvalidProtocolBufferException e) {
                logger.error("ProtoMessage to JSON error:", e);
                throw new BusinessException(CommonEnum.DATA_CONVERSION_EXCEPTION);
            }
        }
        return null;
    }

   public static <T> T toJava2(Message sourceMessage, Class<T> clazz) {
        if (sourceMessage != null) {
            try {
                JsonFormat.TypeRegistry typeRegistry = JsonFormat.TypeRegistry.newBuilder().add(InsertRequest.getDescriptor()).build();
                JsonFormat.Printer printer = JsonFormat.printer().usingTypeRegistry(typeRegistry);
                JsonFormat.Parser parser = JsonFormat.parser().usingTypeRegistry(typeRegistry);
                String json = printer.print(sourceMessage);
                return null;
            } catch (InvalidProtocolBufferException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

当我想解除parse grpc消息到json，然后将

InvalidProtocolBufferException: Cannot find type for url 

i搜索smoe smoe答案丢弃，所以我更改了使用tojava2（）它也会抛出相同的错误，或者，tojava2（）代码有些变质吗？

我能做些什么？谢谢。

Answer 1

当您使用任何时，通常您需要any.pack（）一条消息。请参阅 java生成代码 doc，doc，doc，和。 any.pack（）为您设置type> typeurlprefix为您使用any.unpack（）使用，以确定消息的类型重新包装。

在您的情况下，您可以直接使用any.newbuilder（）。setValue（），并且不设置类型，因此any.unpack（）不知道什么消息类型正在解开包装。

JSON打印机将消息转换为JSON。当它看到任何时，它也尝试解开它。因为它不知道类型，所以它无法做到，因此它抛出了无效的ProtocolBufferexception。请参阅 jsonformat.printer.print.print doc：

public java.lang.String Print（MessageorBuilder Message）
投掷无效的ProtocolBufferexception
抛出异常，如果消息中有未知类型。