Azure 队列接收 http 请求

Question

我想知道是否可以创建一个 Azure 队列（服务总线或存储队列），它可以放置在 Web 应用程序的前面，并且可以第一时间接收 http 请求。

更新

感谢cmets和答案。

我想在不增加 IIS 负担的情况下处理请求。我需要在队列中的请求到达 IIS 之前对其进行处理。

Answer 1

如果有可能创建一个 Azure 队列（服务总线或存储队列），它可以放置在 Web 应用程序的前面并立即接收 http 请求。

我们可以通过添加一些代码在 Azure Web App 中处理请求之前将请求消息保存到队列中。我编写了一个 C# 版本的示例代码，它将请求消息记录到 Azure 存储队列。以下步骤供您参考。

步骤 1. 将 http 模块添加到您的项目中。在这个模块中，我注册了 HttpApplication 的 BeginRequest 事件并进行了消息记录工作。

public class RequestToQueueModeule : IHttpModule
{
    #region IHttpModule Members

    public void Dispose()
    {
        //clean-up code here.
    }

    public void Init(HttpApplication context)
    {
        // Below is an example of how you can handle LogRequest event and provide 
        // custom logging implementation for it
        context.BeginRequest += new EventHandler(OnBeginRequest);
    }

    #endregion

    public void OnBeginRequest(Object source, EventArgs e)
    {
        HttpApplication context = source as HttpApplication;
        AddMessageToQueue(context.Request);
    }


    public void AddMessageToQueue(HttpRequest request)
    {
        StringBuilder sb = new StringBuilder();
        sb.AppendLine(request.HttpMethod + " " + request.RawUrl + " " + request.ServerVariables["SERVER_PROTOCOL"]);
        for (int i = 0; i < request.Headers.Count; i++)
        {
            sb.AppendLine(request.Headers.Keys[i] + ":" + request.Headers[i]);
        }
        sb.AppendLine();
        if (request.InputStream != null)
        {
            using (StreamReader sr = new StreamReader(request.InputStream))
            {
                sb.Append(sr.ReadToEnd());
            }
        }

        // Retrieve storage account from connection string.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse("connection string of your azure storage");

        // Create the queue client.
        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

        // Retrieve a reference to a queue.
        CloudQueue queue = queueClient.GetQueueReference("queue name which is used to store the request message");

        // Create the queue if it doesn't already exist.
        queue.CreateIfNotExists();

        // Create a message and add it to the queue.
        CloudQueueMessage message = new CloudQueueMessage(sb.ToString());
        queue.AddMessage(message);
    }
}

Step 2. 在web.config的system.webServer节点注册上层模块。请修改您的模块放置的命名空间名称。

<system.webServer>
  <modules runAllManagedModulesForAllRequests="true">
    <add name="RequestToQueueModeule" type="[your namespace name].RequestToQueueModeule" />
  </modules>
</system.webServer>

我想在不增加 IIS 负担的情况下处理请求。我需要在队列中的请求到达 IIS 之前对其进行处理。

如果要在请求到达 IIS 之前处理队列中的请求，则需要在 Azure Web App 前面添加代理。 Azure 应用程序网关用作代理，它可以放在 Web 应用程序的前面。如果您只想记录 HTT 请求的主要信息，您可以使用 Azure 应用程序网关并打开访问日志。欲了解更多信息，下面的链接供您参考。

Diagnostic logs of Application Gateway

如果你想保存所有的请求消息，恐怕你需要构建一个自定义代理并自己记录请求。