main.go
@@ -40,7 +40,7 @@ go cache.Init(initchan,*dbIp,*surveyPort,*pubPort) logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕 //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 ruleserver.Init() go ruleserver.TimeTicker() nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) wg.Wait()