问题描述
我正在尝试使用 grpc-web 包装器的 hep 创建一个 grpc 服务器。这个想法是将这个 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
有人帮助将不胜感激。谢谢！
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）