NestJS gRPC服务端流式调用findAllRepos报UNIMPLEMENTED错误如何解决？

问题排查 #

UNIMPLEMENTED错误代表gRPC服务端未找到对应名称的方法实现，结合你的代码有三个核心错误：

• 客户端错误使用服务端装饰器：你在客户端RepoGrpcService的findAllRepos方法上标注的@GrpcStreamCall('MainService')是gRPC服务端专用装饰器，作用是注册服务端的流式处理方法，放在客户端代码中会导致调用逻辑异常，甚至干扰服务端的方法注册。
• 服务端流式方法装饰器使用不当：NestJS中@GrpcStreamMethod仅用于处理客户端流式、双向流式的RPC调用，你定义的findAllRepos属于服务端流式（入参为普通消息，返回为流式），使用通用的@GrpcMethod装饰器即可，只要方法返回Observable<Repository>，NestJS会自动识别为服务端流式响应。
• 客户端流式调用逻辑错误：你当前的客户端findAllRepos方法会同步返回空数组，因为gRPC流式响应是异步的，你在subscribe还未收到所有数据时就直接返回了空的results，逻辑不符合异步调用规则。

解决方案 #

1. 修正服务端Controller代码 #

把findAllRepos的装饰器从@GrpcStreamMethod替换为@GrpcMethod：

// server.controller.ts 修正后
@Controller('repo')
export class RepoController {
  constructor(
    @Inject('RepoService') private readonly repoService: RepoService
  ) {}

  @GrpcMethod('MainService', 'findRepoById')
  findRepoById(request: RepoById, metadata: Metadata): Repository {
    const targetId = request.id;
    return this.repoService.findRepoById(targetId);
  }

  // 替换为@GrpcMethod，返回Observable会被自动识别为服务端流式
  @GrpcMethod('MainService', 'findAllRepos')
  findAllRepos(request: NoParam, metadata: Metadata): Observable<Repository> {
    const subject = new Subject<Repository>();
    const repositories = this.repoService.findAllRepos();
    repositories.forEach((repo) => {
      subject.next(repo);
    });
    subject.complete();
    return subject.asObservable();
  }
}

2. 修正客户端Service代码 #

删除客户端的@GrpcStreamCall装饰器，同时调整异步收集结果的逻辑：

// client.service.ts 修正后
import { toArray } from 'rxjs';

export class RepoGrpcService implements OnModuleInit {
  private mainService: MainServiceClient;

  constructor(@Inject('main_package') private client: ClientGrpc) {}

  onModuleInit() {
    this.mainService = this.client.getService<MainServiceClient>('MainService');
  }

  findRepoById(id: number): Observable<Repository> {
    return this.mainService.findRepoById({ id });
  }

  // 删除@GrpcStreamCall装饰器，使用rxjs的toArray操作符聚合流式结果
  findAllRepos(): Observable<Repository[]> {
    return this.mainService.findAllRepos({}).pipe(
      toArray()
    );
  }
}

3. 可选配置校验 #

如果修改后仍有报错，检查服务端gRPC配置项：

• 确认protoPath指向正确的main.proto文件
• 确认package配置为main，和proto文件内的package定义一致
• 确认RepoController已经在对应模块的controllers数组中完成注册

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