-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathrouter.go
79 lines (69 loc) · 2.4 KB
/
router.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package poleweb
import "net/http"
const ANY = "ANY"
type router struct {
routerGroups []*routerGroup
engine *Engine
}
func (r *router) Group(name string) *routerGroup {
routerGroup := &routerGroup{
name: name,
handleFuncMap: make(map[string]map[string]HandlerFunc),
middlewaresFuncMap: make(map[string]map[string][]MiddlewareFunc),
handlerMethodMap: make(map[string][]string),
treeNode: &treeNode{name: "/", children: make([]*treeNode, 0)},
}
routerGroup.Use(r.engine.middles...)
r.routerGroups = append(r.routerGroups, routerGroup)
return routerGroup
}
type routerGroup struct {
name string
handleFuncMap map[string]map[string]HandlerFunc
middlewaresFuncMap map[string]map[string][]MiddlewareFunc
handlerMethodMap map[string][]string
treeNode *treeNode
middlewares []MiddlewareFunc
}
func (r *routerGroup) handle(name string, method string, handlerFunc HandlerFunc, middlewareFunc ...MiddlewareFunc) {
_, ok := r.handleFuncMap[name]
if !ok {
r.handleFuncMap[name] = make(map[string]HandlerFunc)
r.middlewaresFuncMap[name] = make(map[string][]MiddlewareFunc)
}
_, ok = r.handleFuncMap[name][method]
if ok {
panic("有重复的路由")
}
r.handleFuncMap[name][method] = handlerFunc
r.middlewaresFuncMap[name][method] = append(r.middlewaresFuncMap[name][method], middlewareFunc...)
r.treeNode.Put(name)
}
func (r *routerGroup) Any(name string, handlerFunc HandlerFunc, middlewareFunc ...MiddlewareFunc) {
r.handle(name, ANY, handlerFunc, middlewareFunc...)
}
func (r *routerGroup) Get(name string, handlerFunc HandlerFunc, middlewareFunc ...MiddlewareFunc) {
r.handle(name, http.MethodGet, handlerFunc, middlewareFunc...)
}
func (r *routerGroup) Post(name string, handlerFunc HandlerFunc, middlewareFunc ...MiddlewareFunc) {
r.handle(name, http.MethodPost, handlerFunc, middlewareFunc...)
}
func (r *routerGroup) Use(middlewareFunc ...MiddlewareFunc) {
r.middlewares = append(r.middlewares, middlewareFunc...)
}
func (r *routerGroup) methodHandle(name string, method string, h HandlerFunc, ctx *Context) {
// 组通用中间件
if r.middlewares != nil {
for _, middlewareFunc := range r.middlewares {
h = middlewareFunc(h)
}
}
// 组路由级别
middlewareFuncs := r.middlewaresFuncMap[name][method]
if middlewareFuncs != nil {
for _, middlewareFunc := range middlewareFuncs {
h = middlewareFunc(h)
}
}
h(ctx)
}