我在MySQL数据库中有一个电子邮件队列,通过cron我每分钟处理X条未发送的电子邮件。我的问题是,如果任何特定的电子邮件失败,它将停止执行其余电子邮件。在一种情况下,这是由于SMTP身份验证失败而导致的,由于发送失败电子邮件的尝试不断发生,电子邮件处理基本上停止了。swiftmailer还有其他我应该知道的失败方法吗?
我想知道我在这里可以做些什么来使此循环更安全?如果任何一封电子邮件失败,我想用错误代码(我的或swiftmailers)标记数据库中的记录。
Swiftmailer不是我们发送电子邮件的唯一方法,以下方法是驱动程序的一部分。有什么解决方案?
public function process_queue()
{
$result = [... a few mail queue records ...];
foreach( $result as $params )
{
if( ! class_exists( 'Swift', FALSE ) )
{
require '/libraries/Mail/swiftmailer/lib/swift_required.php';
}
// Prepare transport for sending mail through SMTP
if( $params['protocol'] == 'smtp' )
{
$transport = Swift_SmtpTransport::newInstance( $params['smtp_host'], $params['smtp_port'] )
->setUsername( $params['smtp_user'] )
->setPassword( $params['smtp_pass'] );
}
// Prepare transport for simple mail sending
else
{
$transport = Swift_MailTransport::newInstance();
}
// Prepare swiftmailer mailer object
$mailer = Swift_Mailer::newInstance( $transport );
// Get a new message instance, and apply its attributes
$message = Swift_Message::newInstance()
->setSubject( $params['subject'] )
->setFrom( [ $params['from_email'] => $params['from_name'] ] )
->setTo( $params['to'] )
->setBody( $params['body'], $params['mailtype'] );
$mailer->send( $message );
}
}
您可以将send放在一个try-catch
块中,并在循环完成后处理所有异常。
try {
$mailer->send($message);
} catch(Exception $exception) {
// do something with $exception that contains the error message
}
或者,您可以将第二个参数添加到send
并利用失败。
// Pass a variable name to the send() method
if (!$mailer->send($message, $failures))
{
// do something with $failures that contains the error message
}
另外,如果setTo
由于无效的电子邮件地址而失败,Swift将返回一个错误,因此,不用链接来构建消息,您可以分别执行每种方法并捕获/处理任何错误。
try {
$message->setTo($params['to']);
} catch(Swift_RfcComplianceException $e) {
echo "The email ".$params['to']." seems invalid";
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句