pkg_callgrpcrun 是一个用于在 Flutter 应用中方便地进行 gRPC 调用的插件。它简化了 gRPC 客户端的创建和调用过程，使得开发者可以更轻松地集成 gRPC 服务到 Flutter 应用中。

安装 pkg_callgrpcrun

首先，你需要在 pubspec.yaml 文件中添加 pkg_callgrpcrun 插件的依赖：

dependencies:
  flutter:
    sdk: flutter
  pkg_callgrpcrun: ^1.0.0  # 请使用最新的版本号

然后运行 flutter pub get 来安装依赖。

基本使用

1. 导入必要的库

在你的 Dart 文件中导入 pkg_callgrpcrun 插件：

import 'package:pkg_callgrpcrun/pkg_callgrpcrun.dart';

2. 创建 gRPC 客户端

使用 CallGrpcRun 类来创建 gRPC 客户端。你需要提供 gRPC 服务器的地址和端口：

final grpcClient = CallGrpcRun('https://your-grpc-server-address', 50051);

3. 调用 gRPC 方法

假设你有一个 gRPC 服务定义如下：

service MyService {
  rpc MyMethod (MyRequest) returns (MyResponse);
}

你可以使用 grpcClient.call 方法来调用这个服务：

final request = MyRequest()..someField = 'someValue';

try {
  final response = await grpcClient.call<MyResponse>(
    'MyService/MyMethod',
    request,
    (json) => MyResponse.fromJson(json),
  );
  print('Response: ${response.someField}');
} catch (e) {
  print('Error: $e');
}

4. 处理响应

grpcClient.call 方法返回一个 Future，你可以使用 await 来等待响应，并处理返回的数据。

高级用法

自定义 gRPC 调用选项

你可以通过传递 CallOptions 来自定义 gRPC 调用的选项，例如超时时间、认证信息等：

final response = await grpcClient.call<MyResponse>(
  'MyService/MyMethod',
  request,
  (json) => MyResponse.fromJson(json),
  options: CallOptions(timeout: Duration(seconds: 5)),
);

错误处理

grpcClient.call 方法会抛出异常，你可以使用 try-catch 来捕获和处理错误：

try {
  final response = await grpcClient.call<MyResponse>(
    'MyService/MyMethod',
    request,
    (json) => MyResponse.fromJson(json),
  );
  print('Response: ${response.someField}');
} catch (e) {
  print('Error: $e');
}

示例

以下是一个完整的示例，展示了如何使用 pkg_callgrpcrun 插件进行 gRPC 调用：

import 'package:flutter/material.dart';
import 'package:pkg_callgrpcrun/pkg_callgrpcrun.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('gRPC Example'),
        ),
        body: Center(
          child: ElevatedButton(
            onPressed: () async {
              final grpcClient = CallGrpcRun('https://your-grpc-server-address', 50051);
              final request = MyRequest()..someField = 'someValue';

              try {
                final response = await grpcClient.call<MyResponse>(
                  'MyService/MyMethod',
                  request,
                  (json) => MyResponse.fromJson(json),
                );
                print('Response: ${response.someField}');
              } catch (e) {
                print('Error: $e');
              }
            },
            child: Text('Call gRPC'),
          ),
        ),
      ),
    );
  }
}

class MyRequest {
  String someField;

  Map<String, dynamic> toJson() => {'someField': someField};
}

class MyResponse {
  String someField;

  MyResponse.fromJson(Map<String, dynamic> json) : someField = json['someField'];
}