基于gin封装的mc框架
redis
controller
package controller
import (
"gin-web/contextPlus"
"github.com/gin-gonic/gin"
"gin-web/response"
)
// Index 主页
func Index(c *contextPlus.Context) *response.Response {
return response.Resp().Json(gin.H{"data": "hello world"})
}route
route/web.go
package routes
import (
"gin-web/controller"
"gin-web/controller/file"
"gin-web/controller/regex"
"gin-web/kernel"
"gin-web/middleware"
"github.com/gin-gonic/gin"
)
func _init(_r group) {
//路由组，支持嵌套
_r.Group("/api", func(g group) {
g.Registered(GET, "/", controller.Index).Bind()
g.Registered(GET, "/gg", controller.Index).Bind()
g.Group("/login", func(g2 group) {
g2.Registered(GET, "/", controller.Index).Bind()
})
}, middleware.GoOn)
//单路由
_r.Registered(GET, "/", controller.Index).Bind()
_r.Registered(GET, "/check", controller.CheckCaptcha).Bind()
}session
func Session(c *contextPlus.Context) *response.Response {
c.Session.Set("key", "value")
c.Session.Get("key")
return nil
}验证码
获取验证码
func Captcha(c *contextPlus.Context) *response.Response {
b := c.GetCaptcha()
c.Header("content-type", "image/png")
return response.Resp().Byte(b)
}检查验证码
func CheckCaptcha(c *contextPlus.Context) *response.Response {
code := c.Query("code")
bool:= c.CheckCaptcha(code)
return response.Resp().Json(gin.H{"bool":code})
}参数验证
package regex
import (
"gin-web/contextPlus"
"github.com/gin-gonic/gin"
)
// Regex 参数规则验证示例，路由为 /regex/:name ,请求为 /regex/1sds?test[]=1&test[]=2,regex标记只支持string和[]string两个类型
func Regex(c *contextPlus.Context) *response.Response {
type regex struct {
Test []string `form:"test[]" json:"test" regex:"[0-9a-z/]+"`
Name string `uri:"name" json:"name" regex:"[0-9a-z]+"`
}
var t regex
err := c.ShouldBindPlus(&t)
if err != nil {
return response.Resp().Json(gin.H{"code": 2, "mgs": err.Error()})
}
return response.Resp().Json(gin.H{"code": 1, "msg": "hello world"})
}数据库迁移
[root@localhost ~]# go run migrate/bin/run.go
Use the arrow keys to navigate: ↓ ↑ → ←
? 选择类型:
> 创建数据库迁移
执行迁移
回滚迁移
迁移文件
package migrate_2019_08_12_055619_create_admin_table
import "gin-web/migrate"
func Up() {
migrate.Create("admin", func(createMigrate *migrate.Migrate) {
createMigrate.Name = "migrate_2019_08_12_055619_create_admin_table"
//主键
createMigrate.BigIncrements("id")
//int
createMigrate.Integer("user_id").Unsigned().Nullable().Default(0).Unique().Comment("用户id")
//varchar
createMigrate.String("title", 255).Default("").Comment("标题")
//text
createMigrate.Text("content").Comment("内容")
//索引
createMigrate.Unique("user_id", "title")
})
}
func Down() {
migrate.DropIfExists("admin")
}限流器
package loginLimiter
import (
"gin-web/component/limiter"
"gin-web/contextPlus"
"golang.org/x/time/rate"
"time"
)
func LoginLimiter(c *contextPlus.Context) {
//每秒生成一个令牌，桶的大小是10,第三个参数是自定义key，根据自定义的key寻找限流器（默认是每1分钟清理一次过期的限流器）
if !limiter.NewLimiter(rate.Every(1*time.Second), 10, c.ClientIP()).Allow() {
c.String(500, "访问频率过高")
c.Abort()
}
}分布式锁
非阻塞
func Index(c *contextPlus.Context) *response.Response {
//申请一个锁，过期时间是10秒
lock := redis.GetClient().Lock("lock", 10*time.Second)
//释放锁
defer lock.Release()
//是否拿到锁
if lock.Get() {
return response.Resp().Json(gin.H{"res": true})
}
return response.Resp().Json(gin.H{"res": false})
}阻塞
func Index(c *contextPlus.Context) *response.Response {
//申请一个锁，过期时间是10秒
lock := redis.GetClient().Lock("lock", 10*time.Second)
defer lock.Release()
//是否拿到锁
if lock.Block(time.Second * 3) {
time.Sleep(4 * time.Second)
return response.Resp().Json(gin.H{"res": true})
}
return response.Resp().Json(gin.H{"res": false})
}