📄 🛳️ 🤸🏼 हम स्वोइल का उपयोग करके वेबसोकेट पर एक ऑनलाइन चैट लिखते हैं 🤳🏼 ♑️ 👓

वेबसोकेट्स का विषय पहले ही बार-बार हैबे पर छुआ गया था , PHP में कार्यान्वयन के लिए विशेष विकल्पों पर विचार किया गया था। हालांकि, विभिन्न तकनीकों के अवलोकन के साथ अंतिम लेख के बाद से एक वर्ष से अधिक समय बीत चुका है, और PHP दुनिया में समय के साथ घमंड करने के लिए कुछ है ।

इस लेख में मैं Swoole को रूसी भाषी समुदाय से परिचित कराना चाहता हूं - PHP के लिए एसिंक्रोनस ओपन सोर्स फ्रेमवर्क, सी में लिखा गया है, और एक pecl एक्सटेंशन के रूप में दिया गया है।

गीथूब पर सूत्र ।

झपट्टा क्यों?

निश्चित रूप से ऐसे लोग होंगे जो सैद्धांतिक रूप से ऐसे उद्देश्यों के लिए PHP का उपयोग करने के खिलाफ होंगे, हालांकि, वे अक्सर PHP के पक्ष में खेल सकते हैं:

परियोजना पर विभिन्न भाषाओं के चिड़ियाघर का प्रजनन करने की अनिच्छा
पहले से ही विकसित कोड आधार (यदि परियोजना PHP में है) का उपयोग करने की क्षमता।

फिर भी, यहां तक कि नोड.जेएस / गो / एरलंग और अन्य भाषाओं के साथ तुलना करना, जो मूल रूप से एक अतुल्यकालिक मॉडल की पेशकश करते हैं, स्वोले - सी में लिखा गया एक ढांचा और कम प्रवेश सीमा और शक्तिशाली कार्यक्षमता का संयोजन एक अच्छा उम्मीदवार हो सकता है।

ढांचे की विशेषताएं:

घटना, अतुल्यकालिक प्रोग्रामिंग मॉडल
एसिंक्रोनस टीसीपी / यूडीपी / एचटीटीपी / वेबसोकेट / एचटीटीपी २ क्लाइंट / सर्वर एपीआई
IPv4 / IPv6 / Unixsocket / TCP / UDP और SSL / TLS का समर्थन करें
तेजी से डेटा क्रमांकन / deserialization
उच्च प्रदर्शन, एक्स्टेंसिबिलिटी, 1 मिलियन तक एक साथ कनेक्शन के लिए समर्थन
मिलिसकॉन्ड कार्य अनुसूचक
खुला स्रोत
Coroutines का समर्थन

संभावित उपयोग के मामले:

Mikroservisy
खेल सर्वर
चीजों का इंटरनेट
लाइव संचार प्रणाली
वेब एपीआई
किसी भी अन्य सेवाओं को तत्काल प्रतिक्रिया / उच्च गति / अतुल्यकालिक निष्पादन की आवश्यकता होती है

साइट के मुख्य पृष्ठ पर कोड के उदाहरण देखे जा सकते हैं। प्रलेखन अनुभाग में, फ्रेमवर्क की सभी कार्यक्षमता के बारे में अधिक विस्तृत जानकारी।

चलिए शुरू करते हैं

नीचे मैं ऑनलाइन चैट के लिए एक सरल वेबसोकेट सर्वर लिखने की प्रक्रिया और इसके साथ संभावित कठिनाइयों का वर्णन करूंगा।

शुरू करने से पहले: swoole_websocket_server और swoole_server classes पर अधिक जानकारी (दूसरी कक्षा पहली से विरासत में मिली है)।
चैट के सूत्र।

ढांचा स्थापित करना

Linux users

#!/bin/bash
pecl install swoole

Mac users

# get a list of avaiable packages
brew install swoole
#!/bin/bash
brew install homebrew/php/php71-swoole

आईडीई में स्वत: पूर्ण का उपयोग करने के लिए, यह विचारधारा-सहायक का उपयोग करने का प्रस्ताव है

