main.go 1.3 KB

1234567891011121314151617181920212223242526272829303132333435
  1. package main
  2. import (
  3. "cicv-data-closedloop/common/config/c_log"
  4. "cicv-data-closedloop/common/handler/h_validate_request_header"
  5. "cicv-data-closedloop/common/util"
  6. "cicv-data-closedloop/tools/plugin-compile/package/config"
  7. "cicv-data-closedloop/tools/plugin-compile/package/handler"
  8. "net/http"
  9. "os"
  10. )
  11. func main() {
  12. {
  13. args := os.Args
  14. config.InitApplication(args[1])
  15. c_log.InitLog(config.ApplicationYaml.LogDir, config.ApplicationYaml.ServiceName)
  16. config.InitOss(false)
  17. config.InitOss2(false)
  18. config.InitOss3(false)
  19. }
  20. go func() {
  21. mux := http.NewServeMux()
  22. mux.Handle("/compile", h_validate_request_header.HeaderValidationMiddleware(&handler.CompileHandler{}))
  23. mux.Handle("/pji_compile", h_validate_request_header.HeaderValidationMiddleware(&handler.PjiCompileHandler{}))
  24. mux.Handle("/jili_compile", h_validate_request_header.HeaderValidationMiddleware(&handler.JiliCompileHandler{}))
  25. err := http.ListenAndServe(":"+util.ToString(config.ApplicationYaml.ServicePort), mux) // 这里是阻塞并监听HTTP端口
  26. if err != nil {
  27. c_log.GlobalLogger.Error("程序崩溃监听端口 " + util.ToString(config.ApplicationYaml.ServicePort) + " 失败。")
  28. os.Exit(-1)
  29. }
  30. }()
  31. c_log.GlobalLogger.Infof("启动编译服务成功,监听端口【%v】!", config.ApplicationYaml.ServicePort)
  32. select {}
  33. }