हम स्क्रैच से PHP में वेब सॉकेट बनाते हैं। भाग 2. आईपीसी

अपने पिछले लेख को लिखने के बाद, हम स्क्रैच से PHP में वेब सॉकेट बनाते हैं, मैंने महसूस किया कि मेरे द्वारा उठाए गए विषय में समुदाय की कुछ रुचि है।

पिछले लेख में, मैंने वादा किया था कि मैं इसका वर्णन करूंगा:

• कनेक्शन को संभालने के लिए कई प्रक्रियाएं चलाना
• इंटरप्रोसेस संचार
• प्रक्रियाओं के अलगाव मास्टर कार्यकर्ता
• nginx का उपयोग कर वेब सॉकेट को सम्‍मिलित करना
• कंसोल से लॉन्च
• yii के उदाहरण पर आपके ढांचे के साथ एकीकरण
• प्रदर्शन

और, हमेशा की तरह, परिणामी कोड और लेख के अंत में डेमो चैट का लिंक।

कनेक्शन को संभालने के लिए कई प्रक्रियाएं चलाना

काम करने के लिए एक साधारण वेब सॉकेट सर्वर के लिए, एक प्रक्रिया पर्याप्त है, लेकिन एक साथ कनेक्शन की संख्या बढ़ाने के लिए (और 1024 एक साथ कनेक्शन की सीमा को बायपास करें), साथ ही पूरे प्रोसेसर के संसाधनों का उपयोग करने के लिए (और न केवल एक कोर), यह आवश्यक है कि वेब सॉकेट सर्वर कई प्रक्रियाओं का उपयोग करता है - (आशा है कि प्रक्रियाओं की संख्या = प्रोसेसर कोर की संख्या)।

कई प्रक्रियाओं को शुरू करने के लिए, हम pcntl_fork() फ़ंक्शन का उपयोग करेंगे। यह एक नई प्रक्रिया (बच्चा) बनाता है, जो कि इस कॉल को बनाने वाली मूल प्रक्रिया की लगभग पूर्ण प्रतिलिपि है।
pcntl_fork() कॉल करने के बाद pcntl_fork() एल्गोरिथ्म शाखाएँ: यदि pcntl_fork() फ़ंक्शन pcntl_fork() यह बच्चे की PID को माता-पिता और NULL को बच्चे को वापस कर देता है। यदि कांटा निर्माण विफल रहा, तो pcntl_fork() फ़ंक्शन -1)।

 $pid = pcntl_fork(); //  //        if ($pid == -1) { //      } elseif ($pid) { //      } else { //      ,  PID      getmypid() } 

मूल प्रक्रिया और बच्चे के बीच अंतर के बारे में विकिपीडिया पर पढ़ा जा सकता है।

हम एक लूप में जितनी बच्चे की प्रक्रियाएं कर सकते हैं, उतने बना सकते हैं:

 $childs = array(); for ($i=0; $i<4; $i++) { $pid = pcntl_fork(); //  if ($pid == -1) { die("error: pcntl_fork"); } elseif ($pid) { //  $childs[] = $pid; //   PID,     :) } else { //  break; //  ,        } } 

इंटरप्रोसेस संचार

माता-पिता और बच्चे की प्रक्रिया के बीच बातचीत के लिए, हम सॉकेट का उपयोग करेंगे, अर्थात् संबंधित सॉकेट:
stream_socket_pair() फ़ंक्शन संबंधित अप्रभेद्य स्ट्रीम सॉकेट की एक जोड़ी बनाता है। इस प्रकार, हम एक सॉकेट को लिख सकते हैं, और दूसरे से डेटा पढ़ सकते हैं।

 $pair = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP); //     fwrite($pair[0], ''); //    fread($pair[1], mb_strlen('')); //   

अब हम इस कोड को कांटे से जोड़ते हैं और प्राप्त करते हैं:

 $pair = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP); //   $pid = pcntl_fork(); //  //        if ($pid == -1) { die("error: pcntl_fork"); } elseif ($pid) { //  fclose($pair[0]); //      $child = $pair[1]; //       } else { //  fclose($pair[1]); //      $parent = $pair[0]; //       } 

कई बाल प्रक्रियाओं को बनाने के लिए परिणामी कोड:

 $parent = null; $childs = array(); for ($i=0; $i<5; $i++) { $pair = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP); //   $pid = pcntl_fork(); //  if ($pid == -1) { die("error: pcntl_fork"); } elseif ($pid) { //  fclose($pair[0]); //      $childs[] = $pair[1]; //       } else { //  fclose($pair[1]); //      $parent = $pair[0]; //       break; //  ,        } } 

माता-पिता में इस कोड के काम के परिणामस्वरूप, $childs सरणी में बच्चों के साथ संवाद करने के लिए सभी सॉकेट होंगे, और बच्चे $parent के साथ संवाद करने के लिए $parent का उपयोग करेंगे।

स्वामी और श्रमिकों में प्रक्रियाओं का पृथक्करण

चूंकि हमारे कार्यान्वयन में बच्चे की प्रक्रियाएं सीधे एक दूसरे से संबंधित नहीं हैं और केवल माता-पिता के माध्यम से बातचीत कर सकती हैं, इसलिए माता-पिता और वंशजों के बीच जिम्मेदारियों को साझा करना उचित है:

