问题标签 [azure-servicebus-topics]

我一直在生产应用程序中使用 Azure 服务总线主题。我的理解是系统在发布时保证订阅端的消息至少有一份副本。

在实践中，我通常会看到与发布相对应的 1 条消息。在一些退化的情况下，虽然我看到了倍数。例如：1 个发布对应于相关订阅中的约 20 条消息。目前没有任何东西消耗这个订阅，这让我相信这是发布逻辑。

什么情况下会出现重复消息猖獗？我想网络干扰可能会导致这种情况。还有什么？

请注意，默认的重复处理逻辑无法处理此问题。您将拥有多条具有相同正文和不同消息 ID 的消息——据我所知，这些消息用于建立消息“身份”。

编辑：我的发布逻辑非常简单，类似于以下内容：

我对实现 Azure 服务总线接收来自主题订阅的消息表示怀疑。我们在我们的组织中使用多个应用程序，我们需要在一个子系统之间共享数据，以便我们使用 azure 服务总线。在这里，我的一个应用程序经常向服务总线主题订阅发送消息。每当在我们的应用程序中创建新用户帐户时，每次用户配置文件数据都会将数据发送到相应的服务总线主题订阅。我在下面提到了我必须接收 JSON 对象的快照。消息存储为 JSON 对象。

在此处输入图像描述

JSON对象：

{"id":"N322333","firstName":"adsdddd","lastName":"asddd","email":"hello@gmail.com123ZXc","emailVerified":false,"dateOfBirth":"2016- 08-03","登录":"qqqqqqqqqq","密码":"Pass@1234","homePhone":"233322","mobilePhone":"1111111122asdf","workPhone":"22222","gender" :1,"centerId":"I23642","userType":"student","staffRole":null,"staffActive":false}

现在，我将接收那些在移动到死信之前已经发送到天蓝色服务总线主题订阅队列的 JSON 对象。JSON 对象可以存储在订阅上的 JSON 对象列表。我搜索了很多示例，但无法找到合适的解决方案。请让我分享您的建议如何接收 JSON 对象列表？我会等待你的回应。

问候，

帕蒂班。

我在一个解决方案中创建了两个项目。一个是.net core（v4.6 framework）类库项目，第二个是普通的.net（v4.5.2 framework）类库项目，用于向服务总线主题发送消息。到目前为止，我已经在 project.js 文件中添加了以下参考。

当我将普通 .net 4.5.2 框架的引用添加到 .net core 4.6 框架中时。我收到以下错误。

错误 CS0246 找不到类型或命名空间名称“TestClassLibrary”（是否缺少 using 指令或程序集引用？） TestCoreClassLibrary..NETStandard,Version=v1.6 C:\Projects\AzureServiceBusPOC\TestApplication\src\TestCoreClassLibrary\ Class1.cs 5 活动

我无法从正常的 .net 4.5.2 框架访问成员和成员函数。如果有人知道，请让我分享你的想法。

注意：-
我不知道.net 核心是否支持服务总线实现。

问候，
帕蒂班

有没有办法使用 Node.js SDK 中的共享访问签名密钥连接到 Azure 服务总线订阅？我们想使用 SAS Key 从订阅中读取消息。

文档中有一些关于SAS的内容，但没有具体内容。

我想不通。

我刚开始使用 Azure ServiceBus。一件事对我来说并不完全清楚，我很难找到答案。

如果我调用message.Complete()订阅消息，这是否意味着该消息将不再发送给任何其他订阅者，或者我只是为当前订阅者完成此消息？换句话说，服务总线是否跟踪每个订阅者或每个订阅的消息？

在我的特定用例中，我希望所有订阅者都处理消息，而不仅仅是任何/一个订阅者。主题完全有可能吗？

我试图让天蓝色函数异步订阅一个主题。

当消息到达时，这会失败并显示消息

我在 Azure 函数的 Monitor 部分看到以下内容：带有 ContentType 'null' 的 BrokeredMessage 无法反序列化为带有消息的字符串：'Expecting element 'string' from namespace...

我使用以下代码向该主题发布了一条中间消息

知道可能是什么原因吗？

这是场景：

我有一条消息需要由多个订阅者处理，但每个服务只有一个（每个服务将运行多个实例）。

消息#1，需要由订阅者#1 和#3 处理。消息#2，需要由订阅者#2 和#4 处理。消息 #3，订阅者 #1 和 #3 再次。基本上，每条消息都应该轮询订阅每条消息的每个负载平衡服务，并按每个正在连接的服务分组。在不创建多个主题的情况下这可能吗？

即使不是轮询，我也想尽最大努力跨多个服务进行负载平衡。这可能吗？

对于这种方法：

什么是主题路径？

MSDN 说它是“主题的完整路径名”。

路径名是什么？

有代码示例，但我还没有找到解释这个小细节的代码示例。

我正在使用 azure service bus 消息传递，因为我遇到了一些奇怪的问题。

我用“peeklock”模式创建了一个订阅客户端。使用 SubscriptionClient.ReceiveBatch(500) 方法并收到“n”条消息。然后循环这些消息并执行我的过程，如果我的过程成功完成，则使用 BrokeredMessage.Complete() 从队列中删除该消息。如果该过程中有任何问题，我正在使用 BrokeredMessage.Abandon() 来更新消息。但是消息不会从队列中删除。

经过一些分析，我怀疑我的过程需要更多时间，并且消息锁在过程完成之前就过期了。

然后我决定，在收到来自队列的消息后，我将这些消息推送到本地字符串数组中，然后调用 BrokeredMessage.Complete()。所以不存在锁过期的可能。但是仍然没有从队列中删除消息。

请给出一些想法来解决这个问题。

我有一个 Azure 服务总线主题，我想在使用纯 Javascript 的网页上实时接收消息。

我尝试了这个 SDK（http://developers.de/blogs/damir_dobric/archive/2015/01/26/eventhubs-support-for-azure-servicebus-javascript-sdk.aspx）但是当我加快发送消息时运作良好。

我也尝试过 REST API，但也没有很好地工作。

存在任何替代方案吗？

问候