README
¶
letgo Web Framework
letgo is an open-source, high-performance web framework for the Go programming language.
my email :474790700@qq.com
oschina: https://gitee.com/WJPone
Contents
Installation
To install letgo package, you need to install Go and set your Go workspace first.
- The first need Go installed (version 1.12+ is required), then you can use the below Go command to install letgo.
$ go get -u github.com/wjp-letgo/letgo
- Import it in your code:
import "github.com/wjp-letgo/letgo"
Quick start
Web
package main
import (
"github.com/wjp-letgo/letgo/web"
"github.com/wjp-letgo/letgo/web/context"
"github.com/wjp-letgo/letgo/web/filter"
"fmt"
)
func main() {
web.AddFilter("/user/*",filter.BEFORE_ROUTER,func(ctx *context.Context){
ctx.Output.JSON(200,lib.InRow{
"www":"fff",
})
})
web.LoadHTMLGlob("templates/*")
web.Get("/", func(ctx *context.Context){
//ctx.Output.Redirect(301,"http://www.baidu.com")
x:=ctx.Input.Param("a")
if x!=nil{
ctx.Session.Set("a",x.Int())
var a int
ctx.Session.Get("a",&a)
fmt.Println("a:",a,"x:",x.Int())
}
ctx.Output.HTML(200,"index.tmpl",lib.InRow{
"title":"wjp",
})
})
web.Post("/user/:id([0-9]+)", func(ctx *context.Context){
type A struct{
Data string `json:"data"`
ShopID int64 `json:"shop_id"`
}
a:=A{}
ctx.SetCookie("a", "234234")
ctx.Input.BindJSON(&a)
fmt.Println(a)
ctx.Output.YAML(500,lib.InRow{
"message":"123123",
"b":2,
})
})
web.Get("/user/:id([0-9]+)/:id3([0-9]+)", func(ctx *context.Context){
ctx.Output.XML(200,lib.InRow{
"message":"123123",
"b":2,
})
})
web.Run()//listen and serve on 0.0.0.0:1122 (for windows "localhost:1122")
}
Serving static files
func main() {
web.Static("/assets/", "./assets")
web.StaticFile("/1.png", "./assets/b3.jpg")
web.Run()
}
Register controller
type UserController struct{}
func (c *UserController)Add(ctx *context.Context){
ctx.Output.Redirect(302,"/")
}
func main() {
c:=&UserController{}
web.RegisterController(c)
c2:=&UserController{}
web.RegisterController(c2,"get:add")
web.Run()
}
Enable current limiting algorithm
package main
import (
"github.com/wjp-letgo/letgo/web"
"github.com/wjp-letgo/letgo/web/context"
"github.com/wjp-letgo/letgo/web/filter"
"github.com/wjp-letgo/letgo/web/limiting"
"fmt"
)
func main() {
EnableLimiting(limiting.LIMIT_FLOW_TOKEN_BUCKET, 0.02)
web.AddFilter("/user/*",filter.BEFORE_ROUTER,func(ctx *context.Context){
ctx.Output.JSON(200,lib.InRow{
"www":"fff",
})
})
web.LoadHTMLGlob("templates/*")
web.Get("/", func(ctx *context.Context){
//ctx.Output.Redirect(301,"http://www.baidu.com")
x:=ctx.Input.Param("a")
if x!=nil{
ctx.Session.Set("a",x.Int())
var a int
ctx.Session.Get("a",&a)
fmt.Println("a:",a,"x:",x.Int())
}
ctx.Output.HTML(200,"index.tmpl",lib.InRow{
"title":"wjp",
})
})
web.Post("/user/:id([0-9]+)", func(ctx *context.Context){
type A struct{
Data string `json:"data"`
ShopID int64 `json:"shop_id"`
}
a:=A{}
ctx.SetCookie("a", "234234")
ctx.Input.BindJSON(&a)
fmt.Println(a)
ctx.Output.YAML(500,lib.InRow{
"message":"123123",
"b":2,
})
})
web.Get("/user/:id([0-9]+)/:id3([0-9]+)", func(ctx *context.Context){
ctx.Output.XML(200,lib.InRow{
"message":"123123",
"b":2,
})
})
web.Run()//listen and serve on 0.0.0.0:1122 (for windows "localhost:1122")
}
Captcha
package main
import (
"github.com/wjp-letgo/letgo/web/captcha"
"image/color"
"github.com/wjp-letgo/letgo/file"
"fmt"
)
func main(){
c:=captcha.NewCaptcha()
c.AddFonts("STHUPO.TTF")
c.AddColors(color.RGBA{255,0,255,255},color.RGBA{0,255,255,255},color.Black)
c.SetSize(200,60)
//c.AddBackColors(color.Black,color.Opaque)
//c.Create(4,NUM)
//c.Create(4,LCHAR)
//c.SetDisturbLevel(HIGH)
c.SetDisturbLevel(captcha.MEDIUM)
img1,code1:=c.Create(4,captcha.ALL)
//img1.DrawLine(10,0,100,20,color.RGBA{255,0,255,255})
img1.SaveImage("1.png")
img2,code2:=c.Create(4,captcha.ALL)
file.PutContent("2",img2.Base64Encode())
img2.SaveImage("2.png")
fmt.Println(code1,code2)
}
Model operation
package main
import "github.com/wjp-letgo/letgo/db/mysql"
func main() {
model:=mysql.NewModel("dbname","tablename")
m:=model.Fields("*").
Alias("m").
Join("sys_shopee_shop as s").
On("m.`id`","s.`master_id`").
OrOn("s.master_id",1).
AndOnRaw("m.id=1 or m.id=2").
LeftJoin("sys_lazada_shop as l").
On("m.`id`", "l.`master_id`").
WhereRaw("m.id=1").
AndWhere("m.id",2).
OrWhereIn("m.id",ids).
GroupBy("m.id").
Having("m.id",1).
AndHaving("m.id",1).
OrderBy("m.id desc").Find()
fmt.Println(model.GetLastSql())
fmt.Println(m["master_id"].Int64(),m["name"],m["age"].Int(),m["password"].String())
//show all tables in database
db:=mysql.Connect("connectName", "databaseName")
fmt.Println("tables:",db.ShowTables())
//Judge whether the table exists
fmt.Println("tables:",db.IsExist("tableName"))
//Displays field names and properties
//db2:=mysql.Connect("connectName", "databaseName")
fmt.Println("fieldInformation:",db.Desc("tableName"))
}
Mongo db operation
package main
import (
"github.com/wjp-letgo/letgo/db/mongo"
)
func main() {
type Student struct {
Name string `json:"name"`
Age int `json:"age"`
}
entity:=Student{"wjp", 1}
tb:=mongo.NewModel("databaseName","collectionName")
tb.InsertOne(entity)
}
Dynamic data source
package main
import (
"github.com/wjp-letgo/letgo/db/mysql"
"github.com/wjp-letgo/letgo/lib"
"github.com/wjp-letgo/letgo/db/mongo"
"go.mongodb.org/mongo-driver/bson"
)
func main() {
model:=mysql.NewModel("db2","tablename")
m:=model.Fields("*").
Alias("m").
Join("sys_shopee_shop as s").
On("m.`id`","s.`master_id`").
OrOn("s.master_id",1).
AndOnRaw("m.id=1 or m.id=2").
LeftJoin("sys_lazada_shop as l").
On("m.`id`", "l.`master_id`").
WhereRaw("m.id=1").
AndWhere("m.id",2).
OrWhereIn("m.id",ids).
GroupBy("m.id").
Having("m.id",1).
AndHaving("m.id",1).
OrderBy("m.id desc").Find()
fmt.Println(model.GetLastSql())
}
func init(){
mysql.InjectCreatePool(func(db *mysql.DB)[]mysql.MysqlConnect{
var otherConnects []mysql.MysqlConnect
model:=mysql.NewModelByConnectName("connectName", "databaseName", "database_config")
list:= model.Get()
for _,v:=range list{
otherConnect:=mysql.MysqlConnect{
Master:mysql.SlaveDB{
Name:"db2",
DatabaseName:"db2",
UserName:"userName",
Password:"password",
Host:"127.0.0.1",
Port:"3306",
Charset:"utf8mb4",
MaxOpenConns:20,
MaxIdleConns:10,
},
Slave:make([]mysql.SlaveDB, 1),
}
otherConnects=append(otherConnects, otherConnect)
}
return otherConnects
})
mongo.InjectCreatePool(func(db *mysql.DB)[]mongo.MongoConnect{
var otherConnects []mongo.MongoConnect
var r []bson.D
mongo.NewModelByConnectName("connectName", "databaseName", "database_config").Find(nil, &r)
for _,v:=range r{
otherConnect:=mongo.MongoConnect{
Name:"connectName",
Database:"databaseName",
UserName:"userName",
Password:"password",
Hosts:[]Host{
Host{
Hst:"127.0.0.1",
Port:"27017",
},
},
ConnectTimeout: 10,
ExecuteTimeout: 10,
}
otherConnects=append(otherConnects, otherConnect)
}
return otherConnects
})
}
RPC
import "github.com/wjp-letgo/letgo/net/rpc"
func main(){
s:=rpc.NewServer()
//s.RegisterName("Hello",new(Hello))
s.Register(new(Hello))
go func(){
for{
time.Sleep(10*time.Second)
var reply string
//rpc.NewClient().WithAddress("127.0.0.1","8080").Call("Hello.Say","nihao",&reply).Close()
rpc.NewClient().Start().Call("Hello.Say","nihao",&reply).Close()
fmt.Println(reply)
rm:=rpc.RpcMessage{
Method: "Hello.Say",
Args: "rpc message",
Callback: func(a interface{}){
fmt.Println(a.(string))
},
}
rpc.NewClient().Start().CallByMessage(rm).Close()
}
}()
s.Run()
}
Command
import "github.com/wjp-letgo/letgo/command/command"
func main(){
cmd:=command.New().Cd("D:\\Development\\go\\web\\src").SetCMD("dir")
//cmd.AddPipe(New().SetCMD("find","'\\c'","'80'"))
cmd.Run()
}
Synchronize files
1.server config in config/sync_server.config
{"ip":"127.0.0.1","port":"5566"}
start server
./main server
2.client config in config/sync_client.config
{
"paths":[
{
"locationPath":"D:/Development/go/web/src/sync-v2", //Local directory to be synchronized
"remotePath":"/root/new/buyer2", //Directory stored on the server
"filter":[ //Filter out files that are not synchronized to the server
"main.go",
"runtime/cache/sync/*"
]
}
],
"server":{
"ip":"127.0.0.1", //Server IP
"port":"5566",
"slave":[
{
"ip":"127.0.0.2", //For other servers, it is recommended to be in the same LAN as the server
"port":"5566"
}
]
}
}
start file
./main file
The client sends the file to be synchronized to the server, and then the server synchronizes the file to the slave
3.start cmd
./main cmd
The client sends the console command to the server, and at the same time, it also sends it to the slave, and the concurrent execution interface returns
4.go code
package main
import (
"github.com/wjp-letgo/letgo/plugin"
"github.com/wjp-letgo/letgo/plugin/sync/syncconfig"
"fmt"
"os"
)
func main() {
args:=os.Args
if len(args)>1{
if args[1]=="server"{
plugin.Plugin("sync-server").Run()
} else if args[1]=="file"{
plugin.Plugin("sync-file").Run()
} else if args[1]=="cmd"{
rs:=plugin.Plugin("sync-cmd").Run("/www/","ls -al")
result:=rs.(map[string]syncconfig.CmdResult)
fmt.Println(result)
}
}
Task
Creating memory resident applications When the stop method is called, all tasks will wait for execution and exit
package main
import (
"github.com/wjp-letgo/letgo/cron/task"
"time"
"fmt"
)
func main() {
task.RegisterTask("add",1,func(ctx *Context){
fmt.Println(ctx.Name,ctx.TaskNo)
//fmt.Println()
//time.Sleep(1*time.Second)
})
go func(){
time.Sleep(15*time.Second)
task.Stop()
}()
//task.Start()
task.StartAndWait()
}
Crontab
Creating Crontab
package main
import (
"github.com/wjp-letgo/letgo/cron/context"
"github.com/wjp-letgo/letgo/lib"
"fmt"
"time"
)
func main() {
AddCron("cron1","*/6 * * * * *",func(ctx *context.Context){
fmt.Println("cron1", lib.Now())
})
AddCron("cron2","*/3 * * * * *",func(ctx *context.Context){
fmt.Println("cron2", lib.Now())
})
go func(){
time.Sleep(10*time.Second)
Stop()
}()
StartAndWait()
}
Automatic generation model
package main
import (
"github.com/wjp-letgo/letgo/db/mysql"
)
func main() {
//自动生成数据的所有表的model和entity源码
mysql.GenModelAndEntity("module name",
SlaveDB{
Name:"name",
DatabaseName:"name",
UserName:"user",
Password:"password",
Host:"127.0.0.1",
Port:"3306",
Charset:"utf8mb4",
Prefix: "cd",
},false)
//自动生成单张表的model和entity源码
mysql.GenModelAndEntityByTableName("module name","table name",
SlaveDB{
Name:"name",
DatabaseName:"name",
UserName:"user",
Password:"password",
Host:"127.0.0.1",
Port:"3306",
Charset:"utf8mb4",
Prefix: "cd",
},false)
}
After execution, the model source code will be generated in the current directory model / and the entity source code will be generated in the directory model / entity
Automatic generation router and notes
package main
import (
"github.com/wjp-letgo/letgo/dcode"
)
func main() {
dcode.DcodeRouter("router/router.go","./controller")
}
Before execution
func (c *AccountController) Signin(ctx *context.Context) {
userName := ctx.Input.Param("userName", "").String()
password := ctx.Input.Param("password", 0).Int64()
if userName != "" && password != 0 {
} else {
}
}
After execution
// @Title Signin 接口说明
// @Description: 描述信息
// @router /account/signin [get]
// @Param userName body String "参数说明"
// @Param password body Int64 0 "参数说明"
// @Success 200 {object}
// @Failure 400 Invalid
func (c *AccountController) Signin(ctx *context.Context) {
userName := ctx.Input.Param("userName", "").String()
password := ctx.Input.Param("password", 0).Int64()
if userName != "" && password != 0 {
} else {
}
}
Automatic generation json tag
By using //@json or //@Json
package main
import (
"github.com/wjp-letgo/letgo/dcode"
)
func main() {
dcode.DcodeJson("json/")
}
Before execution
//@json
type N struct {
SName string
JxName int
X int64
}
//@json
type X struct {
SName string
JxName int
X int64
}
After execution
//@json
type N struct {
SName string `json:"s_name"`
JxName int `json:"jx_name"`
X int64 `json:"x"`
}
//@json
type X struct {
SName string `json:"s_name"`
JxName int `json:"jx_name"`
X int64 `json:"x"`
}
func (n *N) String() string {
return lib.ObjectToString(n)
}
func (x *X) String() string {
return lib.ObjectToString(x)
}
Documentation
¶
There is no documentation for this package.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.