PHP पर माइक्रोसर्विसेज़: उन्नत स्तर की आर्किटेक्चर और अभ्यास

PHP पर माइक्रोसर्विसेज़: सिद्धांत से प्रोडक्शन तक

PHP पर मोनोलिथ से माइक्रोसर्विस आर्किटेक्चर में संक्रमण केवल एक तकनीकी उन्नयन नहीं है, बल्कि डेवलपर की सोच में एक मौलिक बदलाव है। उन्नत स्तर पर, हम वास्तविक चुनौतियों का सामना करते हैं: वितरित लेन-देन, डेटा संगति, नेटवर्क विलंबता और डिबगिंग की जटिलता। इस लेख में, हम प्रमुख पैटर्न और व्यावहारिक तकनीकों पर चर्चा करेंगे जो PHP पर एक विश्वसनीय और स्केलेबल सिस्टम बनाने में मदद करेंगे।

1. सेवाओं के बीच संचार: सिंक्रोनस बनाम एसिंक्रोनस

संचार प्रोटोकॉल का चयन पहली चीज़ है जिसका सामना एक आर्किटेक्ट को करना पड़ता है। PHP इकोसिस्टम में दो मुख्य दृष्टिकोण हैं।

REST/gRPC के माध्यम से सिंक्रोनस संचार

उन कार्यों के लिए आदर्श जिनमें तत्काल प्रतिक्रिया की आवश्यकता होती है (जैसे, उपयोगकर्ता के बैलेंस की जाँच करना)। हालांकि, यह कठोर निर्भरताएँ बनाता है: यदि सेवा B डाउन हो जाती है, तो सेवा A भी डाउन हो जाएगी। Circuit Breaker पैटर्न का उपयोग करने की अनुशंसा की जाती है।

// Guzzle लाइब्रेरी का उपयोग करके PHP पर Circuit Breaker का उदाहरण\nuse GuzzleHttp\\Client;\nuse GuzzleHttp\\Exception\\ConnectException;\n\nclass CircuitBreaker {\n    private int $failureCount = 0;\n    private int $threshold = 3;\n    private int $timeout = 30; // सेकंड\n    private bool $open = false;\n    private int $lastFailureTime = 0;\n\n    public function call(string $url): ?array {\n        if ($this->isOpen()) {\n            return null; // त्वरित शॉर्ट-सर्किट\n        }\n\n        try {\n            $client = new Client(['timeout' => 2.0]);\n            $response = $client->get($url);\n            $this->reset();\n            return json_decode($response->getBody(), true);\n        } catch (ConnectException $e) {\n            $this->recordFailure();\n            return null;\n        }\n    }\n\n    private function isOpen(): bool {\n        if (!$this->open) return false;\n        if (time() - $this->lastFailureTime > $this->timeout) {\n            $this->open = false; // आधा-खुला राज्य\n            return false;\n        }\n        return true;\n    }\n\n    private function recordFailure(): void {\n        $this->failureCount++;\n        $this->lastFailureTime = time();\n        if ($this->failureCount >= $this->threshold) {\n            $this->open = true;\n        }\n    }\n\n    private function reset(): void {\n        $this->failureCount = 0;\n        $this->open = false;\n    }\n}

कतारों (RabbitMQ, Kafka) के माध्यम से एसिंक्रोनस संचार

उन कार्यों के लिए जिनमें तत्काल प्रतिक्रिया की आवश्यकता नहीं होती (ईमेल भेजना, रिपोर्ट जनरेट करना)। php-amqplib लाइब्रेरी का उपयोग करें।

// RabbitMQ में इवेंट प्रकाशित करना\nuse PhpAmqpLib\\Connection\\AMQPStreamConnection;\nuse PhpAmqpLib\\Message\\AMQPMessage;\n\n$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');\n$channel = $connection->channel();\n\n$channel->queue_declare('order_created', false, true, false, false);\n\n$data = json_encode([\n    'order_id' => 12345,\n    'user_id' => 678,\n    'total' => 1500.00\n]);\n$msg = new AMQPMessage($data, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);\n$channel->basic_publish($msg, '', 'order_created');\n\n$channel->close();\n$connection->close();

2. डेटा प्रबंधन: CQRS और Event Sourcing

माइक्रोसर्विसेज़ में, प्रत्येक सेवा के पास अपना डेटा होना चाहिए। लेकिन क्या होगा यदि आपको रिपोर्ट के लिए विभिन्न सेवाओं से डेटा संयोजित करने की आवश्यकता है? CQRS (Command Query Responsibility Segregation) पैटर्न मदद करता है।

PHP पर सरल CQRS का कार्यान्वयन

हम कमांड (लेखन) और क्वेरी (पढ़ना) को अलग करते हैं। लेखन के लिए Doctrine ORM का उपयोग करें, पढ़ने के लिए - रीड-मॉडल पर सीधे SQL क्वेरी का।

// कमांड: ऑर्डर बनाना\nclass CreateOrderCommand {\n    public function __construct(\n        public readonly int $userId,\n        public readonly array $items,\n        public readonly float $total\n    ) {}\n}\n\n// हैंडलर\n