support send email with SMTPSSLTransport

apolloconfig · Nov 15, 2023 · d3d338e · d3d338e
1 parent 6812a1a
commit d3d338e
Show file tree

Hide file tree

Showing 2 changed files with 49 additions and 0 deletions.
diff --git a/...portal/src/main/java/com/ctrip/framework/apollo/portal/component/config/PortalConfig.java b/...portal/src/main/java/com/ctrip/framework/apollo/portal/component/config/PortalConfig.java
@@ -223,6 +223,10 @@ public String emailConfigHost() {
     return getValue("email.config.host", "");
   }
 
+  public Boolean emailConfigUseSsl() {
+    return getBooleanProperty("email.config.useSsl", false);
+  }
+
   public String emailConfigUser() {
     return getValue("email.config.user", "");
   }

diff --git a/.../src/main/java/com/ctrip/framework/apollo/portal/spi/defaultimpl/DefaultEmailService.java b/.../src/main/java/com/ctrip/framework/apollo/portal/spi/defaultimpl/DefaultEmailService.java
@@ -20,6 +20,7 @@
 import com.ctrip.framework.apollo.portal.entity.bo.Email;
 import com.ctrip.framework.apollo.portal.spi.EmailService;
 import com.ctrip.framework.apollo.tracer.Tracer;
+import com.sun.mail.smtp.SMTPSSLTransport;
 import com.sun.mail.smtp.SMTPTransport;
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
@@ -49,6 +50,50 @@ public void send(Email email) {
       return;
     }
 
+    Boolean useSsl = portalConfig.emailConfigUseSsl();
+    if (useSsl) {
+      sendWithSsl(email);
+    } else {
+      sendWithoutSsl(email);
+    }
+  }
+
+  private void sendWithSsl(Email email) {
+    SMTPSSLTransport t = null;
+    try {
+      Properties prop = System.getProperties();
+      Session session = Session.getInstance(prop, null);
+
+      Message msg = new MimeMessage(session);
+      msg.setFrom(new InternetAddress(email.getSenderEmailAddress()));
+      msg.setRecipients(Message.RecipientType.TO, InternetAddress.parse(email.getRecipientsString(), false));
+      msg.setSubject(email.getSubject());
+      msg.setDataHandler(new DataHandler(new HTMLDataSource(email.getBody())));
+
+      String host = portalConfig.emailConfigHost();
+      String user = portalConfig.emailConfigUser();
+      String password = portalConfig.emailConfigPassword();
+
+      t = (SMTPSSLTransport) session.getTransport("smtps");
+      t.connect(host, user, password);
+      msg.saveChanges();
+      t.sendMessage(msg, msg.getAllRecipients());
+      logger.debug("email response: {}", t.getLastServerResponse());
+    } catch (Exception e) {
+      logger.error("send email failed.", e);
+      Tracer.logError("send email failed.", e);
+    } finally {
+      if (t != null) {
+        try {
+          t.close();
+        } catch (Exception e) {
+          // nothing
+        }
+      }
+    }
+  }
+
+  private void sendWithoutSsl(Email email) {
     SMTPTransport t = null;
     try {
       Properties prop = System.getProperties();