[Preview] 当前持续完善中，不可生产中使用 [Preview]

GoFast Micro-Service Framework

GoFast是一个用Go语言实现的微服务开发框架。他的产生源于目前流行的gin、go-zero、fastify等众多开源框架；同时结合了作者多年的开发实践经验，很多模块的实现方式都是作者首创；当然也免不了不断借鉴社区中优秀的设计理念。我们的目标是简洁高效易上手，在封装大量特性的同时又不失灵活性。希望你能喜欢GoFast。

更多了解：GoFast的实现细节

GoFast的微服务：虽然也提供现成的微服务治理能力，但我们想强调的是，GoFast更专注于帮助框架使用者清晰的开发业务逻辑。大型项目上框架应该弱化微服务治理，将这一部分特性交给istio处理。

Installation

To install GoFast package, you need to install Go and set your Go workspace first.

The first need Go installed (version 1.15+ is required), then you can use the below Go command to install GoFast.

1

$ go get -u github.com/qinchende/gofast

Quick start

1
2


# assume the following codes in example.go file
$ cat example.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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96


package main

import (
	"fmt"
	"github.com/qinchende/gofast/fst"
	"github.com/qinchende/gofast/fstx"
	"log"
	"net/http"
	"time"
)

var handler = func(str string) func(c *fst.Context) {
	return func(c *fst.Context) {
		log.Println(str)
	}
}

var handlerRender = func(str string) func(c *fst.Context) {
	return func(c *fst.Context) {
		log.Println(str)
		c.JSON(200, fst.KV{"data": str})
	}
}

func main() {
	app := fst.CreateServer(&fst.AppConfig{
		PrintRouteTrees:        true,
		HandleMethodNotAllowed: true,
		RunMode:                "debug",
		FitMaxReqCount:         1,
		FitMaxReqContentLen:    10 * 1024,
	})

	// 拦截器，微服务治理 ++++++++++++++++++++++++++++++++++++++
	app.RegFits(fstx.AddDefaultFits)
	app.Fit(func(w *fst.GFResponse, r *http.Request) {
		log.Println("app fit before 1")
		w.NextFit(r)
		log.Println("app fit after 1")
	})

	// 根路由
	app.NoRoute(func(ctx *fst.Context) {
		ctx.JSON(http.StatusNotFound, "404-Can't find the path.")
	})
	app.NoMethod(func(ctx *fst.Context) {
		ctx.JSON(http.StatusMethodNotAllowed, "405-Method not allowed.")
	})

	// ++ (用这种方法可以模拟中间件需要上下文变量的场景)
	app.Before(func(ctx *fst.Context) {
		ctx.Set("nowTime", time.Now())
		time.Sleep(3 * time.Second)
	})
	app.After(func(ctx *fst.Context) {
		// 处理后获取消耗时间
		val, exist := ctx.Get("nowTime")
		if exist {
			costTime := time.Since(val.(time.Time)) / time.Millisecond
			fmt.Printf("The request cost %dms", costTime)
		}
	})
	// ++ end

	app.Post("/root", handler("root"))
	app.Before(handler("before root")).After(handler("after root"))

	// 分组路由1
	adm := app.AddGroup("/admin")
	adm.After(handler("after group admin")).Before(handler("before group admin"))

	tst := adm.Get("/chende", handlerRender("handle chende"))
	// 添加路由处理事件
	tst.Before(handler("before tst_url"))
	tst.After(handler("after tst_url"))
	tst.PreSend(handler("preSend tst_url"))
	tst.AfterSend(handler("afterSend tst_url"))

	// 分组路由2
	adm2 := app.AddGroup("/admin2").Before(handler("before admin2"))
	adm2.Get("/zht", handler("zht")).After(handler("after zht"))

	adm22 := adm2.AddGroup("/group2").Before(handler("before group2"))
	adm22.Get("/lmx", handler("lmx")).Before(handler("before lmx"))

	// 应用级事件
	app.OnReady(func(fast *fst.GoFast) {
		log.Println("App OnReady Call.")
		log.Printf("Listening and serving HTTP on %s\n", "127.0.0.1:8099")
	})
	app.OnClose(func(fast *fst.GoFast) {
		log.Println("App OnClose Call.")
	})
	// 开始监听接收请求
	_ = app.Listen("127.0.0.1:8099")
}

1
2


# run example.go and visit website 127.0.0.1:8099 on browser
$ go run example.go

在控制台启动后台Web服务器之后，你会看到底层的路由树构造结果：

[GoFast-debug] POST   /root                     --> main.glob..func1.1 (1 handlers)
[GoFast-debug] GET    /admin/chende             --> main.glob..func2.1 (1 handlers)
[GoFast-debug] GET    /admin2/zht               --> main.glob..func1.1 (1 handlers)
[GoFast-debug] GET    /admin2/group2/lmx        --> main.glob..func1.1 (1 handlers)
++++++++++The route tree:

(GET)
└── /admin                                                       [false-/2]
    ├── /chende                                                  [true-]
    └── 2/                                                       [false-zg]
        ├── zht                                                  [true-]
        └── group2/lmx                                           [true-]
(POST)
└── /root                                                        [true-]

++++++++++THE END.
2021/02/20 02:56:00 App OnReady Call.
2021/02/20 02:56:00 Listening and serving HTTP on 127.0.0.1:8099

浏览器输入网址访问地址：127.0.0.1:8099/admin/chende，日志会输出：

2021/02/20 02:57:17 app fit before 1
2021/02/20 02:57:20 before root
2021/02/20 02:57:20 before group admin
2021/02/20 02:57:20 before tst_url
2021/02/20 02:57:20 handle chende
2021/02/20 02:57:20 preSend tst_url
2021/02/20 02:57:20 afterSend tst_url
2021/02/20 02:57:20 after tst_url
2021/02/20 02:57:20 after group admin
2021/02/20 02:57:20 after root
2021/02/20 02:57:20 app fit after 1
The request cost 3000ms
[GET] /admin/chende (127.0.0.1/02-20 02:57:20) 200/24 [3000]
  B:  C: 
  P: 
  R: 
  E:

Core feature

Like gin feature

GoFast目前复用了Gin的很多特性，除特别说明之外，使用方式一样。

Server Handlers

应用启动之后，在开始监听端口之后调用OnReady事件，应用关闭退出之前调用OnClose事件

1
2
3
4
5
6
7
8
9


app.OnReady(func(fast *fst.GoFast) {
	log.Println("App OnReady Call.")
	log.Printf("Listening and serving HTTP on %s\n", "127.0.0.1:8099")
})

app.OnClose(func(fast *fst.GoFast) {
	log.Println("App OnClose Call.")
})

Router Handlers

分组或路由项事件是一样的，现在支持下面四个，以后慢慢扩展和调整

1
2
3
4


tst.Before(handler("before tst_url"))
tst.After(handler("after tst_url"))
tst.PreSend(handler("preSend tst_url"))
tst.AfterSend(handler("afterSend tst_url"))

benchmark

License

This project is licensed under the terms of the MIT license.

（其它介绍陆续补充…）

系列文章导航

GoFast--README