Веб-запрос GRPC с использованием клиента golang?

Я пытаюсь создать сервер grpc с помощью оболочки grpc-web. Идея состоит в том, чтобы использовать этот сервер grpc как с приложением на основе браузера, так и с обычным клиентом grpc. Но я не понимаю, как я могу заставить его работать для обоих приложений?

package main

import (
    "context"
    "fmt"
    "io"
    "log"
    "net/http"
    "strconv"
    "time"

    "github.com/repo/test-grpc-server/greet/greetpb"
    "github.com/improbable-eng/grpc-web/go/grpcweb"
    "google.golang.org/grpc"
)

type server struct{}

func (*server) Greet(ctx context.Context, req *greetpb.GreetRequest) (*greetpb.GreetResponse, error) {
    fmt.Printf("Greet function was invoked with %v", req)
    firstName := req.GetGreeting().GetFirstName()
    result := "Hello " + firstName
    res := greetpb.GreetResponse{
        Result: result,
    }
    return &res, nil
}

func (*server) GreetManyTimes(req *greetpb.GreetManyTimesRequest, stream greetpb.GreetService_GreetManyTimesServer) error {
    fmt.Printf("GreetMany function was invoked with %v", req)

    firstName := req.GetGreeting().GetFirstName()

    for i := 0; i < 10; i++ {
        result := "Hello " + firstName + " number " + strconv.Itoa(i)
        res := &greetpb.GreetManyTimesResponse{
            Result: result,
        }
        stream.Send(res)
        time.Sleep(1000 * time.Millisecond)
    }
    return nil

}
func (*server) LongGreet(stream greetpb.GreetService_LongGreetServer) error {
    fmt.Printf("LongGreet function was invoked with a streaming request\n")
    result := ""
    for {
        req, err := stream.Recv()
        if err == io.EOF {
            // we have finished reading the client stream
            return stream.SendAndClose(&greetpb.LongGreetResponse{
                Result: result,
            })
        }
        if err != nil {
            log.Fatalf("Error while reading client stream: %v", err)
        }

        firstName := req.GetGreeting().GetFirstName()
        result += "Hello " + firstName + "! "
    }
}



func main() {
    fmt.Println("Go gRPC Server")
    /*lis, err := net.Listen("tcp", ":5051")
    if err != nil {
        log.Fatalf("Failed to listen: %v", err)
    }*/
    grpcServer := grpc.NewServer()
    greetpb.RegisterGreetServiceServer(grpcServer, &server{})
    grpc := grpcweb.WrapServer(grpcServer)
    http.HandleFunc("/", func(resp http.ResponseWriter, req *http.Request) {
        allowCors(resp, req)
        if grpc.IsGrpcWebRequest(req) || grpc.IsAcceptableGrpcCorsRequest(req) {
            grpc.ServeHTTP(resp, req)
        }
    })
    httpPort := ":50051"
    fmt.Println("HTTP server listening on", httpPort)
    err := http.ListenAndServe(httpPort, nil)
    if err != nil {
        log.Fatal("Failed to start a HTTP server:", err)
    }

}

func allowCors(resp http.ResponseWriter, req *http.Request) {
    resp.Header().Set("Access-Control-Allow-Origin", "*")
    resp.Header().Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
    resp.Header().Set("Access-Control-Expose-Headers", "grpc-status, grpc-message")
    resp.Header().Set("Access-Control-Allow-Headers", "Accept, Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, XMLHttpRequest, x-user-agent, x-grpc-web, grpc-status, grpc-message")
}

Теперь я пытаюсь вызвать функцию grpc из своего клиента, как показано ниже. Но это не работает..

package main

import (
    "context"
    "fmt"
    "io"
    "log"
    "time"

    "github.com/repo/test-grpc-server/greet/greetpb"
    "github.com/repo/test-grpc-server/sum/sumpb"
    "google.golang.org/grpc"
)

func main() {

    fmt.Println("Hello I'm a client")
    conn, err := grpc.Dial("0.0.0.0:50051", grpc.WithInsecure())
    if err != nil {
        log.Fatalf("could not connect: %v", err)
    }
    defer conn.Close()

    c := greetpb.NewGreetServiceClient(conn)

    doUnary(c)
}
func doUnary(c greetpb.GreetServiceClient) {
    fmt.Println("do unary from the client")
    req := &greetpb.GreetRequest{
        Greeting: &greetpb.Greeting{
            FirstName: "Hsn",
            LastName:  "Hrn",
        },
    }
    res, err := c.Greet(context.Background(), req)
    if err != nil {
        log.Fatalf("error while calling Greet RPC: %v", err)
    }
    log.Printf("Response from Greet: %v", res.Result)

}

