Base/main.go

package main

import (
	"fmt"
	"log"
	"net"
	"sportfitness/base/api/grpc"
	pb "sportfitness/base/api/grpc/base"
	"sportfitness/base/assembly/base"

	"git.beswell.com/gframe/application"
	"github.com/ZR233/glog/v2"
	"github.com/sirupsen/logrus"
)

func main() {
	glog.Init("sportfitness", "base")
	glog.Init("sportfitness", "heartRate")
	app := application.NewDefault()

	err := app.LogUseKafka()
	if err != nil {
		panic(err)
	}

	err = app.AddServiceGrpcClient("bsw/im")
	if err != nil {
		panic(err)
	}

	//基础库初始化
	base.Init()

	grpcServer := app.GRPCServer()

	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", 19090))
	if err != nil {
		logrus.Fatalf("failed to listen: %s", err)
	}
	pb.RegisterApiServer(grpcServer, &grpc.Api{})

	logrus.Infof("listen :%d", 19090)
	err = grpcServer.Serve(lis)
	if err != nil {
		log.Fatal(err)
	}
}