|
|
|
@ -4,12 +4,7 @@ import (
|
|
|
|
|
dciConfig "chain-dci/config"
|
|
|
|
|
"chain-dci/internal/controller"
|
|
|
|
|
_ "chain-dci/internal/handler"
|
|
|
|
|
"chain-dci/pb/dci"
|
|
|
|
|
"chain-dci/pkg/app"
|
|
|
|
|
"fmt"
|
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
|
"net"
|
|
|
|
|
|
|
|
|
|
//common "chain-dci/pkg/init"
|
|
|
|
|
"chain-dci/pkg/tracing"
|
|
|
|
|
"dubbo.apache.org/dubbo-go/v3/config"
|
|
|
|
@ -38,19 +33,18 @@ func main() {
|
|
|
|
|
panic(err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
l, err := net.Listen("tcp", ":8883")
|
|
|
|
|
if err != nil {
|
|
|
|
|
fmt.Printf("failed to listen: %v", err)
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
//l, err := net.Listen("tcp", ":8883")
|
|
|
|
|
//if err != nil {
|
|
|
|
|
// fmt.Printf("failed to listen: %v", err)
|
|
|
|
|
// return
|
|
|
|
|
//}
|
|
|
|
|
|
|
|
|
|
s := grpc.NewServer() // 创建gRPC服务器
|
|
|
|
|
dci.RegisterDciServer(s, &controller.DciProvider{}) // 在gRPC服务端注册服务
|
|
|
|
|
//s := grpc.NewServer() // 创建gRPC服务器
|
|
|
|
|
//dci.RegisterDciServer(s, &controller.DciProvider{}) // 在gRPC服务端注册服务
|
|
|
|
|
// 启动服务
|
|
|
|
|
err = s.Serve(l)
|
|
|
|
|
//err = s.Serve(l)
|
|
|
|
|
//注册服务
|
|
|
|
|
//config.SetProviderService(&controller.DciProvider{})
|
|
|
|
|
//common.Init()
|
|
|
|
|
config.SetProviderService(&controller.DciProvider{})
|
|
|
|
|
if err = config.Load(); err != nil {
|
|
|
|
|
panic(err)
|
|
|
|
|
}
|
|
|
|
|