tsf

README

TSF-Go基于轻量级 Go 微服务框架Kratos为用户现存的 Go 应用提供了接入TSF（腾讯云微服务治理平台）治理平台的能力。

您也可以通过 SDK文档 查看 TSF GO 最新使用说明。

功能特性

• 自动集成 TSF 平台治理能力：分布式远程配置、远程日志、分布式调用链追踪、监控、服务鉴权、服务路由、全链路灰度发布、API 自动上报。
• 同时支持 gRPC 和 HTTP 协议，并可以和JAVA Spring Cloud 服务互相调用。
• 开放性高，丰富的Middlewares、Options可以自定义组件
• 一切围绕 Protobuf 定义Service、Interface、Error、Validating、Swagger json等
• 拥抱开源规范，Trace，Validate，API Definition等都直接使用开源规范和协议
• 可以支持私有化部署

Quick Start

##安装依赖

1.安装 protoc v3.15.0+

请根据自己使用的操作系统，优先选择对应的包管理工具安装，如：

• linux下用yum或apt等安装
• macOS通过brew安装
• windows通过下载可执行程序或者其他安装程序来安装

2.安装 protoc-gen-xxx

go get -u github.com/golang/protobuf/protoc-gen-go
go get -u google.golang.org/grpc/cmd/protoc-gen-go-grpc
go get -u github.com/go-kratos/kratos/cmd/protoc-gen-go-http

服务端开发

1.通过protobuf定义服务接口

syntax = "proto3";

// 定义protobuf包名pacakage_name
package helloworld;

// 如果不使用restful http协议，可以不引入此proto
import "google/api/annotations.proto";

// 这里go_package指定的是protofbu生成文件xxx.pb.go在git上的地址
option go_package = "github.com/bjxujiang/tsf-go/examples/helloworld/proto";

// 定义服务名service_name
service Greeter {
  // 方法接口名,rpc_method
  rpc SayHello (HelloRequest) returns (HelloReply)  {    
  }
}

//  请求参数
message HelloRequest {
  string name = 1;
}

// 响应参数
message HelloReply {
  string message = 1;
}

如上，这里我们定义了一个Greeter服务，这个服务里面有个SayHello方法，接收一个包含msg字符串的HelloRequest参数，返回HelloReply数据。 这里需要注意以下几点：

• syntax必须是proto3，tsf go都是基于proto3通信的。
• package后面必须有option go_package="github.com/bjxujiang/tsf-go/examples/helloworld/proto";指明你的pb.go生成文件的git存放地址，协议与服务分离，方便其他人直接引用
• 编写protobuf时必须遵循谷歌官方规范。

2.生成服务端桩代码xxx.pb.go代码

通过protoc命令生成服务代码(grpc协议) protoc --proto_path=. --proto_path=./third_party --go_out=paths=source_relative:. --go-grpc_out=paths=source_relative:. *.proto

3.编写service实现层代码

import	pb "github.com/bjxujiang/tsf-go/examples/helloworld/proto"

// server is used to implement helloworld.GreeterServer.
type server struct {
	pb.UnimplementedGreeterServer
}

// SayHello implements helloworld.GreeterServer
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
	return &pb.HelloReply{Message: fmt.Sprintf("Welcome %+v!", in.Name)}, nil
}

4.编写server(grpc协议)启动入口main.go

import  pb "github.com/bjxujiang/tsf-go/examples/helloworld/proto"
import 	tsf "github.com/bjxujiang/tsf-go"
import  "github.com/go-kratos/kratos/v2"
import  "github.com/go-kratos/kratos/v2/transport/grpc"

