お世話になっております。
しゃまとんです。
go言語の軽量フレームワークであるgojiを触っておりまして、ふと大量のリクエストが来た時ってプロセス生成ってどうなっているのだろう・・と思い確認してみました。
とりあえずgojiをgo getして最低限動作する状態にします。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
package main import ( "fmt" "net/http" "github.com/zenazn/goji" "github.com/zenazn/goji/web" ) func hello(c web.C, w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello, %s!", c.URLParams["name"]) } func main() { goji.Get("/hello/:name", hello) goji.Serve() } |
起動して、プロセス数を確認してみます。確認としてabコマンドを利用しました。
|
1 |
$ ab -n 1000 -c 100 http://localhost:8000/hello/shamaton |
同時リクエスト数を100として実行してみると、100を超えていてフルでプロセスが生成されているようです。
|
1 2 |
$ ss -o state established -np | grep "limit" | grep "8000" | wc -l 102 |
これだと状況によってはサーバがダウンしてしまいそうです。どうにかして接続制限数を指定できないかなと思っていたら、すでにパッケージがありました。
netutil.LimitListenerを利用してlistenerを作成し、設定すれば良さそうです。
そこで下記のようにコードを変更しました。最大接続数を15にしてみます。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
package main import ( "fmt" "net/http" "github.com/zenazn/goji" "github.com/zenazn/goji/web" "github.com/zenazn/goji/bind" "golang.org/x/net/netutil" ) func hello(c web.C, w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello, %s!", c.URLParams["name"]) } func main() { goji.Get("/hello/:name", hello) listener := netutil.LimitListener(bind.Default(), 15) goji.ServeListener(listener) } |
これを実行して再度abを実行してみます。
|
1 2 |
$ ss -o state established -np | grep "limit" | grep "8000" | wc -l 15 |
gojiでも接続数を制限することができました。フレームワークによって同じようにサクッとlistenerを設定できないものもあるっぽい・・ですかね。
以上です。
![[golang]標準入力を受け取りつつ、システムコマンド(mysqlなど)を実行する](https://shamaton.orz.hm/blog/wp-content/uploads/2015/11/gopher.jpg)
![[Docker] golangとredisのコンテナを繋いでみた](https://shamaton.orz.hm/blog/wp-content/uploads/2016/10/small_v-dark.png)