न्यूनतम वेबसोकेट सर्वर टेम्पलेट:

 <?php $server = new swoole_websocket_server("127.0.0.1", 9502); $server->on('open', function($server, $req) { echo "connection open: {$req->fd}\n"; }); $server->on('message', function($server, $frame) { echo "received message: {$frame->data}\n"; $server->push($frame->fd, json_encode(["hello", "world"])); }); $server->on('close', function($server, $fd) { echo "connection close: {$fd}\n"; }); $server->start();

$ fd कनेक्शन पहचानकर्ता है।
वर्तमान कनेक्शन प्राप्त करें:

 $server->connections;

$ फ़्रेम में भेजे गए सभी डेटा शामिल हैं। यहाँ एक वस्तु का एक उदाहरण दिया गया है जो ऑनमैसेज फ़ंक्शन में आया है:

 Swoole\WebSocket\Frame Object ( [fd] => 20 [data] => {"type":"login","username":"new user"} [opcode] => 1 [finish] => 1 )

फ़ंक्शन का उपयोग करके क्लाइंट को डेटा भेजा जाता है

 Server::push($fd, $data, $opcode=null, $finish=null)

रूसी में फ्रेम और ओपकोड के बारे में और जानें । javascript । अनुभाग "डेटा प्रारूप"

Websocket प्रोटोकॉल के बारे में जितना संभव हो - RFC

और सर्वर पर आए डेटा को कैसे बचाया जाए?
Swoole MySQL , Redis , फ़ाइल I / O के साथ अतुल्यकालिक रूप से काम करने के लिए कार्यक्षमता का परिचय देता है

साथ ही swoole_buffer , swoole_channel और swoole_table
मुझे लगता है कि प्रलेखन से अंतर समझना मुश्किल नहीं है। उपयोगकर्ता नामों को संग्रहीत करने के लिए, मैंने swoole_table का चयन किया। संदेश स्वयं MySQL में संग्रहीत होते हैं।

इसलिए, उपयोगकर्ता नाम तालिका का आरंभ:

 $users_table = new swoole_table(131072); $users_table->column('id', swoole_table::TYPE_INT, 5); $users_table->column('username', swoole_table::TYPE_STRING, 64); $users_table->create();

डेटा के साथ भरना इस प्रकार है:

 $count = count($messages_table); $dateTime = time(); $row = ['username' => $username, 'message' => $data->message, 'date_time' => $dateTime]; $messages_table->set($count, $row);

MySQL के साथ काम करने के लिए, मैंने अभी तक एसिंक्रोनस मॉडल का उपयोग नहीं करने का फैसला किया, लेकिन इसे पीडीओ के माध्यम से वेब सॉकेट सर्वर से मानक तरीके से एक्सेस करने के लिए।

आधार की अपील

 /** * @return Message[] */ public function getAll() { $stmt = $this->pdo->query('SELECT * from messages'); $messages = []; foreach ($stmt->fetchAll() as $row) { $messages[] = new Message( $row['username'], $row['message'], new \DateTime($row['date_time']) ); } return $messages; }

Websocket सर्वर को एक वर्ग के रूप में जारी करने का फैसला किया गया था, और इसे कंस्ट्रक्टर में शुरू किया गया था:

डिजाइनर

 public function __construct() { $this->ws = new swoole_websocket_server('0.0.0.0', 9502); $this->ws->on('open', function ($ws, $request) { $this->onConnection($request); }); $this->ws->on('message', function ($ws, $frame) { $this->onMessage($frame); }); $this->ws->on('close', function ($ws, $id) { $this->onClose($id); }); $this->ws->on('workerStart', function (swoole_websocket_server $ws) { $this->onWorkerStart($ws); }); $this->ws->start(); }

समस्याओं का सामना करना पड़ा:

कोई उपयोगकर्ता 60 सेकंड के बाद चैट डिस्कनेक्ट करता है यदि कोई पैकेट एक्सचेंज नहीं है (यानी, उपयोगकर्ता ने कुछ भी नहीं भेजा या प्राप्त नहीं किया)
यदि लंबे समय तक कोई बातचीत नहीं होती है, तो वेबसर्वर MySQL के साथ संबंध खो देता है

समाधान:

