问题标签 [azure-queues]

我目前正在努力在 nServiceBus 托管应用程序上启动并运行某些东西。我有一个 azure ServiceBus 队列，第 3 方正在向其发布消息，并且我希望我的应用程序（目前在本地托管）接收这些消息。

我已经用谷歌搜索了有关如何配置端点的答案，但我在有效配置中没有运气。有没有人这样做过，因为我可以找到如何连接到 Azure 存储队列而不是服务总线队列的示例。（出于其他原因，我需要 azure servicebus 队列）

我的配置如下

. 启动端点时消息=异常，已记录错误。原因：输入队列 [mytimeoutmanager@sb://[ * ].servicebus.windows.net/] 必须与此 Source=NServiceBus.Host 在同一台机器上

.

请建议如何计算 azure 队列中有多少消息

似乎我的问题的解决方案应该比现在更容易，这让我觉得我错过了显而易见的事情。我正在尝试测试并确保远程客户端计算机可以发送/接收来自 Azure 服务总线队列的消息。

我正在使用 Microsoft 在https://www.windowsazure.com/en-us/develop/net/how-to-guides/service-bus-amqp/提供的示例应用程序

只要所有端口都打开，示例应用程序就可以正常工作。但是，当只有端口 80/443 可用时，我需要该解决方案才能工作。如果我将 Windows 防火墙配置为仅允许 80/443 上的入站/出站流量，则它不起作用。我收到错误“试图以访问权限禁止的方式访问套接字”。

示例应用程序中的违规行是：

我查看了非常多的网站，我发现的一个建议是将连接模式设置为 Http，如下所示：

那也行不通。

我没有尝试在远程客户端或 Azure 托管角色上设置自定义服务。我只需要它们都能够通过 Azure 的服务总线队列和主题发送/接收消息。

谁能指出我的缺点？

我需要通过 Azure 队列发送压缩的 Base64 数据，该队列有 64K 的限制。
我的代码压缩数据，然后将其编码为 Base64 字符串。
我验证压缩和编码的字符串不超过 64000 字节（参见下面的 encodedLen），但是，当我尝试添加 ~57,000 字节的消息时，我的代码崩溃了。

我正在使用 Visual Studio 2012 和 .Net 4.5。
我在这里想念什么？

与许多开发人员一样，我正在寻找一种将现有应用程序集成到 SQL Azure 联合的方法，而替换身份列（我的表的主键）是一个大问题。

由于许多原因，我不想将 GUID 用作我的主键（请不要打开关于 GUID 的辩论，这不是我的问题：我只是不想要 GUID，句号）。

因此，我需要构建一个密钥提供程序来替换标准 SQL 数据库的“身份”功能。我正在使用实体框架，所以我可以很容易地找到一个Id在插入之前设置值的地方（通过覆盖SaveChanges我的ObjectContext类的方法）。我只需要找到一个“不太复杂”的实现来获取当前的 ID，即“农场就绪”。

我已经阅读了这篇 SO 帖子：“分片数据库（Azure 联合数据库）的 ID 生成”和“来自 MSDN 杂志的在 Windows Azure 中同步多个节点”，但这个解决方案对我来说听起来有点复杂。

我正在考虑为每个 SQL 表创建（自动）一个 azure 队列，其中包含一个预加载的连续整数列表。当我想要一个 Id 值时，我只需要从队列中获取一条消息（它变得不可见并在途中被删除），这给了我当前可用的 Id。

关于“Windows Azure Queues”和“Windows Azure Service Bus Queues”之间的选择，我更喜欢“Windows Azure Queues”，因为Service Bus Queues 的“高”延迟。我不认为 Azure Queues 缺少“订购保证”是个问题。

您如何看待使用 Azure 队列提供 Id 值的想法？你有没有看到任何放弃这个想法的论据？在 SQL Azure 联合数据库中提供整数 id 是否有更好的想法，甚至是好的做法？谢谢。

编辑 ：

阿斯塔科夫建议使用 SnowMaker。我终于完成了SnowMaker的一个分支，以与 Azure 存储库的 v2 完全兼容。

编辑 2

请注意，Azure SQL Federation 将于 2015 年 9 月停用，包括 Web 层和业务层，如此处所述。但是这个问题对于自定义分片解决方案仍然有效。

我知道有一种方法可以确定 Azure 队列（存储帐户）中的消息数量（或近似数量）；但是有没有办法查询 Azure服务总线队列上的待处理消息的数量？

我们有一项服务将数据放入服务总线队列。我们为此实施了重试策略。但根据 Windows Azure 团队的说法，队列可能会下降 1-3 分钟。所以我们应该有重试策略，应该尝试超过 3 分钟。

如果我们将重试 3 分钟，则等待响应的客户端将超时，因为默认超时为 60 秒。如果我们将增加超时时间，那么客户必须等待 3 分钟以防中断。

实现此方案的最佳方法是什么？

建议？

我想将 Azure 队列用作高负载/大规模 Web 服务的状态机。

客户端将向 Web 服务端点提交请求，此时我将返回请求 ID。

然后我将消息提交到队列，以便工作角色可以处理它，但在提交过程中不会发生数据库活动。相反，我想使用消息所在的队列来表示它的当前状态。

我的问题是，如果一个工作角色从队列中抓取消息来处理它，它在该队列中变得不可见。如果我想检查该消息的处理状态，我有一个模棱两可的消息状态。消息要么丢失/从未收到，要么它在队列中但不可见，因为它正在处理中。

理想情况下，我希望能够在看不见的信息上达到顶峰。如果我找到一个与请求 id 匹配的请求，我知道如果它不可见则正在处理它，或者如果它可见它正在等待处理。显然，我知道它何时完成处理，因为该操作将导致数据库写入。

那么这是否可能，或者我无法查看 Azure 队列中的不可见消息这一事实是否会导致这种情况？

我们有一个要求，我们需要允许潜在的许多用户将一条消息添加到 Azure 队列服务。使用共享访问签名，我们可以允许用户在有限的时间内将消息添加到队列中。但是是否也可以将我们生成的每个 SAS 令牌限制为最多 1 条消息？或者潜在的恶意用户能否在 SAS 令牌生命周期内将无限数量的消息插入队列？

我正在开发一个要部署在 Azure 中的网站。现在我正在使用 Azure 队列向用户发送电子邮件。我通过休眠当前线程每 60 秒检查一次队列是否接收到消息。

我的问题是我不想等待线程并等待 60 秒，而是想在队列实际收到消息时触发消息发送功能。我找到了服务总线主题/订阅的机制，但我想知道我是否可以使用 Azure 队列实现相同的订阅机制（不使用主题/订阅）。这可能吗？Azure 队列是否可以侦听某些内容，以便仅在收到消息到队列时才能运行。我当然不想让线程睡觉。

谢谢你。