http.go 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. package http
  2. import (
  3. "net/http"
  4. "go-common/app/job/main/aegis/conf"
  5. "go-common/app/job/main/aegis/service"
  6. "go-common/library/log"
  7. bm "go-common/library/net/http/blademaster"
  8. "go-common/library/net/http/blademaster/middleware/verify"
  9. )
  10. var (
  11. srv *service.Service
  12. vfy *verify.Verify
  13. )
  14. // Init init
  15. func Init(s *service.Service, c *conf.Config) {
  16. srv = s
  17. vfy = verify.New(c.Verify)
  18. engine := bm.DefaultServer(c.BM)
  19. route(engine)
  20. if err := engine.Start(); err != nil {
  21. log.Error("bm Start error(%v)", err)
  22. panic(err)
  23. }
  24. }
  25. func route(e *bm.Engine) {
  26. e.Ping(ping)
  27. e.Register(register)
  28. g := e.Group("/x/aegis")
  29. {
  30. g.GET("/start", vfy.Verify, howToStart)
  31. g.GET("/debug/cache", debugCache)
  32. }
  33. }
  34. func ping(c *bm.Context) {
  35. if err := srv.Ping(c); err != nil {
  36. log.Error("ping error(%v)", err)
  37. c.AbortWithStatus(http.StatusServiceUnavailable)
  38. }
  39. }
  40. func register(c *bm.Context) {
  41. c.JSON(map[string]interface{}{}, nil)
  42. }
  43. // example for http request handler
  44. func howToStart(c *bm.Context) {
  45. c.String(0, "Golang 大法好 !!!")
  46. }