1

我正在尝试使用以下堆栈构建 Web 应用程序：

  • 颤振/飞镖
  • 去/goproxy
  • gRPC
  • MongoDB

我能够成功地定义一个 protobuf 并将其编译到 Dart 和 Go 中，但是现在我正在尝试将 UI 与后端集成，我遇到了以下问题：

Error: gRPC Error (code: 2, codeName: UNKNOWN, message:
null, details: [], rawResponse: null, trailers: {})

这是我的客户代码：

import 'package:grpc/grpc_web.dart';

import 'package:proj/protos/cards.pb.dart';
import 'package:proj/protos/cards.pbgrpc.dart';

class FiltersService {
  static ResponseFuture<Filters> getFilters() {
    GrpcWebClientChannel channel =
        GrpcWebClientChannel.xhr(Uri.parse('http://localhost:9000'));

    FiltersServiceClient clientStub = FiltersServiceClient(
      channel,
    );

    return clientStub.getFilters(Void());
  }
}

服务器控制器代码：

const (
    port = 9000
)

var (
    grpcServer *grpc.Server
)


func StartServer() {
    log.Println("Starting server")
    listener, err := net.Listen("tcp", fmt.Sprintf(":%v", port))
    if err != nil {
        log.Fatalf("Unable to listen to port %v\n%v\n", port, err)
    }

    repositories.ConnectToMongoDB()

    grpcServer = grpc.NewServer()
    registerServices()
    grpcWebServer := grpcweb.WrapServer(grpcServer)

    httpServer := &http.Server{
        Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            if r.ProtoMajor == 2 {
                grpcWebServer.ServeHTTP(w, r)
            } else {
                w.Header().Set("Access-Control-Allow-Origin", "*")
                w.Header().Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
                w.Header().Set("Access-Control-Allow-Headers", "Accept, Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization, X-User-Agent, X-Grpc-Web")
                w.Header().Set("grpc-status", "")
                w.Header().Set("grpc-message", "")
                if grpcWebServer.IsGrpcWebRequest(r) {
                    grpcWebServer.ServeHTTP(w, r)
                }
            }
        }),
    }

    httpServer.Serve(listener)

}

// Register services defined in protobufs to call from UI
func registerServices() {
    cardsService := &services.CardsService{}
    protos.RegisterCardsServiceServer(grpcServer, cardsService)

    filtersService := &services.FiltersService{}
    protos.RegisterFiltersServiceServer(grpcServer, filtersService)
}

我可以告诉服务器正在正确接收请求，并且当我输出服务的响应时，我得到了预期的响应。

这是我正在调用的服务：

func (service *FiltersService) GetFilters(ctx context.Context, void *protos.Void) (*protos.Filters, error) {
    filters := repositories.GetFilters()
    return converters.FiltersStructToFiltersProtoConverter(filters), nil
}

当我输出 的响应时converters.FiltersStructToFiltersProtoConverter(filters)，我得到了正确的输出，所以看起来我的服务器设置方式仍然存在问题。

我知道这不是很多信息，但是我不确定您可能需要哪些其他信息，但可以根据需要添加。

4

0 回答 0