दोनों ही मामलों में, हमें पिंग फ़ंक्शन के कार्यान्वयन की आवश्यकता है, जो पहले मामले में हर n सेकंड में क्लाइंट को पिंग करेगा, और दूसरे में MySQL डेटाबेस।

चूंकि दोनों कार्यों को अतुल्यकालिक रूप से काम करना चाहिए, इसलिए उन्हें सर्वर की बाल प्रक्रियाओं में बुलाया जाना चाहिए।

ऐसा करने के लिए, उन्हें "वर्करस्टार्ट" ईवेंट के साथ आरंभ किया जा सकता है। हमने पहले से ही इसे कंस्ट्रक्टर में परिभाषित किया है, और इस घटना के साथ $ इस-> onWorkerStart विधि को पहले से ही कहा जाता है:
Websocket प्रोटोकॉल पिंग-पोंग बॉक्स से बाहर का समर्थन करता है। नीचे आप स्वोल पर कार्यान्वयन देख सकते हैं।

onWorkerStart

 private function onWorkerStart(swoole_websocket_server $ws) { $this->messagesRepository = new MessagesRepository(); $ws->tick(self::PING_DELAY_MS, function () use ($ws) { foreach ($ws->connections as $id) { $ws->push($id, 'ping', WEBSOCKET_OPCODE_PING); } }); }

इसके बाद, मैंने sSQL और टाइमर का उपयोग करके प्रत्येक N सेकंड में एक MySQL सर्वर को पिंग करने के लिए एक साधारण फ़ंक्शन लागू किया:

DatabaseHelper

टाइमर ही initPdo में शुरू होता है अगर यह पहले से ही सक्षम नहीं है:

  /** * Init new Connection, and ping DB timer function */ private static function initPdo() { if (self::$timerId === null || (!Timer::exists(self::$timerId))) { self::$timerId = Timer::tick(self::MySQL_PING_INTERVAL, function () { self::ping(); }); } self::$pdo = new PDO(self::DSN, DBConfig::USER, DBConfig::PASSWORD, self::OPT); } /** * Ping database to maintain the connection */ private static function ping() { try { self::$pdo->query('SELECT 1'); } catch (PDOException $e) { self::initPdo(); } }

काम के मुख्य भाग में जोड़ने, सहेजने, संदेश भेजने (सामान्य CRUD से अधिक जटिल नहीं) के लिए तर्क लिखने और फिर सुधार की बहुत बड़ी गुंजाइश थी।

अब तक मैं अपने कोड को अधिक या कम पठनीय रूप और एक वस्तु-उन्मुख शैली में लाया हूं, मैंने थोड़ी कार्यक्षमता लागू की है:

- नाम से लॉगिन करें;

- जांचें कि नाम व्यस्त नहीं है

 /** * @param string $username * @return bool */ private function isUsernameCurrentlyTaken(string $username) { foreach ($this->usersRepository->getByIds($this->ws->connection_list()) as $user) { if ($user->getUsername() == $username) { return true; } } return false; }

- स्पैम सीमक

 <?php namespace App\Helpers; use Swoole\Channel; class RequestLimiter { /** * @var Channel */ private $userIds; const MAX_RECORDS_COUNT = 10; const MAX_REQUESTS_BY_USER = 4; public function __construct() { $this->userIds = new Channel(1024 * 64); } /** * Check if there are too many requests from user * and make a record of request from that user * * @param int $userId * @return bool */ public function checkIsRequestAllowed(int $userId) { $requestsCount = $this->getRequestsCountByUser($userId); $this->addRecord($userId); if ($requestsCount >= self::MAX_REQUESTS_BY_USER) return false; return true; } /** * @param int $userId * @return int */ private function getRequestsCountByUser(int $userId) { $channelRecordsCount = $this->userIds->stats()['queue_num']; $requestsCount = 0; for ($i = 0; $i < $channelRecordsCount; $i++) { $userIdFromChannel = $this->userIds->pop(); $this->userIds->push($userIdFromChannel); if ($userIdFromChannel === $userId) { $requestsCount++; } } return $requestsCount; } /** * @param int $userId */ private function addRecord(int $userId) { $recordsCount = $this->userIds->stats()['queue_num']; if ($recordsCount >= self::MAX_RECORDS_COUNT) { $this->userIds->pop(); } $this->userIds->push($userId); } }

