gRPC服务

gRPC服务

Example

HTTP配置

type Config struct {
    Host                       string        // IP地址，默认0.0.0.0
    Port                       int           // Port端口，默认9002
    Deployment                 string        // 部署区域
    Network                    string        // 网络类型，默认tcp4
    EnableMetricInterceptor    bool          // 是否开启监控，默认开启
    EnableTraceInterceptor     bool          // 是否开启链路追踪，默认开启
    SlowLogThreshold           time.Duration // 服务慢日志，默认500ms
    EnableAccessInterceptorReq bool          // 是否开启记录请求参数，默认不开启
    EnableAccessInterceptorRes bool          // 是否开启记录响应参数，默认不开启
    EnableLocalMainIP          bool          // 自动获取ip地址
}

用户配置

[server.grpc]
  host = "127.0.0.1"
  port = 9002

用户代码

配置创建一个 grpc 的配置项，其中内容按照上文配置进行填写。以上这个示例里这个配置key是server.grpc

代码中创建一个 gRPC 服务， egrpc.Load(“”).Build()，代码中的 key 和配置中的 key 要保持一致。创建完 gRPC 服务后，将他添加到 ego new 出来应用的 Serve 方法中，之后使用的方法和 gRPC 就完全一致。

package main
import (
    "context"
    "github.com/gotomicro/ego"
    "github.com/gotomicro/ego/core/elog"
    "github.com/gotomicro/ego/server"
    "github.com/gotomicro/ego/server/egrpc"
    "google.golang.org/grpc/examples/helloworld/helloworld"
)
//  export EGO_DEBUG=true && go run main.go --config=config.toml
func main() {
    if err := ego.New().Serve(func() server.Server {
        server := egrpc.Load("server.grpc").Build()
        helloworld.RegisterGreeterServer(server.Server, &Greeter{})
        return server
    }()).Run(); err != nil {
        elog.Panic("startup", elog.Any("err", err))
    }
}
type Greeter struct {
    server *egrpc.Component
}
func (g Greeter) SayHello(context context.Context, request *helloworld.HelloRequest) (*helloworld.HelloReply, error) {
    return &helloworld.HelloReply{
        Message: "Hello EGO, I'm " + g.server.Address(),
    }, nil
}