[dummy] Refactor code and identify performance issue
This commit is contained in:
parent
18c178a4a1
commit
c78613fbf7
1 changed files with 51 additions and 7 deletions
|
@ -1,32 +1,76 @@
|
||||||
|
|
||||||
package main
|
package main
|
||||||
|
|
||||||
|
|
||||||
import "runtime"
|
import "runtime"
|
||||||
import "runtime/debug"
|
import "runtime/debug"
|
||||||
|
import "time"
|
||||||
|
|
||||||
import "github.com/valyala/fasthttp"
|
import "github.com/valyala/fasthttp"
|
||||||
import "github.com/valyala/fasthttp/reuseport"
|
import "github.com/valyala/fasthttp/reuseport"
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
func main () () {
|
func main () () {
|
||||||
|
|
||||||
|
|
||||||
runtime.GOMAXPROCS (2)
|
runtime.GOMAXPROCS (2)
|
||||||
|
|
||||||
debug.SetGCPercent (50)
|
debug.SetGCPercent (50)
|
||||||
debug.SetMaxThreads (128)
|
debug.SetMaxThreads (128)
|
||||||
debug.SetMaxStack (16 * 1024)
|
debug.SetMaxStack (16 * 1024)
|
||||||
|
|
||||||
_data := []byte ("hello world!\n")
|
|
||||||
|
|
||||||
_listener, _error := reuseport.Listen ("tcp4", "127.9.185.194:8080")
|
_listener, _error := reuseport.Listen ("tcp4", "127.9.185.194:8080")
|
||||||
|
|
||||||
if _error != nil { panic (_error) }
|
if _error != nil { panic (_error) }
|
||||||
|
|
||||||
_error = fasthttp.Serve (
|
_server := & fasthttp.Server {
|
||||||
_listener,
|
|
||||||
func (_context *fasthttp.RequestCtx) () {
|
Name : "kawipiko",
|
||||||
_context.Response.SetBodyRaw (_data)
|
Handler : serve,
|
||||||
})
|
GetOnly : true,
|
||||||
|
|
||||||
|
NoDefaultServerHeader : true,
|
||||||
|
NoDefaultContentType : true,
|
||||||
|
DisableHeaderNamesNormalizing : true,
|
||||||
|
|
||||||
|
Concurrency : 4 * 1024 + 128,
|
||||||
|
MaxRequestsPerConn : 256 * 1024,
|
||||||
|
|
||||||
|
ReadBufferSize : 16 * 1024,
|
||||||
|
WriteBufferSize : 16 * 1024,
|
||||||
|
MaxRequestBodySize : 16 * 1024,
|
||||||
|
|
||||||
|
// ReadTimeout : 30 * time.Second,
|
||||||
|
// WriteTimeout : 30 * time.Second,
|
||||||
|
// IdleTimeout : 360 * time.Second,
|
||||||
|
|
||||||
|
TCPKeepalive : true,
|
||||||
|
TCPKeepalivePeriod : 60 * time.Second,
|
||||||
|
|
||||||
|
ReduceMemoryUsage : false,
|
||||||
|
KeepHijackedConns : true,
|
||||||
|
|
||||||
|
ErrorHandler : nil,
|
||||||
|
ConnState : nil,
|
||||||
|
HeaderReceived : nil,
|
||||||
|
|
||||||
|
Logger : nil,
|
||||||
|
LogAllErrors : true,
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
_error = _server.Serve (_listener)
|
||||||
if _error != nil { panic (_error) }
|
if _error != nil { panic (_error) }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
func serve (_context *fasthttp.RequestCtx) () {
|
||||||
|
_context.Response.SetBodyRaw (serveData)
|
||||||
|
}
|
||||||
|
|
||||||
|
var serveData = []byte ("hello world!\n")
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue