Node.js और Redis के साथ संदेश कतारों में महारत हासिल करना:वेब ऐप प्रदर्शन को बढ़ावा देना

कतार क्या है?

नौकरी क्या है?

जॉब प्रोड्यूसर क्या है?

कर्मचारी (नौकरी उपभोक्ता) क्या है?

असफल नौकरियाँ क्या हैं?

• अमान्य या अनुपलब्ध इनपुट डेटा:जब किसी कार्य को संसाधित करने के लिए आवश्यक डेटा अनुपलब्ध है, तो कार्य विफल हो जाएगा। उदाहरण के लिए, ईमेल भेजने का कार्य प्राप्तकर्ता के ईमेल पते के बिना विफल हो जाएगा।
• टाइमआउट:यदि कोई कार्य सामान्य से अधिक समय ले रहा है तो कतार तंत्र द्वारा विफल हो सकता है। यह नौकरी की निर्भरता या किसी अन्य मुद्दे के कारण हो सकता है, लेकिन आम तौर पर आप नहीं चाहते कि एक भी नौकरी हमेशा के लिए चलती रहे।
• नेटवर्क या बुनियादी ढांचे की समस्याएं:ये समस्याएं लगभग आपके नियंत्रण से बाहर हैं, लेकिन ये होती हैं। उदाहरण के लिए, डेटाबेस कनेक्शन त्रुटि से कोई कार्य विफल हो जाएगा।
• निर्भरता के मुद्दे:कभी-कभी कोई नौकरी अच्छी तरह से काम करने के लिए कुछ बाहरी संसाधनों पर निर्भर होती है। जब भी ये अन्य संसाधन अनुपलब्ध या असफल होंगे, तो कार्य विफल हो जाएगा।

क्यूज़ का उपयोग करने वाला एक सरल एप्लिकेशन कैसे बनाएं

एक नया Node.js प्रोजेक्ट बनाएं

mkdir nodejs-queue-project
cd nodejs-queue-project
npm init -y

{
 "name": "nodejs-queue-project",
 "version": "1.0.0",
 "description": "",
 "main": "index.js",
 "scripts": {
 "test": "echo \"Error: no test specified\" && exit 1"
 },
 "keywords": [],
 "author": "",
 "license": "ISC"
}

आवश्यक निर्भरताएँ स्थापित करें

npm i express @types/express @types/node body-parser ts-node ts-lint typescript nodemon nodemailer @types/nodemailer

{
 "name": "nodejs-queue-project",
 "version": "1.0.0",
 "description": "",
 "main": "index.js",
 "scripts": {
 "dev": "nodemon src/app.ts"
 },
 "keywords": [],
 "author": "",
 "license": "ISC",
 "dependencies": {
 "@types/express": "^4.17.17",
 "@types/node": "^20.3.3",
 "@types/nodemailer": "^6.4.8",
 "body-parser": "^1.20.2",
 "express": "^4.18.2",
 "nodemailer": "^6.9.3",
 "nodemon": "^2.0.22",
 "ts-lint": "^4.5.1",
 "ts-node": "^10.9.1",
 "typescript": "^5.1.6"
 }
}

एंडपॉइंट कैसे बनाएं

import express from "express";
import bodyParser from "body-parser";
import nodemailer from "nodemailer";
const app = express();
app.use(bodyParser.json());
app.post("/send-email", async (req, res) => {
 const { from, to, subject, text } = req.body;
 // Use a test account as this is a tutorial
 const testAccount = await nodemailer.createTestAccount();
 const transporter = nodemailer.createTransport({
 host: "smtp.ethereal.email",
 port: 587,
 secure: false,
 auth: {
 user: testAccount.user,
 pass: testAccount.pass,
 },
 tls: {
 rejectUnauthorized: false,
 },
 });
 console.log("Sending mail to %s", to);
 let info = await transporter.sendMail({
 from,
 to,
 subject,
 text,
 html: `<strong>${text}</strong>`,
 });
 console.log("Message sent: %s", info.messageId);
 console.log("Preview URL: %s", nodemailer.getTestMessageUrl(info));
 res.json({
 message: "Email Sent",
 });
});
app.listen(4300, () => {
 console.log("Server started at http://localhost:4300");
});

कतार कैसे बनाएं

npm i bull @types/bull

// This goes at the top of your file
import Bull from 'bull';
const emailQueue = new Bull("email");

const emailQueue = new Bull("email", {
 redis: "localhost:6379",
});

type EmailType = {
 from: string;
 to: string;
 subject: string;
 text: string;
};
const sendNewEmail = async (email: EmailType) => {
 emailQueue.add({ ...email });
};

app.post("/send-email", async (req, res) => {
 const { from, to, subject, text } = req.body;
 await sendNewEmail({ from, to, subject, text });
 console.log("Added to queue");
 res.json({
 message: "Email Sent",
 });
});

नौकरियों को कैसे संसाधित करें

const processEmailQueue = async (job: Job) => {
 // Use a test account as this is a tutorial
 const testAccount = await nodemailer.createTestAccount();
 const transporter = nodemailer.createTransport({
 host: "smtp.ethereal.email",
 port: 587,
 secure: false,
 auth: {
 user: testAccount.user,
 pass: testAccount.pass,
 },
 tls: {
 rejectUnauthorized: false,
 },
 });
 const { from, to, subject, text } = job.data;
 console.log("Sending mail to %s", to);
 let info = await transporter.sendMail({
 from,
 to,
 subject,
 text,
 html: `<strong>${text}</strong>`,
 });
 console.log("Message sent: %s", info.messageId);
 console.log("Preview URL: %s", nodemailer.getTestMessageUrl(info));
 return nodemailer.getTestMessageUrl(info);
};

LRANGE bull:email:wait 0 -1

emailQueue.process(processEmailQueue);

import express from "express";
import bodyParser from "body-parser";
import nodemailer from "nodemailer";
import Bull, { Job } from "bull";
const app = express();
app.use(bodyParser.json());
const emailQueue = new Bull("email", {
 redis: "localhost:6379",
});
type EmailType = {
 from: string;
 to: string;
 subject: string;
 text: string;
};
const sendNewEmail = async (email: EmailType) => {
 emailQueue.add({ ...email });
};
const processEmailQueue = async (job: Job) => {
 // Use a test account as this is a tutorial
 const testAccount = await nodemailer.createTestAccount();
 const transporter = nodemailer.createTransport({
 host: "smtp.ethereal.email",
 port: 587,
 secure: false,
 auth: {
 user: testAccount.user,
 pass: testAccount.pass,
 },
 tls: {
 rejectUnauthorized: false,
 },
 });
 const { from, to, subject, text } = job.data;
 console.log("Sending mail to %s", to);
 let info = await transporter.sendMail({
 from,
 to,
 subject,
 text,
 html: `<strong>${text}</strong>`,
 });
 console.log("Message sent: %s", info.messageId);
 console.log("Preview URL: %s", nodemailer.getTestMessageUrl(info));
};
emailQueue.process(processEmailQueue);
app.post("/send-email", async (req, res) => {
 const { from, to, subject, text } = req.body;
 await sendNewEmail({ from, to, subject, text });
 console.log("Added to queue");
 res.json({
 message: "Email Sent",
 });
});
app.listen(4300, () => {
 console.log("Server started at http://localhost:4300");
});

सारांश