37 lines
758 B
Go
37 lines
758 B
Go
package db
|
|
|
|
import (
|
|
"errors"
|
|
"net"
|
|
|
|
"google.golang.org/grpc"
|
|
"mongo.games.com/goserver/core/logger"
|
|
)
|
|
|
|
var GrpcServer *grpc.Server
|
|
var GrpcClientConn *grpc.ClientConn
|
|
|
|
func RunGrpcServer() {
|
|
GrpcServer = grpc.NewServer()
|
|
registerGrpcServer()
|
|
ln, err := net.Listen("tcp", ":8899")
|
|
if err != nil {
|
|
panic(errors.New("db grpc failed to listen: " + err.Error()))
|
|
}
|
|
|
|
err = GrpcServer.Serve(ln)
|
|
if err != nil {
|
|
panic(errors.New("db grpc failed to serve: " + err.Error()))
|
|
}
|
|
logger.Logger.Infof("db grpc start success")
|
|
}
|
|
|
|
func NewGrpcClientConn() {
|
|
var err error
|
|
GrpcClientConn, err = grpc.NewClient("localhost:8899", grpc.WithInsecure())
|
|
if err != nil {
|
|
panic(errors.New("db grpc failed to dial: " + err.Error()))
|
|
}
|
|
registerGrpcClient()
|
|
}
|