letgo Web Framework

letgo is an open-source, high-performance web framework for the Go programming language.

my email :[email protected]

oschina: https://gitee.com/WJPone

letgo Web Framework
- Installation
- Quick start

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/wjpxxx/letgo

Import it in your code:

import "github.com/wjpxxx/letgo"

Quick start

Web

package mainimport (    "github.com/wjpxxx/letgo/web"    "github.com/wjpxxx/letgo/web/context"	"github.com/wjpxxx/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 mainimport (    "github.com/wjpxxx/letgo/web"    "github.com/wjpxxx/letgo/web/context"	"github.com/wjpxxx/letgo/web/filter"	"github.com/wjpxxx/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 mainimport (	"github.com/wjpxxx/letgo/web/captcha"	"image/color"	"github.com/wjpxxx/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 mainimport "github.com/wjpxxx/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 mainimport (	"github.com/wjpxxx/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 mainimport (	"github.com/wjpxxx/letgo/db/mysql"	"github.com/wjpxxx/letgo/lib"	"github.com/wjpxxx/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/wjpxxx/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/wjpxxx/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 mainimport (	"github.com/wjpxxx/letgo/plugin"	"github.com/wjpxxx/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)		}