使用 javax.mail 发送大邮件，部分邮件发送失败

我正在使用 javax.mail 从我的 SMTP 服务器向用户发送大量电子邮件（大约 1000 封），该服务器拥有我的域。并且所有收件人都在同一域电子邮件中。

发送邮件时，如果只有成功，那么我将令牌保存在 userToken 表中。否则我不会将令牌保存在表中。该过程完成后，userToken 表插入了 950 行，这意味着所有电子邮件都成功。

我编写了以下代码来发送批量电子邮件，但用户没有收到近 300 封电子邮件。执行时我没有收到任何错误，

@RequestMapping(value = "bulkMail")
public  @ResponseBody  String bulkMail(Model model, HttpServletRequest request,@RequestParam(value="myArray") Long[] myArray, HttpServletResponse response) throws IOException {
    Session session = null;
    EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory("roca");
    EntityManager entityManager = entityManagerFactory.createEntityManager();
    entityManager.getTransaction().begin();
    HttpSession httpSession = request.getSession(false);
    session = getRocaSession();
    Test test = (Test) httpSession.getAttribute("test");

    for (int i = 0; i < myArray.length; i++) {
        User user = entityManager.createQuery( "SELECT u FROM User u where u.userId=" + myArray[i], User.class).getSingleResult();

        UserToken userToken;
        try {
            userToken = entityManager.createQuery("SELECT ut FROM UserToken ut where ut.testId="+test.getId()+" and ut.userId="+myArray[i], UserToken.class).getSingleResult();
        } catch (Exception e) {
            userToken = new UserToken();
        }

        String mailStatus = sendMail(userToken,test,request, user.getUserId(),  user.getUserName(), context, user.getEmailId(),session);
        if (!mailStatus.equals("failure")) {
            userToken.setToken(mailStatus);
            userToken.setCreatedDate(new Date());
            userToken.setUpdatedDate(new Date());
            userToken.setTestId(test.getId());
            userToken.setUserId(user.getUserId());
            userToken.setUsed(0);
            testDao.saveOrUpdate(userToken);
        }
    }
    entityManager.getTransaction().commit();
    entityManager.close();
    return "Emails have been send to Users";
}

发送电子邮件

public String sendMail(UserTestToken userTestToken, Test test,HttpServletRequest request, Long accountId,String accountName,
        String context,String accountEmail,Session session) {
    String token = getToken();
    try {
        String email = mailService.sendAlert(test, accountEmail,"User Triger", "[email protected]", "Val", accountId, token, context, accountName, session);
        if (!email.equals("failure")) {
            return token;
        }else {
            return "failure";
        }
    } catch (Exception e) {
        return "failure";
    }       
}

获取电子邮件的会话

public Session getSession() {
    Properties props = new Properties();
    props.put("mail.smtp.auth", "false");
    props.put("mail.smtp.host", "gatesmtp.moc.domain.com");
    props.put("mail.smtp.port", "25");
    Session session = Session.getInstance(props);
    session.setDebug(false);
    return session;
}

邮件服务实现

public String sendTestMailAlert(Test test, String accountEmail, String receiverName, String senderEmail, String url, Long accountId, String token, String context, String       accountName, Session session)
{
    String subject = "Subject";
    String content = "Content";
    return sendMail(accountEmail, content, subject, receiverName, senderEmail, session);
}


private String sendMail(String receiverMailIds, String content, String subject, String employeeName, String employeeEmail, Session session) {
    try {
        Message message = new MimeMessage(session);
        try {
            message.setFrom(new InternetAddress(employeeEmail, employeeName));
        } catch (UnsupportedEncodingException e) {
            this.logger.error("Mail service address catch UnsupportedEncodingException");
        }
        message.setRecipients(Message.RecipientType.TO, InternetAddress.parse(receiverMailIds));
        message.setSubject(subject);
        message.setContent(content, "text/html");
        Transport.send(message);
        return "success";
    } catch (Exception e) {
        this.logger.error("Mail Exception - " + receiverMailIds);
    }
    return "failure";
}