gRPC 的增删改查系列之启动服务

1.路径src\server\server.go
2.启动服务:

package server

import (
    "context"
    v1 "goWebGin/api/proto/v1"
    "google.golang.org/grpc"
    "log"
    "net"
    "os"
)

func RunServer(ctx context.Context, v1Api v1.ToDoServiceServer, port string) error {
    listen, err := net.Listen("tcp", ":"+port)
    if err != nil {
        return err
    }
    server := grpc.NewServer()
    v1.RegisterToDoServiceServer(server, v1Api)
    c := make(chan os.Signal, 1)
    go func() {
        for range c {
            log.Println("shutting down gRPC server..")
            server.GracefulStop()
            <-ctx.Done()
            return
        }
    }()
    log.Println("starting gRPC server...")
    return server.Serve(listen)
}
本作品采用《CC 协议》,转载必须注明作者和本文链接
一切皆自学
讨论数量: 0
(= ̄ω ̄=)··· 暂无内容!

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!