为什么fasthttp像单进程?
why is fasthttp like single process?
requestHandler := func(ctx *fasthttp.RequestCtx) {
time.Sleep(time.Second*time.Duration(10))
fmt.Fprintf(ctx, "Hello, world! Requested path is %q", ctx.Path())
}
s := &fasthttp.Server{
Handler: requestHandler
}
if err := s.ListenAndServe("127.0.0.1:82"); err != nil {
log.Fatalf("error in ListenAndServe: %s", err)
}
多次请求,耗时X*10秒。
fasthttp 是单进程?
两天后...
对于这个问题,我很抱歉,我描述我的问题不是 well.My 问题是由浏览器引起的,浏览器通过同步请求相同的 url,它误导了我,它让我认为 fasthttp 网络服务器 hanlde同步请求。
我认为不是 fasthttp 是单进程?,你问的是 fasthttp 是否同时处理客户端请求?
我很确定任何服务器(包括 fasthttp)包都将同时处理客户端请求。你应该写一个 test/benchmark 而不是通过 几个 浏览器手动访问服务器。以下是此类测试代码的示例:
package main_test
import (
"io/ioutil"
"net/http"
"sync"
"testing"
"time"
)
func doRequest(uri string) error {
resp, err := http.Get(uri)
if err != nil {
return err
}
defer resp.Body.Close()
_, err = ioutil.ReadAll(resp.Body)
if err != nil {
return err
}
return nil
}
func TestGet(t *testing.T) {
N := 1000
wg := sync.WaitGroup{}
wg.Add(N)
start := time.Now()
for i := 0; i < N; i++ {
go func() {
if err := doRequest("http://127.0.0.1:82"); err != nil {
t.Error(err)
}
wg.Done()
}()
}
wg.Wait()
t.Logf("Total duration for %d concurrent request(s) is %v", N, time.Since(start))
}
结果(在我的电脑中)是
fasthttp_test.go:42: Total duration for 1000 concurrent request(s) is 10.6066411s
可以看到你的问题的答案是不是,它是并发处理请求的。
更新:
如果请求的 URL 相同,您的浏览器可能会按顺序执行请求。参见 Multiple Ajax requests for same URL。这解释了为什么响应时间是 X*10s
。
这个问题我很抱歉,我描述的不是我的问题 well.My 问题是由浏览器引起的,浏览器请求相同 url 通过同步,它误导了我,它让我觉得fasthttp 网络服务器通过同步处理请求。
requestHandler := func(ctx *fasthttp.RequestCtx) {
time.Sleep(time.Second*time.Duration(10))
fmt.Fprintf(ctx, "Hello, world! Requested path is %q", ctx.Path())
}
s := &fasthttp.Server{
Handler: requestHandler
}
if err := s.ListenAndServe("127.0.0.1:82"); err != nil {
log.Fatalf("error in ListenAndServe: %s", err)
}
多次请求,耗时X*10秒。 fasthttp 是单进程?
两天后... 对于这个问题,我很抱歉,我描述我的问题不是 well.My 问题是由浏览器引起的,浏览器通过同步请求相同的 url,它误导了我,它让我认为 fasthttp 网络服务器 hanlde同步请求。
我认为不是 fasthttp 是单进程?,你问的是 fasthttp 是否同时处理客户端请求?
我很确定任何服务器(包括 fasthttp)包都将同时处理客户端请求。你应该写一个 test/benchmark 而不是通过 几个 浏览器手动访问服务器。以下是此类测试代码的示例:
package main_test
import (
"io/ioutil"
"net/http"
"sync"
"testing"
"time"
)
func doRequest(uri string) error {
resp, err := http.Get(uri)
if err != nil {
return err
}
defer resp.Body.Close()
_, err = ioutil.ReadAll(resp.Body)
if err != nil {
return err
}
return nil
}
func TestGet(t *testing.T) {
N := 1000
wg := sync.WaitGroup{}
wg.Add(N)
start := time.Now()
for i := 0; i < N; i++ {
go func() {
if err := doRequest("http://127.0.0.1:82"); err != nil {
t.Error(err)
}
wg.Done()
}()
}
wg.Wait()
t.Logf("Total duration for %d concurrent request(s) is %v", N, time.Since(start))
}
结果(在我的电脑中)是
fasthttp_test.go:42: Total duration for 1000 concurrent request(s) is 10.6066411s
可以看到你的问题的答案是不是,它是并发处理请求的。
更新:
如果请求的 URL 相同,您的浏览器可能会按顺序执行请求。参见 Multiple Ajax requests for same URL。这解释了为什么响应时间是 X*10s
。
这个问题我很抱歉,我描述的不是我的问题 well.My 问题是由浏览器引起的,浏览器请求相同 url 通过同步,它误导了我,它让我觉得fasthttp 网络服务器通过同步处理请求。