gateway/core/node/hellowrold/main.go

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()
}