# GO111MODULE on模式
GO111MODULE="on"
GOARCH="amd64"
GOBIN=""
GOCACHE="/home/lizheng/.cache/go-build"
GOENV="/home/lizheng/.config/go/env"
GOEXE=""
GOEXPERIMENT=""
GOFLAGS=""
GOHOSTARCH="amd64"
GOHOSTOS="linux"
GOINSECURE=""
GOMODCACHE="/home/lizheng/gopath/pkg/mod"
GONOPROXY=""
GONOSUMDB=""
GOOS="linux"
# GOPATH 配置
GOPATH="/home/lizheng/gopath"
GOPRIVATE=""
# GOPROXY 配置
GOPROXY="https://goproxy.cn"
# GOROOT 配置
GOROOT="/home/lizheng/go"
GOSUMDB="sum.golang.org"
GOTMPDIR=""
GOTOOLDIR="/home/lizheng/go/pkg/tool/linux_amd64"
GOVCS=""
GOVERSION="go1.17.7"
GCCGO="gccgo"
AR="ar"
CC="gcc"
CXX="g++"
CGO_ENABLED="1"
GOMOD="/dev/null"
CGO_CFLAGS="-g -O2"
CGO_CPPFLAGS=""
CGO_CXXFLAGS="-g -O2"
CGO_FFLAGS="-g -O2"
CGO_LDFLAGS="-g -O2"
PKG_CONFIG="pkg-config"
GOGCCFLAGS="-fPIC -m64 -pthread -fmessage-length=0 -fdebug-prefix-map=/tmp/go-build1495300227=/tmp/go-build -gno-record-gcc-switches"

lizheng@lz-x:~$  apt install -y protobuf-compiler
lizheng@lz-x:~$ protoc --version
libprotoc 3.6.1

lizheng@lz-x:~$ go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.28
lizheng@lz-x:~$ go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.2

// 使用的語法協(xié)議版本 proto3
syntax = "proto3";
package proto;
// 定義生成go文件的package位置和名稱
option go_package = "./;proto";
// 定義Greeter服務
service Greeter {
    // 定義SayHello方法，接受HelloRequest消息， 并返回HelloReply消息
    rpc SayHello (HelloRequest) returns (HelloReply) {}
}
// 定義請求對象
message HelloRequest {
    string name = 1;
}
// 定義返回對象
message HelloReply {
    string message = 1;
}

# \ 為命令換行但不執(zhí)行，可以寫一行那就不需要 \ 了
protoc --go_out=. --go_opt=paths=source_relative \
    --go-grpc_out=. --go-grpc_opt=paths=source_relative \
    helloworld.proto

package main
import (
	"context"
	"flag"
	"fmt"
	"log"
	"net"
	"time"
	h "example.com/ggrpc/handler"
	pb "example.com/ggrpc/proto"
	"google.golang.org/grpc"
)
var (
	port = flag.Int("port", 8000, "The server port")
)
// 定義一個server實現(xiàn)UnimplementedGreeterServer
// UnimplementedGreeterServer 是第四步自動生成的，可以打開對應文件查看
type server struct {
	pb.UnimplementedGreeterServer
}
// server 重寫SayHello方法，做業(yè)務處理
func (s *server) SayHello(c context.Context, req *pb.HelloRequest) (*pb.HelloReply, error) {
	log.Printf("接收到客戶端的消息: %v", req.GetName())
	time.Sleep(time.Second)
	ms := fmt.Sprintf("好的收到,%s %s", req.GetName(), time.Now())
	log.Printf("回復客戶端的消息: %s", ms)
	return &pb.HelloReply{Message: ms}, nil
}
func main() {
	// 解析命令行參數(shù)
	flag.Parse()
	// 監(jiān)聽本地tcp端口
	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", *port))
	if err != nil {
		log.Fatalf("failed to listen: %v", err)
	}
	// 創(chuàng)建一個grpc Server服務對象,Handler非必傳
	// s := grpc.NewServer() // 可以直接創(chuàng)建對象
	s := grpc.NewServer(grpc.StatsHandler(&h.MyHandler{}))
	// 注冊服務
	pb.RegisterGreeterServer(s, &server{})
	// 啟動RPC并監(jiān)聽
	log.Printf("server listening at %v", lis.Addr())
	if err := s.Serve(lis); err != nil {
		log.Fatalf("failed to serve: %v", err)
	}
}

package main
import (
	"context"
	"flag"
	"log"
	"time"
	pb "example.com/ggrpc/proto"
	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"
)
var serAddr = flag.String("addr", "localhost:8000", "the address to connect to")
func main() {
	// 解析命令行參數(shù)
	flag.Parse()
	// 連接服務端
	conn, err := grpc.Dial(*serAddr, grpc.WithTransportCredentials(insecure.NewCredentials()))
	if err != nil {
		log.Fatalf("連接服務器失敗: %v", err)
	}
	log.Printf("建立連接成功: %s", *serAddr)
	// 執(zhí)行完方法自動關閉資源
	defer conn.Close()
	// 創(chuàng)建客戶端
	c := pb.NewGreeterClient(conn)
	log.Println("5秒中之后調(diào)用SayHello方法")
	time.Sleep(time.Second * 5)
	// 創(chuàng)建2秒超時ctx
	ctx, cancel := context.WithTimeout(context.Background(), time.Second*2)
	defer cancel()
	// 發(fā)起RPC請求
	log.Println("開始調(diào)用SayHello方法")
	res, err := c.SayHello(ctx, &pb.HelloRequest{Name: "一號"})
	if err != nil {
		log.Fatalf("請求失敗: %v", err)
	}
	log.Printf("請求結(jié)果: %s", res.GetMessage())
	// 睡眠一會再結(jié)束
	log.Println("3秒后結(jié)束，客戶端自動斷開連接")
	time.Sleep(time.Second * 3)
}

package handler
import (
	"context"
	"log"
	"google.golang.org/grpc/stats"
)
// 自定義handler實現(xiàn)stats.Handler打印一些信息
type MyHandler struct {
}
func (h *MyHandler) TagRPC(c context.Context, tag *stats.RPCTagInfo) context.Context {
	log.Printf("TagRPC: %v", tag)
	return c
}
func (h *MyHandler) HandleRPC(c context.Context, s stats.RPCStats) {
	log.Printf("HandleRPC: %v", s)
}
func (h *MyHandler) TagConn(c context.Context, tag *stats.ConnTagInfo) context.Context {
	log.Printf("TagConn: %v", tag)
	return c
}
func (h *MyHandler) HandleConn(c context.Context, s stats.ConnStats) {
	log.Printf("HandleConn: %v", s)
}