• माता-पिता बच्चे की प्रक्रियाओं के बीच बातचीत के लिए जिम्मेदार होंगे (मास्टर होंगे)
• बाल प्रक्रियाएं सभी काम करेंगी (श्रमिक होंगे)

इसके अलावा, कार्यकर्ता साइट के पन्नों से या मुकुट से लिपियों से संदेश भेजने में लगे रहेंगे। ऐसा करने के लिए, हम एक अतिरिक्त सॉकेट बनाएंगे, और इसे सुनने के सॉकेट में जोड़ेंगे। उदाहरण के लिए, आप एक यूनिक्स सॉकेट बना सकते हैं:

 $service = stream_socket_server('unix:///tmp/websocket.sock', $errorNumber, $errorString); 

वेब सॉकेट प्रॉक्सी nginx का उपयोग कर

Nginx संस्करण 1.3.13 के बाद से वेब सॉकेट प्रॉक्सी का समर्थन करता है। Nginx के लिए धन्यवाद, आप साइट के समान पोर्ट पर वेब सॉकेट सर्वर से कनेक्शन संभाल सकते हैं, साथ ही एक आईपी और आपके द्वारा पसंद किए जाने वाले अन्य बन्स से खुले वेब सॉकेट की संख्या को सीमित कर सकते हैं।

एक उदाहरण nginx config जो इसे अनुमति देता है:

 limit_conn_zone $binary_remote_addr zone=perip:10m; server { listen 5.135.163.218:80; server_name sharoid.ru; location / { limit_conn perip 5; #  5   1 ip proxy_pass http://127.0.0.1:8000; proxy_http_version 1.1; proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; proxy_read_timeout 3600s; #    } } 

कंसोल से लॉन्च करें

php websocket.php या ./websocket.php php websocket.php (निष्पादित करने की अनुमति देने के बाद)
यदि आप nohup उपयोग करते हैं, उदाहरण के लिए, nohup ./websocket.php & , स्क्रिप्ट को कंसोल को बंद करने के बाद काम करना जारी रखेगा।

डिफ़ॉल्ट रूप से, प्रति प्रक्रिया कनेक्शन की संख्या पर दो सीमाएँ हैं।

• पहला ऑपरेटिंग सिस्टम स्तर पर है: आप एक प्रक्रिया में 1024 से अधिक कनेक्शन नहीं खोल सकते। अधिक युगपत कनेक्शनों को संभालने के लिए, कमांड चलाएँ: ulimit -n 65535 , और यदि उपयोगकर्ता के पास पर्याप्त विशेषाधिकार नहीं हैं, तो sudo sh -c "ulimit -n 65535 && exec su $LOGNAME" । वर्तमान मूल्य को ulimit -n कमांड का उपयोग करके देखा जा सकता है
• दूसरा फ़ंक्शन है stream_select() : यह 1024 से अधिक कनेक्शन स्वीकार नहीं करता है। यहां सब कुछ अधिक जटिल है - आपको एक बढ़ी हुई FD_SETSIZE साथ php को फिर से FD_SETSIZE

जैसा कि मैंने पहले ही लिखा था, बाल प्रक्रियाओं (श्रमिकों) का उपयोग करके इन प्रतिबंधों को दरकिनार किया जा सकता है।

Yii के उदाहरण पर अपने ढांचे के साथ एकीकरण

चूंकि हमारा मास्टर हमारी स्क्रिप्ट के साथ संचार के लिए एक अतिरिक्त सॉकेट पर सुनता है (ऊपर के उदाहरण में, यह unix:///tmp/websocket.sock था unix:///tmp/websocket.sock ), हम इस सॉकेट को हमारी साइट में कहीं भी या मुकुट में जोड़ सकते हैं और एक संदेश भेज सकते हैं कि मास्टर भेज देगा सभी कार्यकर्ता, और वे, बदले में, सभी ग्राहक:

 $service = stream_socket_client ('unix:///tmp/websocket.sock', $errno, $errstr); fwrite($service, ' '); 

Yii घटक का उपयोग करते हुए, यह इस तरह दिखेगा:

 Yii::app()->websocket->send(' '); 

प्रदर्शन

डेमो चैट 2.0 (उपयोगकर्ताओं की सूची में जोड़ा गया सीमा, एक आईपी से प्रति सेकंड 1 संदेश)
यह ऊपर वर्णित कार्यों का उपयोग करता था, साथ ही पिछले लेख के प्रकाशन के बाद पहचानी गई कमियों को ठीक करता था।
डेमो चैट 1.0 (कोई उपयोगकर्ता सूची, कोई सीमा नहीं)

मैंने एक पुस्तकालय के रूप में सभी स्रोतों को डिज़ाइन किया और जीथब पर पोस्ट किया

अद्यतन: यदि समुदाय इस विषय में रुचि रखता है, तो अगला लेख इस बारे में होगा कि एक साधारण खेल कैसे बनाया जाए जिसमें सभी प्रतिभागी एक ही खेल के मैदान पर होंगे और वास्तविक समय में एक दूसरे के साथ बातचीत करेंगे (डेमो लगभग तैयार है)।

भाग तीन: चैट से गेम तक: बैटल सिटी