[Improvement-16527][alert] Add retry send email validAddresses when abnormal addresses in the email receiving list

dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-email/src/main/java/org/apache/dolphinscheduler/plugin/alert/email/MailSender.java

@@ -44,12 +44,16 @@
 
 import javax.activation.CommandMap;
 import javax.activation.MailcapCommandMap;
+import javax.mail.Address;
 import javax.mail.Authenticator;
 import javax.mail.Message;
 import javax.mail.MessagingException;
 import javax.mail.PasswordAuthentication;
 import javax.mail.Session;
 import javax.mail.Transport;
+import javax.mail.URLName;
+import javax.mail.event.TransportAdapter;
+import javax.mail.event.TransportEvent;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeBodyPart;
 import javax.mail.internet.MimeMessage;
@@ -351,8 +355,8 @@ private void attachContent(String title, String content, String partContent,
         partList.addBodyPart(part1);
         partList.addBodyPart(part2);
         msg.setContent(partList);
-        // 5. send Transport
-        Transport.send(msg);
+        // 5. send email
+        sendMail(msg, msg.getSession());
         // 6. delete saved file
         deleteFile(file);
     }
@@ -361,7 +365,7 @@ private void attachContent(String title, String content, String partContent,
      * the string object map
      */
     private AlertResult getStringObjectMap(String title, String content, AlertResult alertResult,
-                                           HtmlEmail email) throws EmailException {
+                                           HtmlEmail email) throws EmailException, MessagingException {
 
         /*
          * the subject of the message to be sent
@@ -378,13 +382,42 @@ private AlertResult getStringObjectMap(String title, String content, AlertResult
 
         // send
         email.setDebug(true);
-        email.send();
-
+        email.buildMimeMessage();
+        sendMail(email.getMimeMessage(), email.getMailSession());
         alertResult.setSuccess(true);
 
         return alertResult;
     }
 
+    /**
+     * send mail with validAddresses retry
+     *
+     * @param mimeMessage the message
+     * @param session connectSession
+     */
+    private void sendMail(MimeMessage mimeMessage, Session session) throws MessagingException, AlertEmailException {
+        Transport transport = session.getTransport(new SMTPProvider());
+        transport.addTransportListener(new TransportAdapter() {
+            @Override
+            public void messageNotDelivered(TransportEvent event) {
+                Address[] validUnsentAddresses = event.getValidUnsentAddresses();
+                if (validUnsentAddresses == null || validUnsentAddresses.length < 1) {
+                    return;
+                }
+                try {
+                    transport.sendMessage(mimeMessage, validUnsentAddresses);
+                } catch (MessagingException e) {
+                    log.error("send mail with validAddresses failed:{}", e.getMessage());
+                    throw new AlertEmailException("send mail with validAddresses failed", e);
+                }
+            }
+        });
+        URLName urlName = transport.getURLName();
+        transport.connect(urlName.getHost(), urlName.getUsername(), urlName.getPassword());
+        transport.sendMessage(mimeMessage, mimeMessage.getAllRecipients());
+        transport.close();
+    }
+
     /**
      * file delete
      *