问题标签 [azure-servicebus-topics]

我正在使用 Azure 服务总线主题，但遇到了一个奇怪的问题。

在下面的代码中，我尝试删除订阅（如果存在），然后再次创建它。但是，调用SubsciptionExists返回 false，但随后调用CreateSubscription失败并出现 409 冲突，表明订阅已经存在。

我究竟做错了什么？

此外，如果我查看管理门户中的订阅列表，我看不到我尝试删除并重新创建的订阅。

我在窗口服务器的服务总线上相当新。我想在服务总线订阅中注册一个 .asmx Web 服务，这样如果服务总线中出现任何新消息，服务总线将自动调用 Web 服务。这可能吗？这类似于服务总线中的绑定吗？

提前致谢！！

我有一个使用 Azure 服务总线主题和服务总线队列运行的水平事件源驱动应用程序。我的所有服务器都通过主题接收了一些用于建立我的域模型状态的事件，而队列中的事件（接收频率更高且不改变域模型状态的事件）在服务器之间分发，以便分发加载。

现在，每次我的一个服务器通过队列或主题接收到一个事件时，它都会将它存储在一个 DocumentDB 中，用作事件存储。

现在问题来了。如何确定同一个文档不会被插入两次？假设 3 个服务器接收相同的事件。他们都试图存储它。如果他们决定同时执行所有操作，我怎样才能使其失败 2 台服务器？是否可以在 DocumentDB 中设置任何形式的唯一约束或某种事务范围以防止文档被插入两次？

在使用 Service Bus for Windows Server 时，我包含的所有异常TrackingId。我该如何使用它？

异常样本：

[Microsoft.ServiceBus.Messaging.NoMatchingSubscriptionException] = {“没有为 MessageId 'a4f83bca6f7e49f691ac9953ac121689' 的消息找到匹配的订阅。TrackingId : 048fcfab-ed16-4453-a897-903f3777dc87_GAmrVM-VS_BAmrVM-VS,TimeStamp:8// 2015 年下午 1:36:35"}

注意：我深入 [SBMessageContainer0X] Db 没有任何结果

“如何将 Azure 服务总线与 WebJobs SDK 一起使用”Azure 文档文章显示了使用[ServiceBusTrigger]属性来集成 WebJob 和 Azure 服务总线主题消息。但是，使用 Visual Studio 2015 中的默认 Azure WebJobs 项目模板，对 ServiceBusTrigger 的引用会导致以下编译时异常：

找不到类型或命名空间名称“ServiceBusTrigger”（您是否缺少 using 指令或程序集引用？）

手头的问题是来自 Nuget 的 Microsoft.Azure.WebJobs 包不包含 ServiceBusTriggerAttribute 类。

是否可以添加一个 Nuget 包来包含这个急需的类？

我曾尝试包含 Nuget 的 WindowsAzure.ServiceBus 包，但它也不包含它。

如果没有 ServiceBusTriggerAttribute，我无法连接此 WebJob 以使用来自 Azure 服务总线主题的消息。任何帮助将不胜感激！谢谢！

我有一个Azure 逻辑应用程序，它使用Azure 服务总线连接器向主题发送消息。我什至使用 Properties 字段，并且这些值确实与消息一起传播。但由于某种原因，过滤不适用于这些属性，尽管过滤器在使用其他工具（如服务总线资源管理器）发送消息时有效。

SB 连接器，设置属性：

消息发送到 SB 中的主题，并且在没有过滤器的订阅中可见。（规则 1=1）

但是此消息在带有过滤器的订阅中永远不可用。

尽管通过其他“发布者”（例如使用 SB Explorer 进行测试）发送的消息如果符合过滤条件，则会出现在此订阅中。

任何想法出了什么问题？

我有一个控制台应用程序来读取 Azure 服务总线上订阅中存在的所有代理消息。我那里有大约 3500 条消息。这是我阅读消息的代码：

当我执行代码时，在 dlIE 中，我只能看到 256 条消息。我也尝试过像这样给出预取计数，client.PrefetchCount但它也只返回 256 条消息。

我认为一次可以检索的消息数量有一些限制。但是该方法的msdn页面上没有提到这样的事情RecieveBatch。我可以做些什么来一次检索所有消息？

笔记：

1. 我只想阅读消息，然后让它存在于服务总线上。因此我不使用message.complete方法。

2. 我无法从服务总线中删除并重新创建主题/订阅。

编辑：

我像这样使用 PeekBatch 而不是 ReceiveBatch：

我在订阅中有3255条消息。当第一次调用 peekBatch 时，它会收到 250 条消息。所以它进入while循环PeekBatch(250,3225)。每次只收到 250 条消息。我在输出列表中的最终总消息是3500条重复消息。我无法理解这是如何发生的。

我正在寻找一个异步工作流程，如下所示：

• Azure API 应用程序向 Azure ServiceBus 主题发送消息
• 在 Azure LogicApp ServiceBus 连接器上接收消息
• 调用不同的 Azure API App 端点

最理想的情况是，我想通过这个工作流传递一个 JWT 令牌，这样我们就可以维护从原始 API 应用程序到异步调用端点的授权。

是否有任何模型用于通过逻辑应用连接器传递 JWT 令牌以维护授权？还是必须一起破解？

谢谢，柯克

徒劳地搜索后...我在哪里可以看到已将哪些 Azure 服务总线消息（内容？）发送到给定主题 + 订阅以及哪些已交付的日志/列表？我必须激活特殊功能吗？如果是这样，是哪个？新的还是“经典”的 Azure 管理门户？

谢谢！

我希望客户使用 RSS 阅读器订阅 Azure 服务总线上的主题。

我似乎找不到关于如何开始从服务总线动态生成提要的文档

任何人都可以给我任何指示吗？