| | |
| | | import ( |
| | | "data_msg_push_server/config" |
| | | "data_msg_push_server/service" |
| | | "flag" |
| | | |
| | | "fmt" |
| | | "time" |
| | | ) |
| | | |
| | | var env = flag.String("config", "config", "read storage info") |
| | | |
| | | func init() { |
| | | config.Init(*env) |
| | | config.Init() |
| | | } |
| | | |
| | | func main() { |
| | | fmt.Println("hello!!!") |
| | | done := make(chan bool) |
| | | |
| | | go runEvery(done) |
| | | //result,err := service.GetData() |
| | | //if err != nil { |
| | | // fmt.Println(err) |
| | | //} |
| | | //if result != nil{ |
| | | // |
| | | //} |
| | | <-done |
| | | fmt.Println("程序已退出") |
| | | //fmt.Println(res) |
| | | //fmt.Println(err) |
| | | |
| | | } |
| | | |
| | | func runEvery(done chan<- bool){ |
| | |
| | | connectStatus := service.ConnectControl() |
| | | fmt.Println("connectStatus: ",connectStatus) |
| | | if connectStatus == true { |
| | | url := config.ServUrls.ServerUrl |
| | | url := config.Options.ServerUrl |
| | | result, err1 := service.GetData() |
| | | if err1 != nil { |
| | | fmt.Println(err1) |