2

对于 Windows azure 队列，每个存储的可扩展性目标应该是大约 500 条消息/秒 ( http://msdn.microsoft.com/en-us/library/windowsazure/hh697709.aspx )。我有以下简单的程序，它只是将一些消息写入队列。该程序需要 10 秒才能完成（4 条消息/秒）。我正在从虚拟机内部（在西欧）运行该程序，并且我的存储帐户也位于西欧。我没有为我的存储设置异地复制。我的连接字符串设置为使用 http 协议。

       // http://blogs.msdn.com/b/windowsazurestorage/archive/2010/06/25/nagle-s-algorithm-is-not-friendly-towards-small-requests.aspx
        ServicePointManager.UseNagleAlgorithm = false;

        CloudStorageAccount storageAccount=CloudStorageAccount.Parse(ConfigurationManager.AppSettings["DataConnectionString"]);

        var cloudQueueClient = storageAccount.CreateCloudQueueClient();

        var queue = cloudQueueClient.GetQueueReference(Guid.NewGuid().ToString());

        queue.CreateIfNotExist();
        var w = new Stopwatch();
        w.Start();
        for (int i = 0; i < 50;i++ )
        {
            Console.WriteLine("nr {0}",i);
            queue.AddMessage(new CloudQueueMessage("hello "+i));    
        }

        w.Stop();
        Console.WriteLine("elapsed: {0}", w.ElapsedMilliseconds);
        queue.Delete();

知道如何获得更好的性能吗？

编辑：

根据 Sandrino Di Mattia 的回答，我重新分析了我最初发布的代码，发现它不够完整，无法重现错误。事实上，我在调用 ServicePointManager.UseNagleAlgorithm = false; 之前创建了一个队列。重现我的问题的代码看起来更像这样：

        CloudStorageAccount storageAccount=CloudStorageAccount.Parse(ConfigurationManager.AppSettings["DataConnectionString"]);

        var cloudQueueClient = storageAccount.CreateCloudQueueClient();

        var queue = cloudQueueClient.GetQueueReference(Guid.NewGuid().ToString());

        //ServicePointManager.UseNagleAlgorithm = false; // If you change the nagle algorithm here, the performance will be okay.
        queue.CreateIfNotExist();
        ServicePointManager.UseNagleAlgorithm = false; // TOO LATE, the queue is already created without 'nagle'
        var w = new Stopwatch();
        w.Start();
        for (int i = 0; i < 50;i++ )
        {
            Console.WriteLine("nr {0}",i);
            queue.AddMessage(new CloudQueueMessage("hello "+i));    
        }

        w.Stop();
        Console.WriteLine("elapsed: {0}", w.ElapsedMilliseconds);
        queue.Delete();

Sandrino 建议的使用 app.config 文件配置 ServicePointManager 的解决方案的优点是 ServicePointManager 在应用程序启动时被初始化，因此您不必担心时间依赖性。

4

2 回答 2

10

几天前我回答了一个类似的问题：如何使用 azure storage tables 实现每秒更多 10 次插入。

在表存储中添加 1000 个项目需要 3 多分钟，而随着我在回答中描述的更改，它下降到 4 秒（250 个请求/秒）。最后，表存储和存储队列并没有什么不同。后端是相同的，数据只是以不同的方式存储。而且表存储和队列都通过 REST API 公开，因此如果您改进处理请求的方式，您将获得更好的性能。

最重要的变化：

  • expect100Continue： 错误的
  • useNagleAlgorithm: false （你已经这样做了）
  • 并行请求结合connectionManagement/maxconnection
于 2012-10-16T13:44:12.323 回答
1

此外，ServicePointManager.DefaultConnectionLimit 应在创建服务点之前增加。实际上 Sandrino 的回答说的是同样的事情，但使用的是 config.

即使在云中也关闭代理检测。在代理配置元素中自动检测。减慢初始化。

选择分布式分区键。

将您的帐户配置在计算和客户附近。

设计以根据需要添加更多帐户。

截至 2012 年 7 月，Microsoft 将队列和表的 SLA 设置为 2,000 tps。

抱歉，我没有阅读 Sandrino 的链接答案，只是在这个问题上，因为我正在观看 Build 2012 会议。

于 2013-02-22T20:21:39.670 回答