c# – Azure Web角色中的后台线程

>大卫的解决方案没问题,但没有弹性.实例/进程在处理任务时脱机的是什么？
> Leon的解决方案主要适用于预定的工作,但发送电子邮件并不总是预定的(也许您希望在有人在您的应用程序中注册时发送电子邮件).

您应该看到的另一个选项是在此方案中使用Windows Azure存储队列(它们非常便宜)：

>您的Web应用程序：将消息发送到队列(例如“发送电子邮件到someone@someone.com”)
> WebRole.cs：在启动实例时生成一个新线程,并让它侦听来自该队列的消息.每当消息到达时,处理它.如果成功,请从队列中删除该消息.

该解决方案具有许多优点. WebRole.cs在与Web应用程序不同的进程中运行,因此对请求线程没有影响.除此之外,如果由于某种原因发送邮件失败,邮件将保留在队列中并在下次处理.如果应用程序或进程崩溃,这将确保您不会丢失任何要执行的任务.

这是一个让你入门的例子.请注意,如果您希望生成就绪,则需要改进此代码(重试策略,异常处理,退避轮询,…)：

using System;
using System.Collections.Generic;
using System.Linq;
using Microsoft.WindowsAzure;
using Microsoft.WindowsAzure.Diagnostics;
using Microsoft.WindowsAzure.ServiceRuntime;
using Microsoft.WindowsAzure.StorageClient;
using System.Threading.Tasks;

namespace MvcWebRole1
{
    public class WebRole : RoleEntryPoint
    {
        public override bool OnStart()
        {
            Task.Factory.StartNew(InitializeQueueListener);
            return base.OnStart();
        }

        private void InitializeQueueListener()
        {
            Microsoft.WindowsAzure.CloudStorageAccount.SetConfigurationSettingPublisher((configName,configSetter) =>
            {
                configSetter(Microsoft.WindowsAzure.ServiceRuntime.RoleEnvironment.GetConfigurationSettingValue(configName));
            });


            var storageAccount = CloudStorageAccount.FromConfigurationSetting("DataConnectionString");
            var queueStorage = storageAccount.CreateCloudQueueClient();
            var queue = queueStorage.GetQueueReference("myqueue");
            queue.CreateIfNotExist();

            while (true)
            {
                CloudQueueMessage msg = queue.GetMessage();
                if (msg != null)
                {
                    // DO SOMETHING HERE
                    queue.DeleteMessage(msg);
                }
                else
                {
                    System.Threading.Thread.Sleep(1000);
                }
            }
        }
    }
}