使用异步触发并忘记

Question

考虑这段代码：

public async Task<Status> SendMessage(Message message)
{
    List<IMessage> _messageDispatchers = new List<IMessage>();
    try
    {
        Object[] args = new Object[] { _message };
        IMessage endpoint = (IMessage)Activator.CreateInstance(Type.GetType(_message.AgentDLLName), args);
        _messageDispatchers.Add(endpoint);

        foreach (IMessage dispatcher in _messageDispatchers)
        {
            await Task.Run(() => dispatcher.SendMessage(_message));
        }
        return await Task.Run(() => Status.Success);
    }
    catch (Exception ex)
    {
        logger.Log(LoggerLevel.Error, ex.Message);
        return Status.EmailSendingFailed;
    }

}

发送消息：

public async Task<Status> SendMessage(OutboundMessage outboundmessage)
{
    string strMessage = string.Empty;
    string subject = string.Empty;
    MessageServices objService = new MessageServices();
    try
    {
        var config = (from SmtpConfigurationElement ms in AppConfiguration.Instance.Smtps
                      where ms.Key == "smtp"
                      select ms).Single();

        SmtpClient smtpClient = new SmtpClient(config.Host);
        smtpClient.Port = Convert.ToInt32(config.port);
        smtpClient.EnableSsl = true;
        smtpClient.Credentials = new NetworkCredential(config.UserName, config.Password);

        string[] strToList = outboundmessage.ToList.Split(';');
        MailMessage mail = new MailMessage();
        mail.From = new MailAddress(outboundmessage.FromAddress);

        if (strToList.Length > 0)
        {
            for (int j = 0; j < strToList.Length; j++)
            {
                mail.To.Add(strToList[j]);
            }
        }
        else
        {
            _LOGGER.Log(LoggerLevel.Information, "SMTP Mail Send failed as ToList is not correct");
            return Status.Failed;
        }

        if (!string.IsNullOrEmpty(outboundmessage.CCList))
        {
            string[] strCCList = outboundmessage.CCList.Split(';');
            if (strCCList.Length > 0)
            {
                for (int k = 0; k < strCCList.Length; k++)
                {
                    mail.CC.Add(strToList[k]);
                }
            }
        }

        if (!string.IsNullOrEmpty(outboundmessage.Attachments))
        {
            System.Net.Mail.Attachment attachment;
            attachment = new System.Net.Mail.Attachment(outboundmessage.Attachments);
            mail.Attachments.Add(attachment);
        }

        strMessage = await objService.ReplaceMessageWithPlaceholders(outboundmessage.PlaceholderValues, outboundmessage.MessageBody);
        subject = await objService.ReplaceMessageWithPlaceholders(outboundmessage.PlaceholderValues, outboundmessage.Subject);
        mail.Body = strMessage;
        mail.Subject = subject;
        mail.IsBodyHtml = true;
        await Task.Run(() => smtpClient.Send(mail));


        return Status.Success;
    }
    catch (Exception ex)
    {
        return Status.Failed;
    }
}

以及对 SendMessage 的调用：

public Status MarketingEmail(OutboundMessage _message)
{
    try
    {
        _message.MessageCreatedDate = System.DateTime.Now;
        processor.SendMessage(_message);
        return Status.Success;
    }
    catch (Exception ex)
    {
        _LOGGER.Log(LoggerLevel.Error, "Error in Marketing Email" + ex.ToString());
        return Status.InsertFailed;
    }
}

整个想法是创建一个工作流程，其中发送电子邮件是最后一项任务，这应该是一劳永逸的事情。

现在对 processor.SendMessage(_message) 的调用有这样的建议：

因为没有等待这个调用，所以执行当前方法 在呼叫完成之前继续。考虑应用“等待” 调用结果的运算符。

这是一个有效的东西，因为 async 和 await 需要一起使用。

问题：

1. 如果忽略该建议，当前的方法是否会正常工作？ （我之所以问这个问题，是因为它仍处于开发阶段，我现在可以进行建议的设计更改，而不是以后面对任何关键问题。）
2. 考虑到上述要求，在设计工作流时建议的最佳做法是什么？

Answer 1

当前的方法将“有效”，因为它将继续到 return Status.Success;，而无需等待对 processor.SendMessage(_message); 的调用完成。

但是，由于该调用已被触发并被遗忘，并且 SendMessage 过载不会在 catch 块中进行任何登录，因此您将面临电子邮件发送失败但没有人收到通知的风险。

异步电子邮件发送的常用方法是：将电子邮件存放在其他地方（通常是消息队列或数据库），然后设置一个单独的异步进程来读取排队的电子邮件并发送它们。如果成功，它会将电子邮件标记为已发送。如果失败，它会再次尝试（直到某个时间限制或重试次数），然后如果它放弃，它可以触发通知或设置一个以后可以检查的标志。

然后您的代码基本上会说“好的，电子邮件已成功排队”，而不是“好的，电子邮件已发送”。将实际发送移至单独的进程更加可靠。