如何使用dart protobuf

Question

我正在考虑在我的一个项目中使用dart-protobuf来代替JSON。问题是这个库没有提供任何如何使用它的例子，测试也没有真正的帮助。

我对解析.proto文件的工作方式也有点困惑。

所以我想找一个简单的例子来说明如何在dart中使用这个库。

Answer 1

我不太熟悉dart-protobuf，但是看起来您必须使用protobuf编译器和Dart-protoco-plugin项目来从proto定义生成您的Dart protobuf库。

这里有一些说明：https://github.com/dart-lang/dart-protoc-plugin

Answer 2

我用它，它棒极了。下面是对我来说最难的部分(解序列化)。也许现在医生更好。

发送请求（查询是要发送的协议缓冲区对象）

request.send(query.writeToBuffer()); 

接收响应 （pb.MovieMessage 是协议缓冲区对象，用于反序列化响应）

request.onLoad.listen((ProgressEvent e) {
  if ((request.status >= 200 && request.status < 300) ||
      request.status == 0 || request.status == 304) {

    List<int> buffer = new Uint8List.view(request.response);
    var response = new pb.MovieMessage.fromBuffer(buffer);

编辑

我向服务器发送PB请求的方法

Future<pb.MovieMessage> send(pb.MovieMessage query) {

  var completer = new Completer<pb.MovieMessage>();
  var uri = Uri.parse("http://localhost:8080/public/data/");

  var request = new HttpRequest()
  ..open("POST", uri.toString(), async: true)
    ..overrideMimeType("application/x-google-protobuf")
    ..setRequestHeader("Accept", "application/x-google-protobuf")
    ..setRequestHeader("Content-Type", "application/x-google-protobuf")
    ..responseType = "arraybuffer"
    ..withCredentials = true // seems to be necessary so that cookies are sent
    ..onError.listen((e) {
      completer.completeError(e);
    })
    ..onProgress.listen((e){},
        onError:(e) => _logger.severe("Error: " + e.errorMessage));

    request.onReadyStateChange.listen((e){},
        onError: (e) => _logger.severe("OnReadyStateChange.OnError: " + e.toString())
        );

    request.onLoad.listen((ProgressEvent e) {
      if ((request.status >= 200 && request.status < 300) ||
          request.status == 0 || request.status == 304) {

        List<int> buffer = new Uint8List.view(request.response);
        var response = new pb.MovieMessage.fromBuffer(buffer);
        response.errors.forEach((pb.Error e) => _logger.severe("Error: " + e.errorMessage));

        completer.complete(response);
      } else {
        completer.completeError(e);
      }
    });

    request.send(query.writeToBuffer()); 
    return completer.future;
  }