letgo is an open-source, high-performance web framework for the Go programming language.
my email :474790700@qq.com
oschina: https://gitee.com/WJPone
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"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")
}func main() {
web.Static("/assets/", "./assets")
web.StaticFile("/1.png", "./assets/b3.jpg")
web.Run()
}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()
}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")
}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)
}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"))
}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)
}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
})
}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()
}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()
}1.server config in config/sync_server.config
{"ip":"127.0.0.1","port":"5566"}start server
./main server2.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 fileThe client sends the file to be synchronized to the server, and then the server synchronizes the file to the slave
3.start cmd
./main cmdThe 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)
}
}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()
}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()
}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
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 {
}
}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)
}