开箱即用的后台框架
账号：test
密码：Aa123456
https://github.com/PeterYangs/superAdminPage20
redis
mysql
go run main.go编译二进制文件
go build main.go 直接运行
./main 或者 ./main start 后台运行
./main start -d 安全停止
./main stop 运行内置命令
./main artisancontroller
package controller import ( "github.com/PeterYangs/superAdminCore/v2/contextPlus" "github.com/PeterYangs/superAdminCore/v2/response" ) func Index(c *contextPlus.Context) *response.Response { return response.Resp().Api(1, "success", "index") }route
routes/routes.go
func Routes(_r route.Group) { _r.Registered(route.GET, "/index", controller.Index).Bind() _r.Group("/login", func (_login route.Group) { _login.Registered(route.POST, "/login", login.Login, loginLimiter.LoginLimiter).Bind() _login.Registered(route.POST, "/logout", login.Logout).Bind() }) }session
func Session(c *contextPlus.Context) *response.Response { c.Session.Set("key", "value") c.Session.Get("key") return nil }全局中间件
middleware/global.go
package middleware import ( "github.com/PeterYangs/superAdminCore/v2/contextPlus" "github.com/PeterYangs/superAdminCore/v2/middleware/session" "superadmin/middleware/accessLog" ) func Load() []contextPlus.HandlerFunc { return []contextPlus.HandlerFunc{ session.StartSession, accessLog.AccessLog, } }验证码
获取验证码
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, "msg": err.Error()}) } return response.Resp().Json(gin.H{"code": 1, "msg": "hello world"}) }数据库迁移
[root@localhost ~]# ./main artisan Use the arrow keys to navigate: ↓ ↑ → ← ? 选择类型: > 数据库迁移 数据填充 生成key 生成任务类 迁移文件
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").Default(migrate.Null).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}) }消息队列
生成任务类
[root@localhost superAdminApi20]# ./main artisan Use the arrow keys to navigate: ↓ ↑ → ← ? 选择类型: 数据库迁移 数据填充 生成key > 生成任务类任务类
package access import ( "gin-web/database" "gin-web/model" "gin-web/task" ) type TaskAccess struct { task.BaseTask Parameters *Parameter } type Parameter struct { task.Parameter Ip string Url string Params string AdminId float64 } func NewTask(ip string, url string, params string, adminId float64) *TaskAccess { return &TaskAccess{ BaseTask: task.BaseTask{ TaskName: "access", }, Parameters: &Parameter{ Ip: ip, Url: url, Params: params, AdminId: adminId, }, } } func (t *TaskAccess) Run() error { database.GetDb().Create(&model.Access{ Ip: t.Parameters.Ip, Url: t.Parameters.Url, Params: t.Parameters.Params, AdminId: t.Parameters.AdminId, }) return nil } func (t *TaskAccess) BindParameters(p map[string]interface{}) { t.BaseTask.Bind(t.Parameters, p) }即时任务
package controller import ( "gin-web/contextPlus" "gin-web/queue" "gin-web/response" "gin-web/task/email" "gin-web/task/sms" ) func Task(c *contextPlus.Context) *response.Response { queue.Dispatch(email.NewTask("904801074@qq.com", "title", "content")).Queue("low").Run() return response.Resp().Api(1, "123", "") }延迟队列
package controller import ( "gin-web/contextPlus" "gin-web/queue" "gin-web/response" "gin-web/task/email" "gin-web/task/sms" "time" ) func Task(c *contextPlus.Context) *response.Response { queue.Dispatch(email.NewTask("904801074@qq.com", "title", "content")).Queue("low").Delay(100 * time.Second).Run() return response.Resp().Api(1, "123", "") }重试次数
package controller import ( "gin-web/contextPlus" "gin-web/queue" "gin-web/response" "gin-web/task/email" "gin-web/task/sms" ) func Task(c *contextPlus.Context) *response.Response { queue.Dispatch(email.NewTask("904801074@qq.com", "title", "content")).SetTryTime(3).Run() return response.Resp().Api(1, "123", "") }任务调度
crontab/crontabs.go
package crontab import "fmt" func Crontab(c *crontab) { c.newSchedule().everyHour().function(func() { fmt.Println("每小时") }) c.newSchedule().hourlyAt(16).everyMinute().function(func() { fmt.Println("每个16点的每分钟") }) c.newSchedule().minuteAt(18).function(func() { fmt.Println("每小时的第18分钟") }) c.newSchedule().everyMinute().function(func() { //panic("模拟报错") fmt.Println("每分钟") }) c.newSchedule().everyMinuteAt(2).function(func() { fmt.Println("每2分钟") }) c.newSchedule().everyDay().hourlyAt(16).minuteAt(36).function(func() { fmt.Println("每天16点36分") }) c.newSchedule().dayAt(23).hourlyAt(16).minuteAt(50).function(func() { fmt.Println("23号16点50分") }) c.newSchedule().dayAt(24).hourBetween(8, 10).function(func() { fmt.Println("24号8点-10点") }) c.newSchedule().hourBetween(8, 9).everyMinute().function(func() { fmt.Println("每天8点-9点每分钟") }) c.newSchedule().dayBetween(22, 24).everyHour().everyMinute().function(func() { fmt.Println("22号-24号每分钟") }) }命令行
需要实现
type Artisan interface { ArtisanRun() GetName() string }一个例子
package demo import "github.com/PeterYangs/superAdminCore/v2/component/logs" type Demo struct { } func (d Demo) GetName() string { return "demo" } func (d Demo) ArtisanRun() { logs.NewLogs().Debug("demo") }运行
./main artisan缓存
缓存支持两种驱动file和redis，在.env文件中设置CACHE_DRIVER=redis
package test import ( "fmt" "github.com/PeterYangs/superAdminCore/v2/cache" "github.com/PeterYangs/superAdminCore/v2/contextPlus" "github.com/PeterYangs/superAdminCore/v2/response" ) func Cache(c *contextPlus.Context) *response.Response { cache.Cache().Put("nice", "0", 0) fmt.Println(cache.Cache().Get("nice")) return response.Resp().Api(1, "success", "") }管理员登录模式
在.env文件中设置
#登录模式，single(单点登录),multi(多点登录) LOGIN_MODE=single|multi