SocketProtocolBuffersChannel.java 文件源码

public Message callBlockingMethod(MethodDescriptorContainer methodDescriptor, Message request) throws ServiceException {
    try {
        dataOutputStream.writeUTF(methodDescriptor.getServiceDescriptorContainer().getName());
        dataOutputStream.writeUTF(methodDescriptor.getName());
        dataOutputStream.writeUTF(tokenHolder.getToken() == null ? "" : tokenHolder.getToken());
        request.writeDelimitedTo(dataOutputStream);
        dataOutputStream.flush();
        DynamicMessage response = DynamicMessage.getDefaultInstance(methodDescriptor.getOutputDescriptor());
        Builder responseBuilder = response.newBuilderForType();
        responseBuilder.mergeDelimitedFrom(inputStream);
        return responseBuilder.build();
    } catch (IOException e) {
        LOGGER.error("", e);
    }
    return null;
}