32 lines
731 B
Go
32 lines
731 B
Go
package server
|
|
|
|
import (
|
|
"user-srv/config"
|
|
"user-srv/consul"
|
|
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// 注册grpc服务到consul
|
|
func ConsulGrpc() error {
|
|
// fmt.Println("注册grpc服务到consul", config.ConsulAddress)
|
|
// 初始化consul
|
|
if err := consul.Init(&consul.Config{
|
|
Address: config.ConsulAddress,
|
|
}); err != nil {
|
|
logrus.WithFields(logrus.Fields{
|
|
"func": "ConsulGrpc",
|
|
}).Warnf("consul.Init: %s", err.Error())
|
|
return err
|
|
}
|
|
// 创建gRPC服务器实例
|
|
if err := consul.Register(config.ConsulName, config.GrpcAddress, config.Grpcport, config.ConsulTag); err != nil {
|
|
logrus.WithFields(logrus.Fields{
|
|
"func": "ConsulGrpc",
|
|
}).Warnf("consul.Register: %s", err.Error())
|
|
return err
|
|
}
|
|
return nil
|
|
|
|
}
|