问题标签 [azure-servicebus-topics]

如果 BrokeredMessage 的正文是 JSON 文本，是否可以设置一个主题订阅，并对该 JSON 中的属性进行过滤？

我有一些与服务总线相关的具体问题，我想深入了解这些问题。我已经阅读了很多博客和很多关于服务总线 (SB) 的文档，并且已经实现了一个可以使用它的解决方案。我要问的问题，如何没有得到回答，或者以一种不清楚的方式得到了回答，所以这就是为什么我想更深入地了解细节。所以他们来了：

1) 只是想了解有关 ServiceBus 队列的“OnMessage”功能的更多详细信息。据我了解，根据文档和我的测试，这不是具有 Sleep() 间隔的典型 while()/Receive() 循环，但实际上更多的是基于“推送”的方法。所以我的问题是，如果我将“AutoRenewTimeout”设置为 1 分钟，那么在发出新的 Receive() 操作之前等待接收消息的那 1 分钟的线程会发生什么情况。它是否休眠并等待来自 ServiceBus 的消息被“推送”到它？还是这里更像是一种异步方法，其中一个线程被释放回池中，并且只有在消息到达我设置的 1 分钟 AutoRenewTimeout 窗口的 47 秒时才再次抓取以工作？（不，我不是在说“

2) 关于问题 1)，将“AutoRenewTimeout”设置为 5 分钟、10 分钟或 60 分钟，除了在这些时间间隔触发的 Receive() 操作的明显成本之外，还有什么意义？我想从客户的角度来看，我触发接收操作的频率越低，对我来说就越划算，但是从服务总线的角度/应用程序的角度来看，在此期间“等待消息”，推荐的“ AutoRenewTimeout”期间？如果“AutoRenewTimeout”设置为 1 小时而不是 1 分钟，SB 是否更容易断开连接？当“AutoRenewTimeout”更长时，是否有更多的资源/线程使用被用完？在我读过的任何帖子/博客/文档中，我都找不到任何明确的答案。

3）我在每台服务器上都部署了一个主题/订阅应用程序，该应用程序都向/从一个主题发送/接收消息。现在，我不希望每个客户端（服务器）接收它自己发出的消息，我只想接收其他服务器（客户端）发出的消息。我能够使用 SqlFilter() 实现解决方案，但我想知道是否有任何其他/更好的方法可以做到这一点？在谈到SqlFilters() 时，如果使用简单的比较SqlFilter()，对订阅客户端之间的消息传递速度有什么性能影响（如果有的话）？（我想我可以自己进行基准测试，但我只是好奇地想看看内部结构）

4) 关于消息接收器上的 PeekAndLock 模式，如果在假设的场景中，当消息在 SB 端收到时被标记为已完成，有人能够物理切断 SB 端和应用程序 VM 之间的线路，那么该消息将永远丢失，因为应用程序不会收到它，但 SB 会检查它是否已完成。我的理解是否正确，在 PeekAndLock 模式下，消息被标记为已完成，而应用程序端没有确定收到它的保证？

5）关于删除一个主题的订阅，假设其中有 100 条消息从未收到，这算作 1 次操作还是 101 次操作？

感谢您花时间和精力阅读本文。如有必要，我很乐意澄清任何一点。Abhishek，您似乎是 SB 的建筑师之一，所以如果您看到这篇文章，如果您能发表一些评论，我将不胜感激：)

谢谢！

所以我们最近一直在研究 Azure 服务总线，对于是否应该使用无限循环来轮询队列/订阅还是应该使用 OnMessage 回调/消息泵功能，我们有点困惑。什么会执行更少的操作，从而降低成本？

理想情况下，我们想要一个事件驱动的系统，这样我们就不会浪费操作，而且它通常是一种更好的方法。

我的问题是，使用 OnMessage 定义为“在事件驱动的消息泵中处理消息”真的是事件驱动的吗？

如果您查看此页面（QueueClient.OnMessage）：https ://msdn.microsoft.com/library/azure/microsoft.servicebus.messaging.queueclient.onmessage.aspx您会注意到底部的注释它基本上是调用 Receive() 方法的无限循环的包装器。对我来说，这听起来不太受事件驱动。

现在，如果您查看此页面（SubscriptionClient.OnMessage）： https ://msdn.microsoft.com/en-us/library/azure/dn130336.aspx ，则不存在该注释。那么主题/订阅和队列是否相同，或者它实际上是事件驱动的订阅而不是队列？

为什么他们甚至说它是事件驱动的，而它显然不是？QueueClient.OnMessage 页面上的注释有“无限循环”和“每个接收操作都是计费事件”的事实有点吓人。

此外，我并不真正关心无论哪种方式都会花费多少/很少，我更感兴趣的是使其尽可能高效。

感谢这个后天蓝色资源管理器服务总线提供商？,

我能够提供一个带有主题和订阅的服务总线命名空间。

我现在想知道是否可以在配置订阅时添加SQL 过滤器？

提前致谢。

我创建了一个 azure 服务总线主题应用程序，它可以查看deadletter中的所有消息。我偷看的一些特定消息（具有特定的 messageid）需要从死信队列中删除。请为实施此提供帮助。

Azure 服务总线中的主题订阅是否有限制？

我将为每个 TenantID 创建一个订阅，有问题吗？

我们正在考虑使用 Azure 服务总线（或 Windows Server 的服务总线）将业务事件发布为由我们的 .Net 服务生成的发布/订阅主题。我们希望 IBM Lombardi BPM（无需轮询）接收这些事件。尚不清楚 Lombardi BPM V8.5.6 是否可以订阅 Azure（或 Windows Server 的服务总线）主题。

1. 这可以通过开箱即用的 Lombardi BPM 完成吗？
2. 你怎么做呢？

消息将存储Event Hub特定的时间间隔。一旦此时间到期，消息将自动删除。由于offsetvalues 定义了 event 在 中的位置partition，我很困惑offset value下次是否会得到相同的结果（在数据从分区过期之后）。如果是这样，那么分区offset事件和事件之间有什么区别？sequence

我想使用代理服务（rest）向特定订阅发送消息，我该怎么做。

如果某个主题有很多订阅，并且我想向特定订阅发送消息。

我正在使用 Rebus，我想在“避免多次处理事件”段落中介绍CQRS Journey中描述的内容，但我无法弄清楚。

我将 Rebus 配置为使用 SQL Server for Transport和 MongoDB for Subscriptions和Sagas。Routing配置为基于Type，并将所有命令处理程序的类型映射到Transport中配置的队列。

现在我应该配置 Rebus，当命令发布事件时，它会复制到与现有订阅者类型一样多的单独主题（虚拟或物理队列）中。

就像是：

感谢帮助。