एलिगेंट गो सर्वर (ग्रेसफुल रिस्टार्ट)

इस लेख में, मैं Graceful Restart on Go का वर्णन करने जा रहा हूँ। ग्रेसफुल रिस्टार्ट गो वेब एप्लिकेशन के लिए महत्वपूर्ण है। गो में एक कमी है। गो के पास रनटाइम पर कोड पुनः लोड करने का कोई तरीका नहीं है। इसलिए, गो पर डेवलपर्स को एक समस्या का सामना करना पड़ता है जो जावा, .NET या PHP में लिखे गए सर्वरों में नहीं पाया जाता है। यदि आपको गो में लिखे सर्वर कोड को अपडेट करने की आवश्यकता है, तो सर्वर प्रक्रिया को रोकना होगा और एक नई प्रक्रिया शुरू होनी चाहिए। यह कोड को अपडेट करते समय सर्वर की उपलब्धता को कम करता है।

पिछले लेख में, मैंने 200 पंक्तियों में गो पर बाल्कन का वर्णन किया। बैलेंसर के आधार पर, आप एप्लिकेशन अपडेट के दौरान उच्च उपलब्धता सुनिश्चित कर सकते हैं, लेकिन फिर कैसे बैलेंसर को अपडेट करना है। एक बैलेंसर का उपयोग करना अक्सर सिर्फ ज़रूरत से ज़्यादा हो सकता है। यदि आपका सर्वर मैक ओएस एक्स या लिनक्स पर चल रहा है, तो सर्वर कोड को अपडेट करने और सर्वर पुनरारंभ के समय प्राप्त सभी अनुरोधों को संसाधित करने का एक और तरीका है। यह तरीका है ग्रेसफुल रिस्टार्ट।

ग्रेसफुल रिस्टार्ट का सार यह है कि यूनिक्स / लिनक्स सिस्टमों पर, खुली हुई फाइलें और सॉकेट्स स्पैन्ड प्रक्रियाओं के लिए उपलब्ध हैं। पूर्वजों द्वारा खोली गई फ़ाइल या सॉकेट तक पहुंच प्राप्त करने के लिए उनके लिए फ़ाइल डिस्क्रिप्टर (फ़ाइल डिस्क्रिप्टर एक पूर्णांक है) का मूल्य जानना पर्याप्त है।

यहाँ उन मुद्दों की एक सूची है, जिन्हें आपको Graceful Restart on Go को लागू करने के लिए हल करने की आवश्यकता है

1. गो में, सभी खुली फाइलें प्रक्रिया के अंत में स्वचालित रूप से बंद हो जाती हैं (बंद-पर-निष्पादन)
2. पूर्वजन्म में खुले रखने वाले पुराने कनेक्शनों के साथ कुछ करने की जरूरत है

पहली समस्या दो तरीकों से हल होती है। Fnctl का उपयोग करके, आप syscall.FD_CLOEXEC ध्वज, या syscall को साफ़ कर सकते हैं। Dup बिना syscall.FD_CLOEXEC ध्वज के फ़ाइल डिस्क्रिप्टर की एक प्रति बनाएगा। ये कॉल गो के विंडोज कार्यान्वयन में उपलब्ध नहीं हैं, इसलिए यह तकनीक मैक ओएस एक्स और लिनक्स के साथ काम करती है। इस उदाहरण में, मैं syscall.Dup का उपयोग कर रहा हूं। यह पहले दृष्टिकोण की तुलना में सरल है।

मैं 10 सेकंड में कनेक्शन के लिए टाइमआउट सेट करके और ग्रेसफुल रिस्टार्ट के बाद सर्वर 11 सेकंड को बंद करके दूसरी समस्या हल करता हूं। इसके अलावा, दूसरी समस्या को दो अन्य तरीकों से हल किया जा सकता है: ओपन कनेक्शन की संख्या और पूर्वनिर्धारित फंक (सी * कॉन) सर्व () की गणना करने के लिए, रैपर नेट।लिंटर द्वारा, जो गो में काफी मुश्किल है। अन्य व्यवहार वांछनीय हो सकता है। उदाहरण के लिए, ताकि ग्रेसफुल रिस्टार्ट के बाद पुरानी प्रक्रिया एक त्रुटि की रिपोर्ट करे और कनेक्शन बंद कर दे।

यह समझना महत्वपूर्ण है कि ग्रेसफुल रिस्टार्ट के बाद, कुछ वेब ब्राउजर को रखने के कारण पुराने सर्वर से जुड़ जाएंगे। नए कनेक्शन नए सर्वर के साथ स्थापित किए जाएंगे। स्पष्टता के लिए, कौन सा सर्वर किस अनुरोध को संसाधित करता है, मुझे सर्वर से प्रतिक्रिया में प्रक्रिया के पीआईडी ​​को इंगित करना चाहिए।

grace1.go