func main() {
    flag.Parse()
    // grpc协议
    grpcSrv := grpc.NewServer(
        // 定义grpc协议监听地址
        grpc.Address(":9000"),
        grpc.Middleware(
            // 使用tsf默认的middleware
            tsf.ServerMiddleware(),
        ),
    )
    // 将第三步骤中的service实现结构体注入进grpc server中
    s := &server{}
    pb.RegisterGreeterServer(grpcSrv, s)
  
    // 应用配置
    opts := []kratos.Option{
        // 定义注册到服务发现中的服务名
        kratos.Name("provider-grpc"),
        // 添加grpc server至应用运行时
        kratos.Server(grpcSrv),
    }
    // 添加tsf应用默认启动配置
    // 如果不想启用服务注册，可以加入tsf.EnableReigstry(false)该Option
    opts = append(opts, tsf.AppOptions()...)
    app := kratos.New(opts...)
    // 应用阻塞式启动
    if err := app.Run(); err != nil {
        panic(err) 
    }
}

5.服务启动

• 参考腾讯云文档搭建并启动一个本地轻量级consul注册中心；如果暂时不想启动服务注册直接调试，则可以在第4步骤中传入tsf.EnableReigstry(false)即：opts = append(opts, tsf.AppOptions(tsf.EnableReigstry(false))...)
• 执行go run main.go即可启动server

客户端开发（grpc协议）

1.编写客户端代码

import  pb "github.com/bjxujiang/tsf-go/examples/helloworld/proto"
import  tsf "github.com/bjxujiang/tsf-go"
import 	"github.com/go-kratos/kratos/v2/transport/grpc"
import  "import  "github.com/go-kratos/kratos/v2"

func main() {
    flag.Parse()
    // 指定被调方服务连接地址:<scheme>://<authority>/<service_name>
    // 如果使用服务发现，此处scheme固定为discovery，authority留空，service_name为定义注册到服务发现中的服务名
    // 如果不使用服务发现，直接填写"<ip>:<port>"即可
    clientOpts := []grpc.ClientOption{grpc.WithEndpoint("discovery:///provider-grpc")}
    // 如果不使用服务发现，此行可以删除
    clientOpts = append(clientOpts, tsf.ClientGrpcOptions()...)
    conn, err := grpc.DialInsecure(context.Background(), clientOpts...)
    if err != nil {
        panic(err)
    }
    client := pb.NewGreeterClient(conn)
    reply, err := client.SayHello(context.Background(), &pb.HelloRequest{Name: "tsf_grpc"})
    if err != nil {
        panic(err)
    }
}

2.启动客户端

执行go run main.go即可启动client

##部署至腾讯云TSF治理平台

1. 在TSF上创建应用和镜像仓库

参考文档TSF应用管理创建应用并开通镜像仓库

2. 编写 Dockerfile

FROM centos:7

RUN echo "ip_resolve=4" >> /etc/yum.conf
#RUN yum update -y && yum install -y ca-certificates

# 设置时区。这对于日志、调用链等功能能否在 TSF 控制台被检索到非常重要。
RUN /bin/cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
RUN echo "Asia/Shanghai" > /etc/timezone
ENV workdir /app/

COPY provider ${workdir}
WORKDIR ${workdir}

# tsf-consul-template-docker 用于文件配置功能，如不需要可注释掉该行
#ADD tsf-consul-template-docker.tar.gz /root/

# JAVA_OPTS 环境变量的值为部署组的 JVM 启动参数，在运行时 bash 替换。如果加了${JAVA_OPTS},需要在TSF的容器部署组启动参数中删除默认的"-Xms128m xxx"参数,否则会启动失败
#使用 exec 以使 Java 程序可以接收 SIGTERM 信号。
CMD ["sh", "-ec", "exec ${workdir}provider ${JAVA_OPTS}"]

您需要将上述的 provider 替换为实际的可执行二进制文件名。

3. 打包镜像

将 GOOS=linux go build 编译出的二进制文件放在 Dockfile 同一目录下： docker build . -t ccr.ccs.tencentyun.com/tsf_xxx/provider:1.0 注意：镜像地址改成应用上传镜像页面中实际的地址

4. 推送镜像

docker push ccr.ccs.tencentyun.com/tsf_xxx/provider:1.0 注意：镜像地址改成应用上传镜像页面中实际的地址

4. 部署应用

参考文档TSF部署组

更多文档

• HTTP Restful开发
• TSF远程配置
• Swagger API上报
• 错误定义
• 分布式调用链追踪
• 自定义标签
• 负载均衡
• 自适应熔断

