server.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. package server
  2. import (
  3. "github.com/goflyfox/gtoken/gtoken"
  4. "github.com/gogf/gf/frame/g"
  5. "github.com/gogf/gf/net/ghttp"
  6. "github.com/gogf/gf/os/glog"
  7. )
  8. var TestServerName string
  9. //var TestServerName string = "gtoken"
  10. var server *ghttp.Server
  11. func Start() {
  12. glog.Info("########service start...")
  13. g.Cfg().SetPath("../config")
  14. server = g.Server(TestServerName)
  15. initRouter(server)
  16. glog.Info("########service finish.")
  17. server.Start()
  18. }
  19. func Stop() {
  20. server.Shutdown()
  21. }
  22. var gfToken *gtoken.GfToken
  23. var gfAdminToken *gtoken.GfToken
  24. /*
  25. 统一路由注册
  26. */
  27. func initRouter(s *ghttp.Server) {
  28. // 不认证接口
  29. s.Group("/", func(group *ghttp.RouterGroup) {
  30. group.Middleware(CORS)
  31. // 调试路由
  32. group.ALL("/hello", func(r *ghttp.Request) {
  33. r.Response.WriteJson(gtoken.Succ("hello"))
  34. })
  35. })
  36. // 认证接口
  37. loginFunc := Login
  38. // 启动gtoken
  39. gfToken = &gtoken.GfToken{
  40. ServerName: TestServerName,
  41. LoginPath: "/login",
  42. LoginBeforeFunc: loginFunc,
  43. LogoutPath: "/user/logout",
  44. AuthExcludePaths: g.SliceStr{"/user/info", "/system/user/info"}, // 不拦截路径 /user/info,/system/user/info,/system/user,
  45. MultiLogin: g.Config().GetBool("gToken.MultiLogin"),
  46. }
  47. s.Group("/", func(group *ghttp.RouterGroup) {
  48. group.Middleware(CORS)
  49. gfToken.Middleware(group)
  50. group.ALL("/system/user", func(r *ghttp.Request) {
  51. r.Response.WriteJson(gtoken.Succ("system user"))
  52. })
  53. group.ALL("/user/data", func(r *ghttp.Request) {
  54. r.Response.WriteJson(gfToken.GetTokenData(r))
  55. })
  56. group.ALL("/user/info", func(r *ghttp.Request) {
  57. r.Response.WriteJson(gtoken.Succ("user info"))
  58. })
  59. group.ALL("/system/user/info", func(r *ghttp.Request) {
  60. r.Response.WriteJson(gtoken.Succ("system user info"))
  61. })
  62. })
  63. // 启动gtoken
  64. gfAdminToken = &gtoken.GfToken{
  65. ServerName: TestServerName,
  66. //Timeout: 10 * 1000,
  67. LoginPath: "/login",
  68. LoginBeforeFunc: loginFunc,
  69. LogoutPath: "/user/logout",
  70. AuthExcludePaths: g.SliceStr{"/admin/user/info", "/admin/system/user/info"}, // 不拦截路径 /user/info,/system/user/info,/system/user,
  71. MultiLogin: g.Config().GetBool("gToken.MultiLogin"),
  72. }
  73. s.Group("/admin", func(group *ghttp.RouterGroup) {
  74. group.Middleware(CORS)
  75. gfAdminToken.Middleware(group)
  76. group.ALL("/system/user", func(r *ghttp.Request) {
  77. r.Response.WriteJson(gtoken.Succ("system user"))
  78. })
  79. group.ALL("/user/info", func(r *ghttp.Request) {
  80. r.Response.WriteJson(gtoken.Succ("user info"))
  81. })
  82. group.ALL("/system/user/info", func(r *ghttp.Request) {
  83. r.Response.WriteJson(gtoken.Succ("system user info"))
  84. })
  85. })
  86. }
  87. func Login(r *ghttp.Request) (string, interface{}) {
  88. username := r.GetString("username")
  89. passwd := r.GetString("passwd")
  90. if username == "" || passwd == "" {
  91. r.Response.WriteJson(gtoken.Fail("账号或密码错误."))
  92. r.ExitAll()
  93. }
  94. // 唯一标识,扩展参数user data
  95. return username, "1"
  96. }
  97. // 跨域
  98. func CORS(r *ghttp.Request) {
  99. r.Response.CORSDefault()
  100. r.Middleware.Next()
  101. }