package main import ( "flag" "fmt" "net" "net/http" "os" "os/exec" "syscall" "time" "log" ) var FD *int = flag.Int("fd", 0, "Server socket FD") var PID int = syscall.Getpid() var listener1 net.Listener var file1 *os.File = nil var exit1 chan int = make(chan int) var stop1 = false func main() { fo1, err := os.Create(fmt.Sprintf("pid-%d.log", PID)) if err != nil { panic(err) } log.SetOutput(fo1) log.Println("Grace1 ", PID) flag.Parse() s := &http.Server{Addr: ":8080", ReadTimeout: 10 * time.Second, WriteTimeout: 10 * time.Second, } http.HandleFunc("/", DefHandler) http.HandleFunc("/stop", StopHandler) http.HandleFunc("/restart", RestartHandler) http.HandleFunc("/grace", GraceHandler) http.HandleFunc("/think", ThinkHandler) if *FD != 0 { log.Println("Starting with FD ", *FD) file1 = os.NewFile(uintptr(*FD), "parent socket") listener1, err = net.FileListener(file1) if err != nil { log.Fatalln("fd listener failed: ", err) } } else { log.Println("Virgin Start") listener1, err = net.Listen("tcp", s.Addr) if err != nil { log.Fatalln("listener failed: ", err) } } err = s.Serve(listener1) log.Println("EXITING", PID) <-exit1 log.Println("EXIT", PID) } func DefHandler(w http.ResponseWriter, req *http.Request) { fmt.Fprintf(w, "def handler %d %s", PID, time.Now().String()) } func ThinkHandler(w http.ResponseWriter, req *http.Request) { time.Sleep(5 * time.Second) fmt.Fprintf(w, "think handler %d %s", PID, time.Now().String()) } func StopHandler(w http.ResponseWriter, req *http.Request) { log.Println("StopHandler", req.Method) if(stop1){ fmt.Fprintf(w, "stopped %d %s", PID, time.Now().String()) } stop1 = true fmt.Fprintf(w, "stop %d %s", PID, time.Now().String()) go func() { listener1.Close() if file1 != nil { file1.Close() } exit1<-1 }() } func RestartHandler(w http.ResponseWriter, req *http.Request) { log.Println("RestartHandler", req.Method) if(stop1){ fmt.Fprintf(w, "stopped %d %s", PID, time.Now().String()) } stop1 = true fmt.Fprintf(w, "restart %d %s", PID, time.Now().String()) go func() { listener1.Close() if file1 != nil { file1.Close() } cmd := exec.Command("./grace1") err := cmd.Start() if err != nil { log.Fatalln("starting error:", err) } exit1<-1 }() } func GraceHandler(w http.ResponseWriter, req *http.Request) { log.Println("GraceHandler", req.Method) if(stop1){ fmt.Fprintf(w, "stopped %d %s", PID, time.Now().String()) } stop1 = true fmt.Fprintf(w, "grace %d %s", PID, time.Now().String()) go func() { defer func() { log.Println("GoodBye") }() listener2 := listener1.(*net.TCPListener) file2, err := listener2.File() if err != nil { log.Fatalln(err) } fd1 := int(file2.Fd()) fd2, err := syscall.Dup(fd1) if err != nil { log.Fatalln("Dup error:", err) } listener1.Close() if file1 != nil { file1.Close() } cmd := exec.Command("./grace1", fmt.Sprint("-fd=", fd2)) err = cmd.Start() if err != nil { log.Fatalln("grace starting error:", err) } log.Println("sleep11", PID) time.Sleep(10 * time.Second) log.Println("exit after sleep", PID) exit1<-1 }() } 

इस कार्यक्रम को बिना चलाए चलाएं ।

 go build grace1.go ./grace1 

अब जब सर्वर चल रहा है, तो हमारे पास निम्नलिखित हैंडलर हैं

http://127.0.0.1:8080/ - डिफ़ॉल्ट हैंडलर
http://127.0.0.1:8080/restart - सामान्य सर्वर पुनरारंभ
http://127.0.0.1:8080/grace - ग्रेसफुल सर्वर रीस्टार्ट
http://127.0.0.1:8080/think - विलंबित हैंडलर

यह सब कैसे काम करता है, यह जांचने के लिए, मैंने गो पर एक और कार्यक्रम लिखा। यह सर्वर से लगातार अनुरोध करता है, यदि कोई त्रुटि नहीं है, तो पत्र जी प्रदर्शित होता है, यदि त्रुटि ई है । प्रत्येक अनुरोध के बाद, कार्यक्रम 10ms पर सो जाता है।

bench1.go

 package main import ( "net/http" "time" ) func main() { nerr := 0 ngood := 0 for i := 0; i < 10000; i++ { resp, err := http.Get("http://127.0.0.1:8080/") if err != nil { // error print("E") nerr++ }else{ print("g") ngood++ resp.Body.Close() } time.Sleep(10 * time.Millisecond) } println() println("Good:", ngood, "Error", nerr) } 

यदि आप लोड के तहत सर्वर को पुनरारंभ करते हैं, तो बेंच 1।गो निम्न चित्र देता है।

 gggggggggggggggggggggggggggggggggggggggggggggggggggggggEEEEEgggggggggggggggggggg gggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggg gggggggggggggggggggggggggggggggggEEggggggggggggggggggggggggggggggggggggggggggggg ggggggggggggggggggggggggggggggggggggggggggggggggEEgggggggggggggggggggggggggggggg ggggggggggggggggggggggggEggggggggggggggggggggggggggggggggggggggggggggggggggggggg gggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggg gggEEggggggggggggggggggEgggggggggggggggggggEggggggggggggggggEEgggggggggggggggggE gggggggggggggggggggggEEgggggggggggggggggEggggggggggggggggggggEggggggggggggggggEE gggggggggggggggggEEgggggggggggggggggEEggggggggggggggggggEgggggggggggggggEEgggggg 

एक या एक से अधिक अक्षर E सर्वर त्रुटि और पुनः आरंभ के दौरान अनुपलब्धता का प्रतीक है। (मैंने सर्वर को कई बार ओवरलोड किया, इसलिए अक्षर ई आम हैं)

अगर ग्रेसफुल रिस्टार्ट का उपयोग करना है तो मैंने त्रुटियों का बिल्कुल भी अवलोकन नहीं किया।