grpc_async_bidirectional_stream_example
grpc_async_bidirectional_stream_example copied to clipboard
fananchong
grpc async bidirectional stream example
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.46.2 to 1.56.3. Release notes Sourced from google.golang.org/grpc's releases. Release 1.56.3 Security server: prohibit more than MaxConcurrentStreams handlers from running at once (CVE-2023-44487) In addition to this...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.40.0 to 1.56.3. Release notes Sourced from google.golang.org/grpc's releases. Release 1.56.3 Security server: prohibit more than MaxConcurrentStreams handlers from running at once (CVE-2023-44487) In addition to this...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.7.0 to 0.17.0. Commits b225e7c http2: limit maximum handler goroutines to MaxConcurrentStreams 88194ad go.mod: update golang.org/x dependencies 2b60a61 quic: fix several bugs in flow control accounting 73d82ef...
编译不通过
C:\Users\Administrator\Downloads\grpc_async_bidirectional_stream_example-main\out\build\x64-Debug\main.cpp.obj : error LNK2019: 无法解析的外部符号 "private: static class test::MsgEcho * __cdecl google::protobuf::Arena::CreateMaybeMessage(class google::protobuf::Arena *)" (??$CreateMaybeMessage@VMsgEcho@test@@$$V@Arena@protobuf@google@@CAPEAVMsgEcho@test@@PEAV012@@Z)，函数 "protected: static class test::MsgEcho * __cdecl google::protobuf::MessageLite::CreateMaybeMessage(class google::protobuf::Arena *)" (??$CreateMaybeMessage@VMsgEcho@test@@@MessageLite@protobuf@google@@KAPEAVMsgEcho@test@@PEAVArena@12@@Z) 中引用了该符号 C:\Users\Administrator\Downloads\grpc_async_bidirectional_stream_example-main\out\build\x64-Debug\main.cpp.obj : error LNK2019:...
最近测试时，发现，双向流，服务端在流写入结束后，貌似没有写入一个stream.Finish(grpc::Status::OK,）这样的，我用go 客户端接收服务端流信息时，收不到 IO.EOF/ 我调试看，每次都是closestream 然后调用OnExit就结束了。 而且感觉，调用了很多次OnExit. 不知道是哪里用错了，还是，尝试debug，但是里面状态机状态有点多。。 Go grpc客户端 for { //fmt.Println("for.....") res, err := stream.Recv() if err == io.EOF { fmt.Println("server closed") break } if err != nil {...
