Flutter移动端应用中如何拦截GRPC响应？

在Flutter里拦截gRPC响应，核心是利用grpc包提供的ClientInterceptor类，通过重写它的方法来捕获并处理响应。以下是具体实现步骤：

1. 自定义响应拦截器类 #

创建一个继承自ClientInterceptor的类，重写interceptUnaryCall（处理单次请求响应）和interceptStreamingCall（处理流式请求响应）方法：

import 'package:grpc/grpc.dart';

class GrpcResponseInterceptor extends ClientInterceptor {
  // 拦截单次请求的响应
  @override
  ResponseFuture<R> interceptUnaryCall<Q, R>(
    ClientMethod<Q, R> method,
    Q request,
    CallOptions options,
    UnaryInvoker<Q, R> invoker,
  ) {
    // 先执行原请求逻辑，拿到响应的Future
    final responseFuture = invoker(method, request, options);
    
    // 监听响应结果，实现拦截逻辑
    return responseFuture.then((response) {
      // 这里可以添加你的处理逻辑：比如打印响应、修改响应内容、上报日志等
      print('拦截到Unary响应 [${method.name}]: ${response.toString()}');
      // 返回原响应或修改后的响应
      return response;
    }).catchError((error) {
      // 处理请求错误场景
      print('Unary请求出错 [${method.name}]: $error');
      throw error; // 抛出错误让上层业务处理
    });
  }

  // 拦截流式请求的响应
  @override
  ResponseStream<R> interceptStreamingCall<Q, R>(
    ClientMethod<Q, R> method,
    Stream<Q> requests,
    CallOptions options,
    StreamingInvoker<Q, R> invoker,
  ) {
    final responseStream = invoker(method, requests, options);
    
    // 处理流式响应的每一条数据
    return responseStream.map((response) {
      print('拦截到Streaming响应 [${method.name}]: ${response.toString()}');
      return response;
    }).handleError((error) {
      print('Streaming请求出错 [${method.name}]: $error');
      throw error;
    });
  }
}

2. 在gRPC客户端中使用拦截器 #

创建gRPC客户端实例时，将自定义的拦截器传入interceptors参数：

// 假设你的gRPC客户端是自动生成的MyServiceClient
final client = MyServiceClient(
  ClientChannel(
    'your_server_host',
    port: 50051,
    options: const ChannelOptions(credentials: ChannelCredentials.insecure()),
  ),
  interceptors: [GrpcResponseInterceptor()], // 注入拦截器
);

补充说明 #

• 如果需要修改响应内容，直接在then或map方法中修改后返回即可，上层业务会拿到修改后的响应。
• 可以在拦截器中统一处理错误，比如收集错误日志、做重试逻辑等。

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