4

我有一个 Windows 服务，它使用 Entity Framework 5 从数据库中的队列中读取电子邮件，然后使用 System.Net.Mail.SmtpClient 将它们发送到 SMTP 服务器

这是我第一次尝试编写 F# 应用程序，我来自 C# 背景。如何改进它以提供更多功能和/或更充分地利用 F# 的特性？你能解释一下做出这些改变有什么好处吗？

worker 由服务宿主构建，服务启动时调用它的工作函数，服务停止时将 ContinueWorking 设置为 false。

namespace EmailService

open log4net

open System
open System.Linq
open System.Net.Mail

open EmailService.Context

type Worker(contextFactory: EmailContextFactory, mailClient: ISmtpClient, logger: ILog) =

    let MapToMessage(email : Email) =
        let message = new MailMessage()
        message.Sender <- new MailAddress(email.From)
        message.From <- new MailAddress(email.From)
        message.Subject <- email.Subject
        message.Body <- email.Body
        message.IsBodyHtml <- email.IsBodyHtml
        message.To.Add(email.To)
        (email, message)

    member val ContinueWorking = true with get, set
    member this.Work() = 
        logger.Info "Starting work"

        let mutable unsentEmails = Array.empty<Email>
        while this.ContinueWorking do

            use context = contextFactory.GetEntities()
            while this.ContinueWorking && Array.isEmpty unsentEmails do
                System.Threading.Thread.Sleep(1000)
                unsentEmails <- query { for q in context.QueueItems do
                                           where (q.Error = null)
                                           select q.Email }
                                |> query.Take(10)
                                |> query.toArray

            Array.map MapToMessage unsentEmails
                |> Array.iter (fun (email, message) -> 
                    try
                        mailClient.SendMail(message)
                        email.DateSent <- new Nullable<DateTime>(DateTime.UtcNow)
                        context.QueueItems.Remove(email.QueueItem) |> ignore
                    with
                        | ex -> 
                            logger.Error(ex)
                            email.QueueItem.Error <- ex.ToString())

            context.SaveChanges() |> ignore
            logger.Info (sprintf "Sent %d emails" unsentEmails.Length)



        logger.Info "Work complete"
4

1 回答 1

5

该Work方法创建了一个最终需要停止的长时间运行的进程。在 F# 中表示这一点的更好方法是使用异步工作流 - 可以在不阻塞线程的情况下暂停异步工作流（因此您不需要Thread.Sleep），并且可以使用CancellationToken.

否则，您的代码对我来说看起来不错。我做了一些小的改动（比如take在 F# 查询语法中的使用，这是一个不错的小功能）。

我也不太明白为什么你的代码有两个嵌套while循环。那有必要吗？如果不是，我认为您可以编写如下内容：

member this.Work() = async {
    logger.Info "Starting work"
    while true do
        do! Async.Sleep(1000)
        use context = contextFactory.GetEntities()
        let unsentEmails =
          query { for q in context.QueueItems do
                  where (q.Error = null)
                  select q.Email 
                  take 10 }
        unsentEmails
        |> Array.map MapToMessage 
        |> Array.iter (fun (email, message) -> 
                try
                    mailClient.SendMail(message)
                    email.DateSent <- new Nullable<DateTime>(DateTime.UtcNow)
                    context.QueueItems.Remove(email.QueueItem) |> ignore
                with ex ->
                     logger.Error(ex)
                     email.QueueItem.Error <- ex.ToString())
        context.SaveChanges() |> ignore
        logger.Info (sprintf "Sent %d emails" unsentEmails.Length)
    logger.Info "Work complete" }

要启动该过程（并稍后停止），您可以编写如下内容：

// Start the work
let cts = new CancellationTokenSource()
Async.Start(worker.Work(), cts.Token)

// Stop the worker
cts.Cancel()
于 2012-11-22T12:54:53.643 回答