package main import ( "fmt" "gateway/core/node" "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/net/ghttp" "github.com/gogf/gf/v2/os/gproc" "os" "os/signal" "syscall" "time" ) func main111() { //node.NewNode().Register("usermodule", "8888", "http://127.0.0.1") var serverCode string = "gatewayDemo" var serverPort int = 8099 closeNotify, err := node.NewNode().Register(serverCode, fmt.Sprintf("%d", serverPort)) if err != nil { panic(err) } go func() { server := g.Server() server.SetPort(serverPort) server.BindHandler("/gatewayDemo/{page}", func(r *ghttp.Request) { //r.Response.Header().Set("deductNum", "6") //r.Response.Header().Set("ids", strings.Join(getIdArr(20000), ",")) r.Response.Write(map[string]interface{}{ "code": 1, "func": r.Get("page"), "param": map[string]interface{}{ "name": r.Get("name").String(), "age": r.Get("age").Int64(), "eId": r.Get("entId").Int64(), "uId": r.Get("userId").String(), }, }) }) server.Run() }() quit := make(chan os.Signal, 1) signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) <-quit closeNotify() } func main() { s := g.Server() gc := ghttp.NewConfig() gc.Graceful = true gc.GracefulTimeout = 20 s.SetConfig(gc) s.BindHandler("/", func(r *ghttp.Request) { r.Response.Writeln("哈喽!") }) s.BindHandler("/pid", func(r *ghttp.Request) { r.Response.Writeln(gproc.Pid()) }) s.BindHandler("/sleep", func(r *ghttp.Request) { r.Response.Writeln(gproc.Pid()) time.Sleep(10 * time.Second) r.Response.Writeln(gproc.Pid()) }) s.EnableAdmin("/jyGateway/admin/api") s.SetPort(8199) s.Run() }