Мой файл .prot выглядит так ..

syntax = "proto3";

package greet;
option go_package="./greet/greetpb";

message Greeting {
    string first_name =1 ;
    string last_name = 2;
}

message GreetRequest {
    Greeting greeting = 1;
}

message GreetResponse {
    string result = 1;
}

message GreetManyTimesRequest{
    Greeting greeting =1;
}

message GreetManyTimesResponse{
    string result=1;
}
message LongGreetRequest {
    Greeting greeting = 1;


}

message LongGreetResponse{
    string result = 1;
}


service GreetService{
    //Unary
    rpc Greet (GreetRequest) returns (GreetResponse) {};
    //Server Streaming 
    rpc GreetManyTimes(GreetManyTimesRequest) returns (stream GreetManyTimesResponse) {};
    //Client Streaming 
    rpc LongGreet(stream LongGreetRequest) returns (LongGreetResponse) {};

}

Журналы ошибок, которые я получаю:

Hello I'm a client
INFO: 2021/04/27 12:53:17 [core] parsed scheme: ""
INFO: 2021/04/27 12:53:17 [core] scheme "" not registered, fallback to default scheme
INFO: 2021/04/27 12:53:17 [core] ccResolverWrapper: sending update to cc: {[{0.0.0.0:50051  <nil> 0 <nil>}] <nil> <nil>}
INFO: 2021/04/27 12:53:17 [core] ClientConn switching balancer to "pick_first"
INFO: 2021/04/27 12:53:17 [core] Channel switches to new LB policy "pick_first"
INFO: 2021/04/27 12:53:17 [core] Subchannel Connectivity change to CONNECTING
INFO: 2021/04/27 12:53:17 [core] parsed scheme: ""
INFO: 2021/04/27 12:53:17 [core] scheme "" not registered, fallback to default scheme
INFO: 2021/04/27 12:53:17 [core] ccResolverWrapper: sending update to cc: {[{0.0.0.0:50051  <nil> 0 <nil>}] <nil> <nil>}
INFO: 2021/04/27 12:53:17 [core] ClientConn switching balancer to "pick_first"
INFO: 2021/04/27 12:53:17 [core] Channel switches to new LB policy "pick_first"
INFO: 2021/04/27 12:53:17 [core] Subchannel Connectivity change to CONNECTING
do unary from the client
INFO: 2021/04/27 12:53:17 [core] blockingPicker: the picked transport is not ready, loop back to repick
INFO: 2021/04/27 12:53:17 [core] Subchannel picks a new address "0.0.0.0:50051" to connect
INFO: 2021/04/27 12:53:17 [core] pickfirstBalancer: UpdateSubConnState: 0xc000021cd0, {CONNECTING <nil>}
INFO: 2021/04/27 12:53:17 [core] Channel Connectivity change to CONNECTING
INFO: 2021/04/27 12:53:17 [core] Subchannel picks a new address "0.0.0.0:50051" to connect
INFO: 2021/04/27 12:53:17 [core] pickfirstBalancer: UpdateSubConnState: 0xc000021ed0, {CONNECTING <nil>}
INFO: 2021/04/27 12:53:17 [core] Channel Connectivity change to CONNECTING
INFO: 2021/04/27 12:53:17 [core] Subchannel Connectivity change to TRANSIENT_FAILURE
INFO: 2021/04/27 12:53:17 [transport] transport: loopyWriter.run returning. connection error: desc = "transport is closing"
INFO: 2021/04/27 12:53:17 [transport] transport: loopyWriter.run returning. connection error: desc = "transport is closing"
INFO: 2021/04/27 12:53:17 [core] Subchannel Connectivity change to TRANSIENT_FAILURE
INFO: 2021/04/27 12:53:17 [core] pickfirstBalancer: UpdateSubConnState: 0xc000021ed0, {TRANSIENT_FAILURE connection closed}
INFO: 2021/04/27 12:53:17 [core] Channel Connectivity change to TRANSIENT_FAILURE
INFO: 2021/04/27 12:53:17 [core] pickfirstBalancer: UpdateSubConnState: 0xc000021cd0, {TRANSIENT_FAILURE connection closed}
INFO: 2021/04/27 12:53:17 [core] Channel Connectivity change to TRANSIENT_FAILURE
2021/04/27 12:53:17 error while calling Greet RPC: rpc error: code = Unavailable desc = connection closed
exit status 1