पुनश्च: हाँ, कनेक्शन आईडी पर सत्यापन है। शायद यह इस मामले में इसे बदलने के लिए समझ में आता है, उदाहरण के लिए, उपयोगकर्ता के आईपी पते के साथ।

मुझे यह भी यकीन नहीं है कि इस स्थिति में यह swoole_channel था जो सबसे उपयुक्त था। मुझे लगता है कि बाद में इस पल को संशोधित करने के लिए।

- ezyang / htmlpurifier का उपयोग करके सरल XSS सुरक्षा

- सिंपल स्पैम फिल्टर

भविष्य में अतिरिक्त चेक जोड़ने की क्षमता के साथ।

 <?php namespace App\Helpers; class SpamFilter { /** * @var string[] errors */ private $errors = []; /** * @param string $text * @return bool */ public function checkIsMessageTextCorrect(string $text) { $isCorrect = true; if (empty(trim($text))) { $this->errors[] = 'Empty message text'; $isCorrect = false; } return $isCorrect; } /** * @return string[] errors */ public function getErrors(): array { return $this->errors; } }

फ्रंटेंड चैट अभी भी बहुत कच्ची है, क्योंकि मैं बैकएंड के लिए अधिक आकर्षित हूं, लेकिन जब अधिक समय होगा, तो मैं इसे और अधिक सुखद बनाने की कोशिश करूंगा।

जानकारी कहाँ से प्राप्त करें, रूपरेखा के बारे में समाचार प्राप्त करें?

अंग्रेजी आधिकारिक साइट - उपयोगी लिंक, अप-टू-डेट प्रलेखन, उपयोगकर्ताओं से कुछ टिप्पणियां
ट्विटर - वर्तमान समाचार, उपयोगी लिंक, दिलचस्प लेख
इश्यू ट्रैकर (जीथूब) - बग, प्रश्न, रूपरेखा के रचनाकारों के साथ संचार। वे बहुत चालाकी से जवाब देते हैं (उन्होंने कुछ घंटों में एक सवाल के साथ मेरे सवाल का जवाब दिया, पिंगलोप के कार्यान्वयन में मदद की)।
बंद मुद्दे - मैं भी सलाह देता हूं। उपयोगकर्ताओं के सवालों का एक बड़ा डेटाबेस और फ्रेमवर्क के रचनाकारों से उत्तर।
डेवलपर्स द्वारा लिखित परीक्षण - प्रलेखन के लगभग हर मॉड्यूल में PHP में लिखे गए परीक्षण हैं, उपयोग के मामले दिखाते हैं।
चीनी विकी फ्रेमवर्क - अंग्रेजी में जैसा कि सभी जानकारी है, लेकिन उपयोगकर्ताओं से बहुत अधिक टिप्पणियां (मदद करने के लिए Google अनुवादक)।

एपीआई प्रलेखन - काफी सुविधाजनक रूप में फ्रेमवर्क के कुछ वर्गों और कार्यों का विवरण।

सारांश

यह मुझे लगता है कि स्वोलोल पिछले साल बहुत सक्रिय रूप से विकसित हो रहा है, यह मंच से बाहर आ गया है जब इसे "कच्चा" कहा जा सकता है, और अब यह एसिंक्रोनस प्रोग्रामिंग और नेटवर्क प्रोटोकॉल के कार्यान्वयन के संदर्भ में नोड.जेएस / के उपयोग के साथ पूर्ण प्रतियोगिता में है।

मुझे उन विषयों पर अलग-अलग राय सुनने और उन लोगों से प्रतिक्रिया प्राप्त करने में खुशी होगी जो पहले से ही स्वोल का उपयोग करने का अनुभव रखते हैं

आप लिंक द्वारा चैट रूम में चैट कर सकते हैं
गीथूब पर स्रोत उपलब्ध हैं।

हम स्वोइल का उपयोग करके वेबसोकेट पर एक ऑनलाइन चैट लिखते हैं

झपट्टा क्यों?

चलिए शुरू करते हैं

जानकारी कहाँ से प्राप्त करें, रूपरेखा के बारे में समाचार प्राप्त करें?

सारांश

More articles: