👎🏿 🧥 🤽🏻 MTProto प्रॉक्सी आँकड़े संग्रह ㊗️ 🌃 ⏩

सामग्री

प्रागितिहास
सांख्यिकी संग्रह
आंकड़े प्रदर्शित करते हैं
दृश्य और आँकड़े
स्कैन
निष्कर्ष

प्रागितिहास

हाय हब्र, टेलीग्राम अब लोकप्रियता के चरम पर हैं, सभी घोटालों, साज़िशों, ताले उसके चारों ओर घूमते हैं, जिसके सिलसिले में टेलीग्राम ने MTProto Proxy नामक प्रॉक्सी के अपने स्वयं के संस्करण को रोल किया, जिसे लॉक को बायपास करने में मदद करने के लिए डिज़ाइन किया गया है। हालांकि, टेलीग्राम MTProto प्रॉक्सी द्वारा प्रदान की जाने वाली निगरानी सेवाएं वास्तविक समय में आंकड़ों का अवलोकन करने और उन्हें अपने परिवर्तनों की निगरानी करने के लिए इकट्ठा करने की अनुमति नहीं देती हैं, इसलिए हम अपने दम पर समस्या का समाधान करेंगे।

सांख्यिकी संग्रह

डॉकर हब पर आधिकारिक MTProto प्रॉक्सी पेज में कहा गया है कि हम कंटेनर में मौजूद MTProto प्रॉक्सी से सीधे docker exec mtproto-proxy curl http://localhost:2398/stats प्राप्त करने के लिए docker exec mtproto-proxy curl http://localhost:2398/stats का उपयोग कर सकते हैं, इसलिए हमारा कोड इस तरह दिखेगा।

 package main import ( "io/ioutil" "net/http" "strings" "time" ) type User struct { Num string } var Users User func CurrenUsers() (err error) { //   response, err := http.Get(`http://localhost:2398/stats`) if err != nil { return } body, err := ioutil.ReadAll(response.Body) if err != nil { return } defer response.Body.Close() stat := strings.Split(string(body), "\n") for _, item := range stat { //        //     if strings.HasPrefix(item, `total_special_connections`) { Users.Num = strings.Split(item, "\t")[1] } } return nil } func main() { for t := time.Tick(10 * time.Second); ; <-t { if err := CurrenUsers(); err != nil { continue } } }

total_special_connections आने वाले क्लाइंट कनेक्शन की संख्या के समान total_special_connections हब पर इंगित किया गया है

आंकड़े प्रदर्शित करते हैं

अगला, हमें उपयोगकर्ताओं की वर्तमान संख्या को सरल और सुविधाजनक रूप में प्रदर्शित करने की आवश्यकता है, हम इसे ब्राउज़र में आउटपुट करेंगे।

 package main import ( "html/template" "io/ioutil" "net/http" "strings" "time" ) type User struct { Num string } type HTML struct { IndexPage string } var Users User var IndexTemplate = HTML{ IndexPage: `<!DOCTYPE html> <html> <head> <link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.1.0/css/bootstrap.min.css" integrity="sha384-9gVQ4dYFwwWSjIDZnLEWnxCjeSWFphJiwGPXr1jddIhOegiu1FwO5qRGvFXOdJZ4" crossorigin="anonymous"> <title>Stats</title> <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no"> </head> <body> <div class="container-fluid"> <div class="row justify-content-center text-center" style="margin-top: 20%"> <h1>Count of current users of MTProto Proxy: {{.Num}}</h1> </div> </div> </body> </html>`, } func CurrenUsers() (err error) { //   response, err := http.Get(`http://localhost:2398/stats`) if err != nil { return } body, err := ioutil.ReadAll(response.Body) if err != nil { return } defer response.Body.Close() stat := strings.Split(string(body), "\n") for _, item := range stat { //        //     if strings.HasPrefix(item, `total_special_connections`) { Users.Num = strings.Split(item, "\t")[1] } } return nil } func sendStat(w http.ResponseWriter, r *http.Request) { if r.Method == "GET" { t := template.Must(template.New("indexpage").Parse(IndexTemplate.IndexPage)) t.Execute(w, Users) } } func init() { go func() { for t := time.Tick(10 * time.Second); ; <-t { if err := CurrenUsers(); err != nil { continue } } }() } func main() { http.HandleFunc("/", sendStat) http.ListenAndServe(":80", nil) }

init क्या है

मुख्य कॉल करने से पहले किसी भी स्थिति में इनिट को बुलाया जाएगा

अब, हमारे MTProto प्रॉक्सी के IP पते पर जाकर, हम ग्राहकों की वर्तमान संख्या देख सकते हैं।

दृश्य और आँकड़े

डेटाडॉग , ज़ैबिक्स , ग्राफाना , ग्रेफाइट के आंकड़ों को देखने और बनाए रखने के लिए कई विकल्प हैं। मैं दातादोग का उपयोग करूंगा। कमांड go get -u github.com/DataDog/datadog-go/statsd statsd go get -u github.com/DataDog/datadog-go/statsd का उपयोग करके go get -u github.com/DataDog/datadog-go/statsd statsd लाइब्रेरी को आयात करते हैं और कोड में इसका उपयोग करते हैं।

 package main import ( "html/template" "io/ioutil" "net/http" "os" "strconv" "strings" "time" "github.com/DataDog/datadog-go/statsd" ) var ( datadogIP = os.Getenv("DDGIP") tagName = os.Getenv("TGN") t, _ = strconv.Atoi(os.Getenv("TIMEOUT")) timeout = time.Duration(t) * time.Second ) type User struct { Num string } type HTML struct { IndexPage string } var Users User var IndexTemplate = HTML{ IndexPage: `<!DOCTYPE html> <html> <head> <link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.1.0/css/bootstrap.min.css" integrity="sha384-9gVQ4dYFwwWSjIDZnLEWnxCjeSWFphJiwGPXr1jddIhOegiu1FwO5qRGvFXOdJZ4" crossorigin="anonymous"> <title>Stats</title> <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no"> </head> <body> <div class="container-fluid"> <div class="row justify-content-center text-center" style="margin-top: 20%"> <h1>Count of current users of MTProto Proxy: {{.Num}}</h1> </div> </div> </body> </html>`, } func (u User) convert() int64 { num, _ := strconv.Atoi(u.Num) return int64(num) } func CurrenUsers() (err error) { //   response, err := http.Get(`http://localhost:2398/stats`) if err != nil { return } body, err := ioutil.ReadAll(response.Body) if err != nil { return } defer response.Body.Close() stat := strings.Split(string(body), "\n") for _, item := range stat { //        //     if strings.HasPrefix(item, `total_special_connections`) { Users.Num = strings.Split(item, "\t")[1] } } return nil } func sendStat(w http.ResponseWriter, r *http.Request) { if r.Method == "GET" { t := template.Must(template.New("indexpage").Parse(IndexTemplate.IndexPage)) t.Execute(w, Users) } } func init() { if t == 0 { timeout = 10 * time.Second } go func() { for t := time.Tick(timeout); ; <-t { if err := CurrenUsers(); err != nil { continue } } }() //    Datadog go func() error { c, err := statsd.New(datadogIP + ":8125") if err != nil || len(datadogIP) == 0 { return err } c.Namespace = "mtproto." c.Tags = append(c.Tags, tagName) for t := time.Tick(timeout); ; <-t { c.Count("users.count", Users.convert(), nil, 1) } }() } func main() { http.HandleFunc("/", sendStat) http.ListenAndServe(":80", nil) }

यह एक डॉकटर छवि में सब कुछ एकत्र करने के लिए रहता है

 FROM telegrammessenger/proxy COPY mtproto_proxy_stat . RUN echo "$(tail -n +2 run.sh)" > run.sh && echo '#!/bin/bash\n./mtproto_proxy_stat & disown' | cat - run.sh > temp && mv temp run.sh CMD [ "/bin/sh", "-c", "/bin/bash /run.sh"]

स्कैन

पहले हमें डाटडॉग एजेंट के साथ कंटेनर शुरू करना होगा

 docker run -d --name dd-agent -v /var/run/docker.sock:/var/run/docker.sock:ro -v /proc/:/host/proc/:ro -v /sys/fs/cgroup/:/host/sys/fs/cgroup:ro -e DD_DOGSTATSD_NON_LOCAL_TRAFFIC=true -e DD_API_KEY=_ datadog/agent:latest

महत्वपूर्ण है कि हम एजेंट को अपना डेटा भेज सकें, आपको पर्यावरण चर DD_DOGSTATSD_NON_LOCAL_TRAFFIC लिए true सेट करने की आवश्यकता है

इसके बाद, docker inspect dd-agent करते हुए docker inspect dd-agent हमें डेटा भेजने के लिए कंटेनर के IP को देखने की आवश्यकता है

और एजेंट कंटेनर में एक पुल के साथ जोड़कर हमारे MTProto प्रॉक्सी शुरू करें

 docker run -d -p 443:443 -p 80:80 -e WORKERS=16 -e DDGIP=172.17.0.2 -e TGN=mtproto:main --link=dd-agent --name=mtproto --restart=always -v proxy-config:/data trigun117/mtproto_proxy_stat

और कुछ ही मिनटों में हम पहले से ही वांछित मीट्रिक और स्रोत का चयन करके एक ग्राफ बना सकते हैं (यह टैग जो MTProto प्रॉक्सी के साथ कंटेनर को शुरू करते समय निर्दिष्ट किया गया है)

और उस पर हमारे आँकड़े प्रदर्शित करें

जीवित उदाहरण

निष्कर्ष

खुद के लिए, मैंने डेटा के साथ सुविधाजनक काम के लिए नए उपकरणों की खोज की, उनकी महान विविधता से परिचित हुआ और मेरे स्वाद के लिए उपयुक्त कुछ चुना।

आपका ध्यान देने के लिए धन्यवाद, मैं सुझाव देता हूं कि हर कोई टिप्पणियों में अपनी राय, टिप्पणियां और सुझाव साझा करें।

गितुब भंडार