Building Event-Driven Microservices in MERN with RabbitMQ and Node.js (In Hindi)

Building Event-Driven Microservices in MERN with RabbitMQ and Node.js

नमस्ते दोस्तों! आज हम एक बहुत ही गंभीर और एडवांस टॉपिक पर चर्चा करने वाले हैं। जब हम MERN Stack में बड़े प्रोजेक्ट्स बनाते हैं, तो एक समय ऐसा आता है जहाँ एक ही monolithic codebase को मैनेज करना बहुत मुश्किल हो जाता है। यहीं से जन्म होता है Microservices का। लेकिन सिर्फ सर्विस को अलग-अलग करने से काम नहीं चलता, असली जादू तब होता है जब ये सर्विसेज एक-दूसरे से "Event-Driven" तरीके से बात करती हैं।

आज हम सीखेंगे कि कैसे NodeJS और RabbitMQ का उपयोग करके एक robust इवेंट-ड्रिवन सिस्टम बनाया जाए।

Event-Driven Architecture क्या है और क्यों चाहिए?

कल्पना कीजिए कि आपके पास एक E-commerce एप्लीकेशन है। जब कोई यूजर ऑर्डर प्लेस करता है, तो आपको बहुत सारे काम करने होते हैं: Inventory अपडेट करना, Invoice जनरेट करना, और यूजर को ईमेल भेजना। अगर आप ये सब एक ही API call में करेंगे, तो आपकी API रिस्पॉन्स देने में बहुत समय लेगी।

Event-Driven Architecture में, आपकी Order Service सिर्फ एक "OrderCreated" इवेंट पब्लिश कर देती है। बाकी की सर्विसेज (Inventory, Email, Invoice) उस इवेंट को "सुनती" हैं और अपना काम बैकग्राउंड में करती हैं। इससे आपकी मुख्य API सुपर-फास्ट हो जाती है।

RabbitMQ: द मैसेज ब्रोकर

RabbitMQ एक मैसेज ब्रोकर है। यह सर्विसेज के बीच में एक "डाकिये" की तरह काम करता है। एक सर्विस मैसेज भेजती है (Producer), और दूसरी सर्विस उसे रिसीव करती है (Consumer)।

स्टेप 1: सेटअप और इंस्टालेशन

सबसे पहले अपने प्रोजेक्ट में RabbitMQ client इंस्टॉल करें:

npm install amqplib

हम मान लेते हैं कि आपके पास एक ExpressJS सर्वर है। अब हम एक RabbitMQ कनेक्शन यूटिलिटी बनाएंगे ताकि बार-बार कनेक्शन न खोलना पड़े।

// rabbitmq.js
const amqp = require('amqplib');

let channel = null;

async function connectRabbitMQ() {
    try {
        const connection = await amqp.connect('amqp://localhost');
        channel = await connection.createChannel();
        console.log("RabbitMQ Connected Successfully");
    } catch (error) {
        console.error("RabbitMQ Connection Failed:", error);
    }
}

function getChannel() {
    return channel;
}

module.exports = { connectRabbitMQ, getChannel };

स्टेप 2: Producer बनाना (Order Service)

जब यूजर ऑर्डर प्लेस करे, तब हमें मैसेज पब्लिश करना है।

// orderController.js
const { getChannel } = require('./rabbitmq');

const placeOrder = async (req, res) => {
    const orderData = req.body;
    
    // ऑर्डर सेव करने का लॉजिक (MongoDB) यहाँ होगा
    
    const channel = getChannel();
    const exchange = 'order_exchange';
    
    // मैसेज पब्लिश करना
    channel.assertExchange(exchange, 'fanout', { durable: false });
    channel.publish(exchange, '', Buffer.from(JSON.stringify(orderData)));
    
    res.status(201).json({ message: "Order placed, processing started!" });
};

स्टेप 3: Consumer बनाना (Email/Inventory Service)

अब दूसरी सर्विस इस इवेंट को सुनेगी।

// consumer.js
const amqp = require('amqplib');

async function consumeEvents() {
    const connection = await amqp.connect('amqp://localhost');
    const channel = await connection.createChannel();
    const exchange = 'order_exchange';

    await channel.assertExchange(exchange, 'fanout', { durable: false });
    const q = await channel.assertQueue('', { exclusive: true });
    
    channel.bindQueue(q.queue, exchange, '');

    console.log("Waiting for events...");

    channel.consume(q.queue, (msg) => {
        const order = JSON.parse(msg.content.toString());
        console.log("Received Order Event:", order);
        // यहाँ आप अपना Email या Inventory logic लिख सकते हैं
    }, { noAck: true });
}

consumeEvents();

Best Practices और Debugging

दोस्तों, ध्यान देने वाली बात ये है कि जब आप प्रोडक्शन में RabbitMQ यूज़ करते हैं, तो कुछ बातों का ध्यान रखना बहुत ज़रूरी है:

• Error Handling: हमेशा try-catch ब्लॉक का यूज़ करें। अगर कंज्यूमर क्रैश हो गया, तो मैसेज 'Unacknowledged' रह जाएगा।
• Persistent Queues: अगर आप चाहते हैं कि RabbitMQ रीस्टार्ट होने पर भी डेटा न खोए, तो 'durable: true' का उपयोग करें।
• Dead Letter Exchanges: अगर कोई मैसेज प्रोसेस नहीं हो पा रहा, तो उसे सीधा रिजेक्ट न करें, उसे एक 'DLX' में डाल दें ताकि बाद में उसे डीबग किया जा सके।

सामान्य गलतियां

सबसे बड़ी गलती जो मैंने डेवलपर्स को करते देखी है, वह है हर रिक्वेस्ट पर नया कनेक्शन खोलना। याद रखें, 'amqp.connect' बहुत महंगा ऑपरेशन है। हमेशा एक सिंगल कनेक्शन और चैनल को पूरे ऐप में शेयर करें जैसा हमने ऊपर के उदाहरण में किया है।

तो दोस्तों, आज हमने सीखा कि कैसे RabbitMQ का उपयोग करके हम अपने MERN प्रोजेक्ट्स को Event-Driven बना सकते हैं। यह तरीका आपके सिस्टम को बहुत ही scalable बना देगा। प्रैक्टिस करते रहें!