疑问写前面
- grpc有内部对心跳的处理吗，还是说，双工需要自己作心跳管理，有懂的留言一下。
SEO优化
grpc如何双工通信?
grpc如何从服务端推送消息给客户端?
gprc环境如何搭建?
grpc生成go文件的命令是?
grpc牛比.
grpc stream 服务端如何Close?
简介
gprc的详细描述不多介绍
这里仅与http作横向对比,集中体现在如下差异:
- 传输协议: grpc为tcp(http2)，http为http1，http2，使用者感知度不大，不作介绍.
- 序列化协议: grpc为protobuf，http为json,xml等,json居多，前者为二进制协议，后者为文本协议，所以grpc序列化的速度和大小远优于http，但对普通的业务，性能感知差异不大。
- 服务路由: grpc根据预先在proto文件里声明好的服务方法，客户端可以对生成的客户端代码直接调用这些声明好的服务方法，而http则是根据url地址与method协同，来路由到正确的服务方法.
- 服务调用: grpc直接面向ip与端口，http面向域名，即一般是限定在80(http)和443(https)
选择
选择http还是grpc，这个可以根据简介里的差异来分析。
- 面向外部用户与否。grpc直接面向ip和端口，所以肯定不方便拿给外部用，选http最佳,但这不是绝对的，毕竟socket本身也是面向ip和端口的，需要tcp的场景也没有谁会刻意转http.
- 需不需要苛求带宽与速度 。grpc因为他的序列化protobuf优势，小而快，苛求带宽和速度刻意选用grpc.
- 长连接与否。如果只再grpc和http里选择，选grpc，当然可以，面向长连接我更推荐原生socket(tcp，ws)之类的
go示例
示例repo:
https://github.com/fwhezfwhez/TestX/tree/master/test_grpc 依赖:
protoc:https://github.com/golang/protobuf protoc-gen-go:https://github.com/golang/protobuf/tree/master/protoc-gen-go
需要在path下，找到 protoc和protoc-gen-go命令，执行protoc --version输出版本号即安装正常.
proto文件生成go命令:
protoc --go_out=plugins=grpc:. hello.proto
hello.proto
syntax = "proto3";
package pb;
message HelloRequest {
string username = 1;
}
message HelloResponse {
string message = 1;
}
service HelloService {
rpc SayHello(HelloRequest) returns (HelloResponse){}
}
client
package main
import (
"context"
"fmt"
"google.golang.org/grpc"
"test_X/test_grpc/pb"
)
func main() {
conn, err := grpc.Dial("localhost:6001", grpc.WithInsecure())
if err != nil {
fmt.Println(err.Error())
return
}
defer conn.Close()
c := pb.NewHelloServiceClient(conn)
r, err := c.SayHello(context.Background(), &pb.HelloRequest{Username: "ft"})
if err != nil {
fmt.Println(err.Error())
return
}
fmt.Println(r.Message)
}
server
package main
import (
"context"
"fmt"
"google.golang.org/grpc"
"net"
"test_X/test_grpc/pb"
)
type HelloService struct {
}
func (hs HelloService) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloResponse, error) {
return &pb.HelloResponse{Message: fmt.Sprintf("你好，%s", in.Username)}, nil
}
func main() {
lis, err := net.Listen("tcp", ":6001")
if err != nil {
fmt.Println(err.Error())
return
}
s := grpc.NewServer()
pb.RegisterHelloServiceServer(s, HelloService{})
s.Serve(lis)
}
拓展
1. grpc如何双工，服务端推送
在上述代码里直接拓展:
第一步，增加proto接口描述并重新生成go文件:
protoc --go_out=plugins=grpc:. hello.proto
// How to generate hello.proto to go file:
// protoc --go_out=plugins=grpc:. hello.proto
syntax = "proto3";
package pb;
message HelloRequest {
string username = 1;
}
message HelloResponse {
string message = 1;
}
// +
message ClientStream {
bytes stream = 1;
}
message ServerStream {
bytes stream = 1;
}
service HelloService {
rpc SayHello(HelloRequest) returns (HelloResponse){}
rpc Chat(stream ClientStream) returns (stream ServerStream){}
}
// +
第二步，增加服务端实现Chat的方法实例
server
package main
import (
"context"
"fmt"
"google.golang.org/grpc"
"io"
"net"
"test_X/test_grpc/pb"
)
type HelloService struct {
}
func (hs *HelloService) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) {
return &pb.HelloResponse{Message: fmt.Sprintf("你好，%s", req.Username)}, nil
}
// ++++++++++++++++++++++++++++++++
func (hs *HelloService) Chat(conn pb.HelloService_ChatServer)error {
for {
stream, err:=conn.Recv()
if err == io.EOF {
return nil
}
if err != nil {
return err
}
fmt.Println("receive from client:",stream.Stream)
conn.Send(&pb.ServerStream{
Stream: newBytes(1,2,3,4,5),
})
}
return nil
}
// ++++++++++++++++++++
func main() {
lis, err := net.Listen("tcp", ":6001")
if err != nil {
fmt.Println(err.Error())
return
}
s := grpc.NewServer()
pb.RegisterHelloServiceServer(s, &HelloService{})
go func() {
s.Serve(lis)
}()
fmt.Println(s.GetServiceInfo())
select {}
}
func newBytes(a ...byte)[]byte{
return a
}
第三步，客户端调用
client
package main
import (
"context"
"errorX"
"fmt"
"google.golang.org/grpc"
"io"
"test_X/test_grpc/pb"
"time"
)
func main() {
conn, e := grpc.Dial("localhost:6001", grpc.WithInsecure())
if e != nil {
fmt.Println(e.Error())
return
}
defer conn.Close()
c := pb.NewHelloServiceClient(conn)
// say hello
r, e := c.SayHello(context.Background(), &pb.HelloRequest{Username: "ft"})
if e != nil {
fmt.Println(e.Error())
return
}
fmt.Println(r.Message)
// ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
// chat
chatClilent, e :=c.Chat(context.Background())
if e != nil {
fmt.Println(e.Error())
return
}
go func(){
for{
stream, e:=chatClilent.Recv()
if e == io.EOF {
fmt.Println("EOF")
return
}
if e != nil {
fmt.Println(errorx.Wrap(e).Error())
return
}
fmt.Println("receive from server:", stream.Stream)
}
}()
chatClilent.Send(&pb.ClientStream{
Stream: newBytes(10,9,8,7),
})
select{
case <-time.After(20 * time.Second):
}
}
func newBytes(a ...byte)[]byte{
return a
}
// ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
结束:
cd servergo run main.gocd clientgo run main.go
receive from client: [10 9 8 7]
你好，ft
receive from server: [1 2 3 4 5]
服务端如何Close
rpc面向每个连接，即服务端chat函数return即Close连接
func (hs *HelloService) Chat(conn pb.HelloService_ChatServer)error {
for {
stream, err:=conn.Recv()
if err == io.EOF {
fmt.Println("EOF")
return nil
}
if err != nil {
return err
}
fmt.Println("receive from client:",stream.Stream)
conn.Send(&pb.ServerStream{
Stream: newBytes(1,2,3,4,5),
})
// 关闭连接
// return nil
}
return nil
}