Jak zamknąć połączenie Smtp w SwiftMailer

Question

Używam SwiftMailer do wysyłania wiadomości e-mail z procesu pracownika gearman. Używam klasy Swift_SmtpTransport do wysyłania e-maili.

Problem polega na tym, że jeśli ten proces roboczy nie będzie działał przez jakiś czas, upłynie czas połączenia smtp SwiftMailer. Teraz, gdy pojawia się następne zadanie, SwiftMailer nie wysyła wiadomości e-mail, gdy upłynął limit czasu połączenia.

Idealnie chciałbym zamknąć połączenie smtp po każdym zadaniu. Nie mogę znaleźć api w klasie, która robi to specjalnie. Nie działa też obiekt unset(), ponieważ jest to klasa statyczna.

Answer 1

biegnę pracownika w nieskończonej pętli przy użyciu Swiftmailer i AWS SES byłem coraz błąd:

Expected response code 250 but got code "421", with message "421 Timeout waiting for data from client. 

rozwiązanie dla mojego skryptu:

$love = true; 
while($love) { 
    $message = Message::to($record->to) 
     ->from(array('no-reply@clouddueling.com' => $user->name())) 
     ->reply(array($user->email => $user->name())) 
     ->subject($record->subject) 
     ->body($body->value) 
     ->html(true) 
     ->send(); 

    if (! $message->was_sent()) 
     throw new Swift_TransportException($errstr . ': ' . $errno); 
} 

Answer 2

Mam ten sam wyjątek z Wiersz poleceń symfony2 podczas wysyłania dużej ilości wiadomości e-mail przy użyciu SwiftMailer i AWS SES.

Mogę naprawić mój problem, uruchamiając i zatrzymując warstwę transportu za każdym razem. Zajrzyj do mojego posta na blogu, aby uzyskać więcej informacji: http://www.prowebdev.us/2013/06/swiftmailersymfony2-expected-response.html

Answer 3

Istnieje nieuprzejma opcja: zatrzymaj transport jawnie. Podczas kolejnych wywołań metody sendMail, SwiftMailer sprawdzi, czy transport jest w górze (to nie jest, teraz) i uruchom go ponownie. IMNSHO, SwiftMailer powinien przechwytywać czas oczekiwania SMTP i ponownie automatically.But, na razie, jest to obejście:

function sendMail($your_args) { 
    try{ 
     $mailer = Swift_Mailer::newInstance($transport); 
     $message = Swift_Message::newInstance('Wonderful Subject') 
     ->setFrom(array('john@doe.com' => 'John Doe')) 
     ->setTo(array('receiver@domain.org', 'other@domain.org' => 'A name')) 
     ->setBody('Here is the message itself'); 

     $result = $mailer->send($message); 
     $mailer->getTransport()->stop(); 

    } catch (Swift_TransportException $e) { 
     //this should be caught to understand if the issue is on transport 
    } catch (Exception $e) { 
     //something else happened 
    } 

} 

Answer 4

mogę wysyłać maili w pętli, a ja łapanie Swift_TransportException i tworzenie nowej instancji Swift_Mailer ale To nie była właściwa poprawka: problemem jest transport , a nie mailer. Rozwiązaniem jest wydać wyraźne wezwanie do Swift_SmtpTransport::stop():

foreach($recipients as $to => $body){ 
    try{ 
     $message->setTo($to); 
     $message->setBody(body); 
     $mailer->send($message); 
    }catch(Swift_TransportException $e){ 
     $mailer->getTransport()->stop(); 
     sleep(10); // Just in case ;-) 
    } 
} 

ten sposób wykrywa Swift Mailer jest zatrzymany i uruchamia go automatycznie, dzięki czemu odzyskuje poprawnie z błędów komunikacyjnych.

Answer 5

Kiedy rura jest uszkodzona, $ mailer-> getTransport() -> stop() również się nie powiedzie. A z powodu tego błędu transport nie może zostać zatrzymany. Rozwiązaniem jest

// Let's try to send an email. 
$tries = 3; 
while ($tries--) { 
    try { 
     $sent = $this->mailer->send($message); 
     break; 
    } catch (\Exception $e) { 
     // Connection problems 
     // @see https://github.com/swiftmailer/swiftmailer/issues/490 
     try { 
      // Try to stop 
      $this->mailer->getTransport()->stop(); 
     } catch (\Exception $e) { 
      // Got Exception while stopping transport. 
      // We have to set _started to 'false' manually, because due to an exception it is 'true' now. 
      $t = $this->mailer->getTransport(); 
      $reflection = new \ReflectionClass($t); 
      $prop = $reflection->getProperty('_started'); 
      $prop->setAccessible(true); 
      $prop->setValue($t, false); 
      $prop->setAccessible(false); 
     } 
    } 
}