Examples

• gRPC
• HTTP
• gin-go
• log
• error
• tracing
• breaker

Documentation

Index

• func AppOptions(opts ...Option) []kratos.Option
• func BreakerMiddleware(opts ...ClientOption) middleware.Middleware
• func ClientGrpcOptions(copts ...ClientOption) []tgrpc.ClientOption
• func ClientHTTPOptions(copts ...ClientOption) []http.ClientOption
• func ClientMiddleware() middleware.Middleware
• func ClientOperation(ctx context.Context) (method string, operation string)
• func ID(optFuncs ...Option) kratos.Option
• func LocalEndpoint(ctx context.Context) (local struct{ ... })
• func Metadata(optFuncs ...Option) (opt kratos.Option)
• func Registrar(optFuncs ...Option) kratos.Option
• func ServerMiddleware(opts ...ServerOption) middleware.Middleware
• func ServerOperation(ctx context.Context) (method string, operation string)
• type ClientOption
  • func WithBalancer(b balancer.Balancer) ClientOption
  • func WithBreakerConfig(cfg *breaker.Config) ClientOption
  • func WithBreakerErrorHook(h func(ctx context.Context, operation string, err error) (success bool)) ClientOption
  • func WithEnableDiscovery(enableDiscovery bool) ClientOption
  • func WithMiddlewares(m ...middleware.Middleware) ClientOption
• type Option
  • func APIMeta(enable bool) Option
  • func EnableReigstry(enable bool) Option
  • func GRPCServer(srv *grpc.Server) Option
  • func Medata(metadata map[string]string) Option
  • func ProtoServiceName(fullname string) Option
• type ServerOption

Functions

func AppOptions

func AppOptions(opts ...Option) []kratos.Option

func BreakerMiddleware

func BreakerMiddleware(opts ...ClientOption) middleware.Middleware

func ClientGrpcOptions

func ClientGrpcOptions(copts ...ClientOption) []tgrpc.ClientOption

func ClientHTTPOptions

func ClientHTTPOptions(copts ...ClientOption) []http.ClientOption

func ClientMiddleware

func ClientMiddleware() middleware.Middleware

ClientMiddleware is client middleware

func ClientOperation

func ClientOperation(ctx context.Context) (method string, operation string)

func ID

func ID(optFuncs ...Option) kratos.Option

func LocalEndpoint

func LocalEndpoint(ctx context.Context) (local struct {
	Service string
	IP      string
	Port    uint16
})

func Metadata

func Metadata(optFuncs ...Option) (opt kratos.Option)

func Registrar

func Registrar(optFuncs ...Option) kratos.Option

func ServerMiddleware

func ServerMiddleware(opts ...ServerOption) middleware.Middleware

ServerMiddleware is a grpc server middleware.

func ServerOperation

func ServerOperation(ctx context.Context) (method string, operation string)

Types

type ClientOption

type ClientOption func(*clientOpionts)

func WithBalancer

func WithBalancer(b balancer.Balancer) ClientOption

func WithBreakerConfig

func WithBreakerConfig(cfg *breaker.Config) ClientOption

func WithBreakerErrorHook

func WithBreakerErrorHook(h func(ctx context.Context, operation string, err error) (success bool)) ClientOption

func WithEnableDiscovery

func WithEnableDiscovery(enableDiscovery bool) ClientOption

func WithMiddlewares

func WithMiddlewares(m ...middleware.Middleware) ClientOption

type Option

type Option func(*appOptions)

Option is HTTP server option.

func APIMeta

func APIMeta(enable bool) Option

func EnableReigstry

func EnableReigstry(enable bool) Option

func GRPCServer

func GRPCServer(srv *grpc.Server) Option

func Medata

func Medata(metadata map[string]string) Option

func ProtoServiceName

func ProtoServiceName(fullname string) Option

ProtoServiceName specific the proto service name(<package_name.service_name>) generated by swagger api

type ServerOption

type ServerOption func(*serverOpionts)