Кто-то будет очень благодарен за помощь. Спасибо!


person Aech    schedule 27.04.2021    source источник
comment
Попробуйте использовать это: conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure()) в клиенте. Я подозреваю, что "0.0.0.0" не маршрутизируемый адрес.   -  person Tinkerer    schedule 27.04.2021
comment
@Tinkerer Спасибо за ответ. Но нет, это все то же самое. :(   -  person Aech    schedule 27.04.2021
comment
Журнал выглядит иначе?   -  person Tinkerer    schedule 27.04.2021
comment
ИНФОРМАЦИЯ: 2021/04/27 16:32:53 [core] ccResolverWrapper: отправка обновления на cc: {[{localhost: 50051 ‹nil› 0 ‹nil›}] ‹nil› ‹nil›}   -  person Aech    schedule 27.04.2021
comment
только эта строка отличается   -  person Aech    schedule 27.04.2021
comment
Удалось ли вам подтвердить, что grpc.io/docs/languages/go/quickstart У тебя пример работает? (Кроме того, вы уверены, что ваш клиент - тот, который вы используете? Я не вижу никаких ссылок на включенный пакет "github.com/repo/test-grpc-server/sum/sumpb" в коде).   -  person Tinkerer    schedule 27.04.2021
comment
На самом деле у меня больше функций, где используется sumpb. И я не вызываю эти функции в основном прямо сейчас, поэтому не разместил здесь код ..   -  person Aech    schedule 27.04.2021
comment
Мой клиент отлично работает, когда я удаляю оболочку grpcweb из кода сервера. Только проблема в том, что я не могу использовать сервер как для браузера, так и для обычного клиента, как я написал в своем вопросе. Этот сервер работает нормально, например. с веб-клиентом vue.js. и если я удалю оболочку, она будет работать с клиентом, который я разместил здесь, но не с моим веб-клиентом vue.js   -  person Aech    schedule 27.04.2021
comment
Вы пробовали вместо этого gRPC Web-прокси?   -  person Sam Chats    schedule 27.04.2021
comment
Привет, @Sam, я установил его, но не знал, как его использовать? Не могли бы вы помочь? Я новичок в голанге. Я запустил его с адресом моего сервера 50051, и он вернул мне 0.0.0.0:8080. Тогда мне нужно будет использовать порт 8080 в моем клиенте или порт 50051? И мне следует использовать с ним обертку grpcweb или я должен использовать обычный сервер grpc?   -  person Aech    schedule 27.04.2021
comment
Вы должны использовать свой обычный сервер grpc. Из вашего описания кажется, что вам нужно использовать порт 8080 от вашего клиента.   -  person Sam Chats    schedule 27.04.2021
comment
github.com/gustavohenrique/grpc-web-golang-vuejs, я попробовал это приложение с веб-прокси gRPC .. Я заменил бэкэнд на обычный сервер grpc и запустил прокси. но интерфейсное приложение не может с ним работать ..   -  person Aech    schedule 27.04.2021
comment
gRPC и gRPC-Web - это разные проводные протоколы (gRPC-Web был создан, потому что API-интерфейсы веб-браузера не обеспечивают достаточный контроль над запросами HTTP / 2 для реализации gRPC). Сервер может работать как (на разных портах); ваш веб-клиент должен подключаться через gRPC-Web, а клиенты переходить через gRPC (можно было бы написать клиент gRPC-Web для Go и есть, но gRPC более эффективен). github.com/improbable-eng/grpc-web/go/grpcweb у меня хорошо работает (и это проще, чем развертывание прокси).   -  person Brits    schedule 28.04.2021
comment
Привет @ Brits, Спасибо за комментарий. Как вам удалось запустить и то, и другое одновременно? не могли бы вы поделиться некоторыми примерами? это было бы действительно полезно ... Спасибо!   -  person Aech    schedule 28.04.2021
comment
Было бы неплохо запустить один сервер в обычном режиме? и прочее вне рутины? я только что проверил .. он работает. но будет ли это нормально для более длительного пробега?   -  person Aech    schedule 28.04.2021
comment
@Aech, который должен работать нормально (если вы хотите поддерживать чистое завершение работы, вы можете запустить оба сервера в отдельных процедурах go). Я добавлю ответ с грубым кодом.   -  person Brits    schedule 29.04.2021


Ответы (1)


Согласно комментариям, проблема в том, что вы пытались подключиться к серверу gRPC-Web с помощью клиента gRPC. gRPC и gRPC-Web - это разные проводные протоколы (gRPC-Web был создан, потому что API-интерфейсы веб-браузера не обеспечивают достаточный контроль над запросами HTTP / 2 для реализации gRPC). Это сообщение в блоге содержит хороший обзор.

Поскольку вы создаете веб-приложение, вам необходимо использовать gRPC-Web; если вы также хотите подключиться к своему серверу с помощью клиента go, то предпочтительным вариантом является использование gRPC (сервер может и то, и другое одновременно). Другой вариант, который может работать, - использовать gRPC-Web-клиент, но я не пробовал (будет менее эффективно).

«Официальный» способ запуска gRPC-Web - через envoy plugin, но пока вы это пишете, перейдите на страницу incredable-eng / grpc-web предоставляет другой, более простой вариант, который вы уже используете (у них также есть прокси, но это усложняет развертывание).

Ваш сервер необходимо изменить для работы как gRPC, так и gRPC-Web. Самый простой вариант - запустить их на разных портах (можно использовать мультиплексор для определения типа содержимого, но я не пробовал это делать; он хорошо работает, если вы хотите обслуживать html / js и gRPC-Web на одном порту).

Подход, который я использую для запуска обоих серверов, следующий (пожалуйста, рассматривайте это как неполный псевдокод, я извлек фрагменты из нескольких моих приложений, но не скомпилировал / не тестировал и т. Д.; Не стесняйтесь обновлять, когда вы обнаружите проблемы!):

grpcServer := grpc.NewServer()
greetpb.RegisterGreetServiceServer(grpcServer, &server{})

// Your application is probably doing other things and you will want to be
// able to shutdown cleanly; passing in a context is a good method..
ctx, cancel = context.Cancel(context.Background())
defer cancel()   // Ensure cancel function is called eventually

// Start the grpc server on port 50050
grpcTerminated := make(chan struct{})
lis, err := net.Listen("tcp", ":50050")
if err != nil {
    panic(fmt.Sprintf("gRPC - failed to listen: %s", err))
}

go func() {
    if sErr := grpcServer.Serve(lis); sErr != nil {
       fmt.Printf("grpc server shutdown: %s", err)       
    }
    close(grpcTerminated) // In case server is terminated without us requesting this
}()

// Start the grpc-Web server on port 5051
grpcWebTerminated := make(chan struct{})
grpc := grpcweb.WrapServer(grpcServer)
mux := http.NewServeMux()
mux.HandleFunc("/", func(resp http.ResponseWriter, req *http.Request) {
   allowCors(resp, req)
   if grpc.IsGrpcWebRequest(req) || grpc.IsAcceptableGrpcCorsRequest(req) {
      grpc.ServeHTTP(resp, req)
    }
}))
rpcWebServer := &http.Server{
        Handler: mux,
        Addr:    ":50051"}

wg.Add(1)
go func() {
   defer wg.Done()
   if err := rpcWebServer.ListenAndServe(); err != nil {
      fmt.Printf("Web server (GRPC) shutdown: %s", err)
   }
   close(grpcWebTerminated) // In case server is terminated without us requesting this
}()

// Wait for the web server to shutdown OR the context to be cancelled...
select {
   case <-ctx.Done():
      // Shutdown the servers (there are shutdown commands to request this)
   case <-grpcTerminated:
      // You may want to exit if this happens (will be due to unexpected error)
   case <-grpcWebTerminated:
      // You may want to exit if this happens (will be due to unexpected error)
}

// Wait for the goRoutines to complete
<-grpcTerminated:
<-grpcWebTerminated
person Brits    schedule 28.04.2021