बिटटोरेंट ट्रैकर C # में

लंबे समय तक मैंने C # में सबसे सरल ट्रैकर के उदाहरण के लिए नेट की खोज की, लेकिन, दुर्भाग्य से, मेरी खोज असफल रही। इसलिए, मैंने सी # में एक ट्रैकर लिखने में खुद को आज़माने का फैसला किया, और अधिक या कम काम करने वाला संस्करण प्राप्त किया, मैं इसके निर्माण के अनुभव को सभी के साथ साझा करूंगा। और साथ ही, इसके सुधार पर अधिक से अधिक सुझाव प्राप्त करें।

लेकिन शुरू से शुरू करते हैं ...

मैंने जो पहला काम किया, वह बिटटोरेंट प्रोटोकॉल विनिर्देश खुला था:।

यह कहता है कि क्लाइंट निम्नलिखित डेटा के साथ सर्वर को एक GET अनुरोध भेजता है: info_hash, peer_id, ip, port, अपलोड, डाउनलोड, बाएं और ईवेंट।

तदनुसार, डेटाबेस सर्वर पर, मैंने निम्न तालिका बनाई:

CREATE TABLE [dbo].[psy_trance_fm_bittorrent_announces] ( [id] [int] IDENTITY(1,1) NOT NULL, [info_hash] [char](40) NOT NULL, [peer_id] [char](40) NOT NULL, [ip] [varchar](512) NOT NULL, [port] [int] NOT NULL, [uploaded] [int] NOT NULL, [downloaded] [int] NOT NULL, [left] [int] NOT NULL, [event] [varchar](512) NULL ) 

यह विनिर्देशन में भी लिखा गया है कि सर्वर क्लाइंट को टेक्स्ट / सादे प्रारूप में एक बिनकोड शब्दकोश के रूप में डेटा भेजता है।

एक Bencoded शब्दकोश में चार डेटा प्रकार हो सकते हैं: string, int, list, और Dictionary।

मैंने बेनकोड में चार एन्कोडिंग कार्य लिखे - प्रत्येक डेटा प्रकार के लिए एक:

  public string encode(string _string) { StringBuilder string_builder = new StringBuilder(); string_builder.Append(_string.Length); string_builder.Append(":"); string_builder.Append(_string); return string_builder.ToString(); } 

  public string encode(int _int) { StringBuilder string_builder = new StringBuilder(); string_builder.Append("i"); string_builder.Append(_int); string_builder.Append("e"); return string_builder.ToString(); } 

  public string encode(List<object> list) { StringBuilder string_builder = new StringBuilder(); string_builder.Append("l"); foreach (object _object in list) { if (_object.GetType() == typeof(string)) { string_builder.Append(encode((string)_object)); } if (_object.GetType() == typeof(int)) { string_builder.Append(encode((int)_object)); } if (_object.GetType() == typeof(List<object>)) { string_builder.Append(encode((List<object>)_object)); } if (_object.GetType() == typeof(SortedDictionary<string, object>)) { string_builder.Append(encode((SortedDictionary<string, object>)_object)); } } string_builder.Append("e"); return string_builder.ToString(); } 

  public string encode(SortedDictionary<string, object> sorted_dictionary) { StringBuilder string_builder = new StringBuilder(); string_builder.Append("d"); foreach (KeyValuePair<string, object> key_value_pair in sorted_dictionary) { string_builder.Append(encode((string)key_value_pair.Key)); if (key_value_pair.Value.GetType() == typeof(string)) { string_builder.Append(encode((string)key_value_pair.Value)); } if (key_value_pair.Value.GetType() == typeof(int)) { string_builder.Append(encode((int)key_value_pair.Value)); } if (key_value_pair.Value.GetType() == typeof(List<object>)) { string_builder.Append(encode((List<object>)key_value_pair.Value)); } if (key_value_pair.Value.GetType() == typeof(SortedDictionary<string, object>)) { string_builder.Append(encode((SortedDictionary<string, object>)key_value_pair.Value)); } } string_builder.Append("e"); return string_builder.ToString(); } 

मैं आपका ध्यान इस तथ्य की ओर आकर्षित करता हूं कि शब्दकोशों के लिए मैंने सॉर्टेडबार्डर <string, object>, और Dictionary <string, object> टाइप नहीं किया। ऐसा इसलिए है, क्योंकि विनिर्देश के अनुसार, शब्दकोशों में कुंजियों को क्रमबद्ध किया जाना चाहिए।

खैर, फिर शुरू हुआ मजा ...

ऐसा लगता है कि GET अनुरोध से info_hash और peer_id प्राप्त करने के लिए, यह क्रमशः Request.QueryString ["info_hash"] और Request.QueryString ["peer_id"] का उपयोग करने के लिए पर्याप्त है, लेकिन ये विधियां पूरी बकवास हैं। बहुत देर तक मैं समझ नहीं पाया कि मामला क्या था ...

और बात यह थी: info_hash, क्लाइंट से सर्वर पर प्रेषित, कुछ इस तरह दिखता है:% 124Vx% 9A% BC% DE% F1% 23Eg% 89% AB% CD% EF% 124Vx% 9A। Request.QueryString ["info_hash"] इसे UTF-8 प्रारूप स्ट्रिंग मानता है और इसे डिकोड करता है।

उदाहरण के लिए, रिफ्लेक्टर फ़ंक्शन FillFromString को देखकर आप इसे सत्यापित कर सकते हैं।

