问题标签 [azure-servicebus-subscriptions]

我正处于设计我们的两个企业应用程序如何向 Azure 服务总线中的主题广播的高级结构的早期阶段。我是这项技术的新手，在初步阅读文档后，我很想使用一个简单的解决方案：为我们想要广播的每种不同的事件类型使用一个单独的主题。

我喜欢这个解决方案（而不是使用过滤器），因为它提供了对共享访问密钥的最精细控制、最少的消息吞吐量，并且还允许在每个主题的基础上轻松添加订阅删除。

另一种解决方案是使用更少的主题（向单个主题发送多个事件），然后配置过滤器来确定每条消息是否应该发送到订阅。从维护的角度来看，这似乎不必要地更复杂，也更不方便。当我可以创建数千个主题时，为什么还要使用过滤器？

任何人都可以就最佳方法提供反馈吗？

我有一个名为“IntegrationEvent”的 Azure ServiceBus 主题和一个名为“TestSubscription”的订阅。我为此订阅注册了两个订阅者，我拥有CompetingConsumers。

两个订阅者都处理了大量消息。我需要改变什么以使这种情况不再发生？我认为每条消息都应该只由一个订阅者处理？

发件人：

我使用两个订阅者/消费者（不是订阅）来监听 IntegrationEvent。

我正在使用 Microsoft 门户中的以下代码来发送和接收来自 Azure 服务总线主题/订阅的消息。代码工作正常。总线当我运行 2 个接收器代码实例时，消息在 2 个接收器之间分配。10 个发送 && 接收 5 个。我只想知道如何在所有接收者中获取所有消息。

-------------------------------------------------- --------------------------

}

我正在尝试使用 Azure 蓝图工件中的嵌套模板将主题部署到 Azure 服务总线。此总线是在与蓝图的其余部分不同的订阅中创建的。我一直在关注这篇文章：https ://docs.microsoft.com/en-us/azure/azure-resource-manager/resource-manager-cross-resource-group-deployment

我的工件定义为：

}

使用导入蓝图时Import-AzBlueprintWithArtifact -Name $blueprintName -ManagementGroupId $managementGroupId -InputPath $blueprintFolder -Force 收到以下错误：

“错误！此工件无效。错误：'13' 行和'5' 列的模板资源'nestedTemplate' 无效。订阅范围内的部署内的嵌套部署不支持'SubscriptionId' 属性。请参阅https ://aka.ms/arm-template/#resources了解使用详情。'"

我正在尝试以下代码来检查 Azure 服务总线主题订阅是否已存在：

我收到以下错误SubscriptionExistsAsync：

Microsoft.Azure.ServiceBus.ServiceBusException：'指定的 HTTP 谓词 (GET) 无效。要了解更多信息，请访问 https://aka.ms/sbResourceMgrExceptions。. TrackingId：aa8b87cc-ea45-4fdc-be39-bf1877774b0e_G24，SystemTracker：needspacetests：队列：sc-messenger，时间戳：2019-12-18T11：33：45'

我在这里做错了什么/错过了什么？

笔记：

• 我在基本计划中使用新创建的 Azure 服务总线和新（手动）创建的队列。
• queueName具有现有队列的值。

我是天蓝色服务巴士和公共交通的新手。我正在寻找针对特定情况的解决方案。

我有一个包含多个订阅者的天蓝色服务总线主题。订阅者将根据过滤器接收消息。我用下面的代码创建了主题和订阅者

在代码中，我们添加了Message 自定义属性，例如From。

现在我想使用masstransit发送这样的消息。在公共交通中，我找不到使用Publish()方法添加消息自定义属性的任何选项。有什么方法可以使用可以使用这些过滤器的公共交通发送这些消息？

注意：我已经阅读了这个问题的答案但是这里的答案告诉我们在订阅者端过滤消息。我想要的是这种过滤将在到达订阅者之前发生。

在我的解决方案中，Azure 服务总线上的消息使用者是基于 .net 的应用程序，我们通过在使用者应用程序 app.config 中配置应用程序 ID 和密码来使用 AAD 服务主体实现安全方面，并且它工作正常，没有问题。

虽然向 Azure 服务总线发布消息的应用程序是基于“GO”语言的，但 Azure 服务总线相关的 SDK 在进行 Azure 服务总线相关的服务器调用时无法使用 AAD 服务主体。服务主体可以作为 Azure 服务总线相关 REST api 的授权标头传入吗？没有把握。因此，我们将 SAS 签名与 Azure 服务总线 url（在我们的例子中用于发布消息）一起发送，我们认为这是安全的威胁，因为 SAS 签名很可能因各种原因在传输层上受到损害。

因此，对于 Azure sdk 不可用的语言，如 GO、Erlang 等，在与 azure 服务总线集成以发布/订阅它的同时，整合安全方面的最佳方法是什么？除了 SAS 签名方法。

我们正在尝试从“GO”语言应用程序连接到 Azure 服务总线实体，并且可以通过提供将通过安全主体获得的 SAS 令牌或 Azure AD OAuth2.0 令牌与 Azure 服务总线实体集成。从技术上讲，我更喜欢安全主体选项而不是 SAS 令牌，因为它存在安全漏洞。

如何使用 Azure AD SDK 不可用的“GO”等语言从 Azure AD 获取 OAuth2.0 令牌？

是否可以直接调用 Azure AD REST API 来访问 OAuth2.0 令牌？如果是，一些代码示例会有所帮助，否则请建议合适的选项。

我正在使用以下 javascript 代码在 azure 服务总线中列出一个主题。

库和版本 @azure/service-bus 1.1.2

应用程序启动后，它工作正常。但如果任何情况下连接丢失或连接超时，监听器将停止监听。

你能告诉我如何解决这个问题。如果连接丢失，是否有任何重试机制可以重新连接连接。

subscriptionClient.AbandonAsync 与 subscriptionClient.closeAsync 有什么区别。

我需要检查订阅客户端中是否存在主题。由于某些限制，我无法使用 azure 管理客户端