Zend_Mail के साथ ईमेल को कतार में लगाने का एक आसान तरीका

सभी को नमस्कार।

मैं Zend_Mail का उपयोग करके ई-मेल कतारों को व्यवस्थित करने के लिए एक बहुत ही सरल और आसान तरीका साझा करना चाहता हूं। लेख में उदाहरण जानबूझकर संभव के रूप में सरल किए गए हैं और फ्रेमवर्क से बंधे नहीं हैं, क्योंकि लेख का उद्देश्य एक विधि दिखाना है, न कि एक विशिष्ट कार्यान्वयन। इसके अलावा, इस समाधान को केवल Zend फ्रेमवर्क के ढांचे के भीतर उपयोग करने की आवश्यकता नहीं है, यह आसानी से किसी भी परियोजना में फिट हो सकता है।

सीधे बिंदु पर जाएं। हमें आवश्यकता होगी:
- डेटाबेस में तालिका;
- परिवहन का वर्ग;
- संदेश भेजने वाले फ़ाइल (मुकुट पर चलाता है)।

सबसे पहले हम डेटाबेस तालिका को परिभाषित करते हैं:

CREATE TABLE email_queue ( id INT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, recipients TEXT NOT NULL, subject CHAR(255) NOT NULL, message TEXT NOT NULL, header TEXT NOT NULL, parameters TEXT, max_attempts TINYINT UNSIGNED NOT NULL DEFAULT 3, attempts TINYINT UNSIGNED NOT NULL DEFAULT 0, is_false TINYINT(1) UNSIGNED NOT NULL DEFAULT 0, in_process INT UNSIGNED DEFAULT NULL DEFAULT 0, time_last_attempt INT UNSIGNED DEFAULT NULL, create_time INT UNSIGNED NOT NULL ); 

अगला, हमारा परिवहन वर्ग बनाएँ:

 class EmailQueueTransport extends Zend_Mail_Transport_Sendmail { /** * Send mail using EmailQueue * * @access public * @return void * @throws Zend_Mail_Transport_Exception If parameters is set but not a string * @throws Zend_Mail_Transport_Exception If failed to add a message in queue */ public function _sendMail() { if ($this->parameters !== null && !is_string($this->parameters)) { /** * Exception is thrown here because $parameters is a public property */ throw new Zend_Mail_Transport_Exception('Parameters were set but are not a string'); } $db = Zend_Db_Table_Abstract::getDefaultAdapter(); $statement = $db->prepare(' INSERT email_queue SET recipients = :recipients, subject = :subject, message = :message, header = :header, parameters = :parameters, create_time = :create_time '); $result = $statement->execute(array( 'recipients' => $this->recipients, 'subject' => $this->_mail->getSubject(), 'message' => $this->body, 'header' => $this->header, 'parameters' => $this->parameters, 'create_time' => time() )); if (!$result) { throw new Zend_Mail_Transport_Exception( 'Failed to add a message in queue.'); } } } 

यह सब जो करता है वह Zend_Mail से तैयार डेटा प्राप्त करता है और इसे डेटाबेस में सहेजता है। यदि तालिका में कोई रिकॉर्ड बनाना विफल रहा, तो Zend_Mail_Transport_Exception को फेंकता है।

खैर, एक फाइल जो संदेश भेजने को लागू करती है, मान लीजिए कि फ़ाइल एक अलग फ़ोल्डर में है, एप्लिकेशन की जड़ में:

 <?php /** * Add the messages in the log * * @param type $message * @return void */ function set_log($message) { $message = date('H:i dmY ', time()) . $message . "\r\n"; $logFile = dirname(__FILE__) . DIRECTORY_SEPARATOR . 'logs' . DIRECTORY_SEPARATOR . basename(__FILE__, '.php') . '.log'; error_log($message, 3, $logFile); } try { $config = include realpath(dirname(__FILE__) . '/../') . '/application/config/config.php'; // Path to config file $configDb = $config['db']['params']; $db = new PDO( 'mysql:host=' . $configDb['host'] . ';dbname=' . $configDb['dbname'], $configDb['username'], $configDb['password'], array( PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8'", 'profiler' => false, ) ); } catch (PDOException $e) { set_log('Connection error: ' . $e->getMessage()); } $limit = 100; // limit rows $processLimitTime = 600; // 10 minutes $statement = $db->query(' SELECT * FROM email_queue WHERE attempts < max_attempts AND in_process < ' . (time() - $processLimitTime) . ' ORDER BY id ASC LIMIT ' . $limit ); $rows = $statement->fetchAll(PDO::FETCH_ASSOC); foreach ($rows as $row) { $db->beginTransaction(); $result = $db->exec(' UPDATE email_queue SET in_process = ' . time() . ' WHERE id = ' . $row['id'] ); if (!$result) { set_log('Error when updating record from the table "email_queue". Id queue is ' . $row['id'] . '.'); continue; } $isSent = mail( $row['recipients'], $row['subject'], $row['message'], $row['header'], $row['parameters'] ); $db->commit(); if ($isSent) { $result = $db->exec('DELETE from email_queue WHERE id = ' . $row['id']); if (!$result) { set_log('Error when deleting record from the table "email_queue". Id queue is ' . $row['id'] . '.'); } } else { $result = $db->exec(' UPDATE email_queue SET is_false = 1, in_process = 0, attempts = ' . ($row['attempts'] + 1) . ' WHERE id = ' . $row['id'] ); if (!$result) { set_log('Error when updating record from the table "email_queue". Id queue is ' . $row['id'] . '.'); } set_log('Error when sending messages to e-mail. Id queue is ' . $row['id'] . ', e-mails is ' . $row['recipients'] . '.'); } } 

कतार उपयोग:

 $mail = new Zend_Mail(); $mail->setFrom($from); $mail->addTo($to); $mail->setBodyHtml($body); $mail->setSubject($subject); $transport = new \EmailQueueTransport(); $mail->send($transport); 

तदनुसार, यदि आपको मेल के माध्यम से एक कतार के बिना एक संदेश भेजने की आवश्यकता है, तो - परिवहन पास न करें या नल पास न करें।

PS शायद कोई इसे Zend_Queue का उपयोग करना अधिक सही मानता है, और शायद यह सही होगा। किसी भी मामले में मेरा दावा नहीं है कि लेख में वर्णित विधि एकमात्र सही निर्णय है। हमेशा कई समाधान होते हैं, मैंने उनमें से सिर्फ एक का वर्णन किया है।

PPS विशेष धन्यवाद marknn और जीन उपयोगकर्ताओं के लिए उपयोगी टिप्पणियों के लिए।