इस बिंदु को प्राप्त करने के लिए, मैंने Request.Url.Query के साथ काम करने का फैसला किया, जो एक कच्चा स्ट्रिंग लौटाता है।

वास्तव में, मैंने Reflector से FillFromString फ़ंक्शन कोड लिया और इसे डिकोड करने के लिए जिम्मेदार कुछ पंक्तियों को हटा दिया:

  string s = Request.Url.Query.Substring(1); SortedDictionary<string, object> parameters = new SortedDictionary<string, object>(StringComparer.Ordinal); int num = (s != null) ? s.Length : 0; for (int i = 0; i < num; i++) { int startIndex = i; int num4 = -1; while (i < num) { char ch = s[i]; if (ch == '=') { if (num4 < 0) { num4 = i; } } else if (ch == '&') { break; } i++; } string str = null; string str2 = null; if (num4 >= 0) { str = s.Substring(startIndex, num4 - startIndex); str2 = s.Substring(num4 + 1, (i - num4) - 1); } else { str2 = s.Substring(startIndex, i - startIndex); } parameters.Add("@" + str, str2); } 

खैर, अपने मूल हेक्साडेसिमल प्रारूप में info_hash और peer_id को वापस करने के लिए, मैंने दो और पंक्तियाँ लिखीं:

  parameters["@info_hash"] = BitConverter.ToString(HttpUtility.UrlDecodeToBytes((string)parameters["@info_hash"])).Replace("-", "").ToLower(); parameters["@peer_id"] = BitConverter.ToString(HttpUtility.UrlDecodeToBytes((string)parameters["@peer_id"])).Replace("-", "").ToLower(); 

विनिर्देश द्वारा, आईपी और घटना वैकल्पिक पैरामीटर हैं। आईपी ​​सर्वर पर अधिकांश ग्राहकों को नहीं भेजता है, और ईवेंट केवल तीन मामलों में स्थानांतरित होता है: शुरू किया, पूरा किया और रोका।

इसलिए, मैंने जांचने का फैसला किया कि क्या वे पैरामीटर संग्रह में हैं, लेकिन यदि नहीं, तो उन्हें जोड़ें:

  if (parameters.ContainsKey("@ip") == false) { parameters.Add("@ip", Request.UserHostAddress); } if (parameters.ContainsKey("@event") == false) { parameters.Add("@event", DBNull.Value); } 

शेष सरल है। हम जाँचते हैं कि क्या डेटाबेस में कोई वितरण है जो संचारित info_hash और peer_id से मेल खाता है, यदि नहीं, तो इसे जोड़ें, यदि ऐसा है, तो बस वितरण डेटा को अपडेट करें।

psy_trance_fm.execute_scalar और psy_trance_fm.execute_non_query डेटाबेस के साथ काम करने के लिए कार्य करते हैं, वे बहुत ही विशिष्ट हैं और मैं यहां बिंदु नहीं देखता।

  psy_trance_fm psy_trance_fm = new psy_trance_fm(); if (psy_trance_fm.execute_scalar("SELECT * FROM [dbo].[psy_trance_fm_bittorrent_announces] WHERE [info_hash] = @info_hash AND [peer_id] = @peer_id", parameters, CommandType.Text) == null) { psy_trance_fm.execute_non_query("INSERT INTO [dbo].[psy_trance_fm_bittorrent_announces] ([info_hash], [peer_id], [ip], [port], [uploaded], [downloaded], [left], [event]) VALUES (@info_hash, @peer_id, @ip, @port, @uploaded, @downloaded, @left, @event)", parameters, CommandType.Text); } else { psy_trance_fm.execute_non_query("UPDATE [dbo].[psy_trance_fm_bittorrent_announces] SET [ip] = @ip, [port] = @port, [uploaded] = @uploaded, [downloaded] = @downloaded, [left] = @left, [event] = @event WHERE [info_hash] = @info_hash AND [peer_id] = @peer_id", parameters, CommandType.Text); } 

डेटाबेस में डेटा दर्ज करने के बाद, हमें क्लाइंट को बेनकोड किए गए शब्दकोश को वापस करना होगा।

यह निम्नानुसार किया जाता है:

  SortedDictionary<string, object> sorted_dictionary = new SortedDictionary<string, object>(StringComparer.Ordinal); sorted_dictionary.Add("interval", 60); List<object> peers = new List<object>(); DataTable data_table = psy_trance_fm.fill("SELECT * FROM [dbo].[psy_trance_fm_bittorrent_announces] WHERE [info_hash] = @info_hash", parameters, CommandType.Text); foreach (DataRow data_row in data_table.Rows) { SortedDictionary<string, object> peer = new SortedDictionary<string, object>(StringComparer.Ordinal); peer.Add("peer id", data_row["peer_id"]); peer.Add("ip", data_row["ip"]); peer.Add("port", data_row["port"]); peers.Add(peer); } sorted_dictionary.Add("peers", peers); bencode bencode = new bencode(); Response.Write(bencode.encode(sorted_dictionary)); 

खैर, यह बात है! सबसे सरल सी # बिटटोरेंट ट्रैकर तैयार है। हां, इसमें कोई त्रुटि से निपटने, सांख्यिकी, और इतने पर और आगे नहीं है। लेकिन यह काम करता है!

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

पढ़ने के लिए धन्यवाद!