コメントで、人々は何でも空想できると感じています。 おそらく、誰かが私が違反だと考えており、Goにはバランサーが存在しません。 したがって、私はバランサーコードをすぐにレイアウトすることにしました。 このコードは、「特別な状況」で4時間で作成され、「全員」がギリシャにいたため、過負荷なしで2週間ほぼ同じ形式で動作しました。 コードは美しくなく、エラーも含まれていますが、機能し、バランスが取れているため、すでに価値がありました。
カットの下には、ほとんどオリジナルの筆記体バランサーがあります。 元の定数とCookieデコードコードを削除しました。
package main // (c) http://habrahabr.ru/users/pyra/ BSD license import ( // "encoding/json" "fmt" // "io" "io/ioutil" "log" "time" "net/http" "net/url" // "os" // "sort" "strconv" "strings" // "time" "errors" ) func main() { //http.HandleFunc("/r", handle_redir) //http.Handle("/extrahtml/", http.FileServer(http.Dir("./extrahtml/"))) http.HandleFunc("/googleXXXXXXXXXXXX.html", handle_google) http.HandleFunc("/", handle_def) https1 := &http.Server{ Addr: ":8443", Handler: nil, ReadTimeout: 20 * time.Second, WriteTimeout: 20 * time.Second, MaxHeaderBytes: 1 << 15, } go func() { log.Fatal(https1.ListenAndServeTLS("device.crt", "device.key")) }() http1 := &http.Server{ Addr: ":8080", Handler: nil, ReadTimeout: 20 * time.Second, WriteTimeout: 20 * time.Second, MaxHeaderBytes: 1 << 15, } http1.ListenAndServe() } var reqcntr int var opencntr int func redirectPolicyFunc(req *http.Request, via []*http.Request) error { e := errors.New("redirect") return e } func handle_google(w http.ResponseWriter, r *http.Request) { fmt.Println("google") b, _ := ioutil.ReadFile("googleXXXXXXXXXXXXXXXX.html") fmt.Println(len(b)) w.Write(b) } func handle_def(w http.ResponseWriter, r *http.Request) { // opencntr++ defer func() { opencntr-- }() client := &http.Client{ CheckRedirect: redirectPolicyFunc, } ip := strings.Split(r.RemoteAddr, ":")[0] // ( ) reqcntr++ q := r.URL.RawQuery //fmt.Println("def ", r.Method, reqcntr, q) //r.Form, _ = url.ParseQuery(r.URL.RawQuery) //io.WriteString(w, r.URL.Path) path := r.URL.Path // ID var cid int64 // breporting := false // if strings.HasSuffix(path, ".php") { // fmt.Println("breporting = true") breporting = true } // if path == "/ajax/main.php" { path = "/ajax/main_hide1777.php" } cid = -2 if strings.HasPrefix(path, "/ajax/") || strings.HasPrefix(path, "/im/") { // ID m, err := url.ParseQuery(q) if err == nil { id := m.Get("xid") if id == "" { id = m.Get("aid") if id == "" { id = m.Get("cid") if id == "" { id = m.Get("bid") } } } cid, err = strconv.ParseInt(id, 10, 64) if err != nil { cid = -1 } } } else if strings.HasPrefix(path, "/avatar/") { // /avatar/1234.gif // ID - 1234 cid = -1 pos1 := strings.Index(path[8:], ".") if pos1 != -1 { id := path[6 : pos1+6] var err error cid, err = strconv.ParseInt(id, 10, 64) if err != nil { cid = -1 } } } // else // ID //host := "test000.cloud" host := "login.yahoo.com" // if cid > 1000 && cid < 5000 { host = "prod002.cloud" } else if cid >= 5000 && cid < 7000 { host = "prod003.cloud" } else if cid >= 7000 && cid < 15000 { host = "prod005.cloud" } else if cid >= 15000 && cid < 16000 { host = "prod006.cloud" } else if cid >= 25000 && cid < 34000 { host = "prod011.cloud" } url := "" // IP PHP 5.3 FastCGI if breporting { url = "https://" + host + path + "?" + q + "&HEHE_IP="+ip+"&HEHE_SECRET=B87BVf5" }else{ url = "https://" + host + path + "?" + q } fmt.Println(url) // GET if r.Method == "GET" { req1, err := http.NewRequest("GET", url, nil) if err != nil { fmt.Println("Error1: ", err) // } req1.Header = r.Header req1.Header.Add("XHEHE_REMOTE_IP", ip) resp, _ := client.Do(req1) StatusCode := resp.StatusCode defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) if err != nil { fmt.Println("Error2: ", err) // )))) // } fmt.Println("def ", r.Method, reqcntr, opencntr, url, len(body), StatusCode) for k1, v1 := range resp.Header { for _, v2 := range v1 { w.Header().Add(k1, v2) } } w.WriteHeader(StatusCode) w.Write(body) } } // 190
このコードが書き直された後。 以前のパックのアイデアを実装しました。 サーバーへの接続数、統計、レポート、ルーティングテーブルを更新するためのAPIの制御のおかげで、常に機能する管理パネル用の別のポート（これによりユーザーは移行できます）。 そして現在、インスタンスの更新またはユーザーの移行のリクエストに遅延が発生しています。ベータ版には静的キャッシュ、リダイレクトキャッシュもあります。
ユーザー移行とは何ですか。 写真なしのメインユーザープロファイルは10 KB以下です。 サーバーAはユーザーをファイルにシリアル化し、ファイルは圧縮され、ファイルはサーバーBにコピーされます。バランサーは、このユーザーからの要求をサーバーBに送信するように指示されます。
Goとnginxを比較したいと思います。 明らかに、nginxは高速ですが、nginxが1つのコアで300 Mbpsまたは500 Mbpsのバランスをとり、50 Mbpsだけを移動する場合、同じDigitalOceanで5ドルのクラウドサーバー上の典型的な仮想ポートの速度を考慮すると、どのようにお金に変換されるのでしょうか？ Goが1 MBしかバランスできない場合はどうなりますか？ 比較して書く時間はありません。
誰かがベンチマークを作成することに決めた場合、応答サイズが異なるだけでなく、要求が遅延して処理される可能性があることも考慮することが重要です。 したがって、Goはインスタンスのシミュレーションに最適です。 http.NewRequestの代わりに、time.Sleepを配置します。 バランサーよりも1桁多いインスタンスが必要です。
PS Goに精通していない人向け。 Goは、この一見同期的なコードを非同期に変換し、非同期呼び出しを使用して単一のスレッドまたは複数のスレッドで実行できます。 nginxと同じように。 コンパイルにより、Goに依存しない実行ファイルが生成され、Goなしのマシンで実行できます。