package main import ( "flag" "go_dreamfactory/modules/robot" "go_dreamfactory/services" "go_dreamfactory/lego" "go_dreamfactory/lego/base/rpcx" "go_dreamfactory/lego/core" ) /* 服务类型:mainte 服务描述:数据库维护以及GM后台接口 服务 */ var ( conf = flag.String("conf", "./conf/robot.yaml", "获取需要启动的服务配置文件") //启动服务的Id ) /*服务启动的入口函数*/ func main() { flag.Parse() s := NewService( rpcx.SetConfPath(*conf), rpcx.SetVersion("1.0.0.0"), ) s.OnInstallComp( //装备组件 //services.NewGateRouteComp(), //此服务需要接受用户的消息 需要装备网关组件 ) lego.Run(s, robot.NewModule()) //运行模块 } func NewService(ops ...rpcx.Option) core.IService { s := new(Service) s.Configure(ops...) return s } // worker 的服务对象定义 type Service struct { services.ServiceBase } // 初始化worker需要的一些系统工具 func (this *Service) InitSys() { this.ServiceBase.InitSys() }