MassTransit AzureServiceBus 生成的队列

2024-05-06

我有一个托管在 Azure Service Fabric 解决方案中的 MT 设置的工作配置。

我有一个发送消息的 API 和一个读取消息的无状态应用程序。

在无状态应用程序中,我告诉它使用类型的消息TestMessage具有以下内容:

container.Register(Classes.FromThisAssembly().BasedOn<IConsumer>());
var busControl = Bus.Factory.CreateUsingAzureServiceBus(cfg =>
        {
            var h = cfg.Host(new Uri("sb://xxxxx.servicebus.windows.net"), host =>
            {
                host.OperationTimeout = TimeSpan.FromSeconds(5);

                host.TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider("RootManageSharedAccessKey", "******");
            });

            cfg.ReceiveEndpoint(h, "fabric-test", ec =>
            {
                ec.UseMessageScope<ConsumeContext>();
                ec.LoadFrom(_container);
            });
        });

在 API 中,我指定了结构测试队列并发送:

var p = await _bus.GetSendEndpoint(new Uri("sb://xxxxx.servicebus.windows.net/fabric-test"));

await p.Send(new TestMessage(Guid.NewGuid()));

然而,这一切都很好。

当我查看 azure 门户时,我可以看到已创建 3 个队列和 1 个主题:

  • 桌面mmd2jga_stateless1_bus_qypoyyypboqbzhk5bdkg665cyh(队列)
  • Desktopmmd2jga_webapi1_bus_qypoyyypboqbsitfbdkg665pdd(队列)
  • 结构测试(队列)
  • xxxxx.core.testmessage(主题)

虽然这一切都发生了work我想知道这一切是什么?


stateless1是您的服务结构总线实例,即为该总线创建的临时队列。webapi1是你的Web api总线实例,用于发送到无状态服务,也是一个临时队列。fabric-test是您的接收端点的服务队列。namespace.core.testmessage是您的消息类型,由您的服务端点订阅。

这全部由 MassTransit 构建,以支持您正在使用的消息结构。临时队列会在 5 分钟后消失,不用担心 - 它们只是用于寻址和维护与 ASB 的连接。

主题是在消息被发送时创建的发表该类型,以便您的服务端点接收它。如果您不想订阅特定服务端点的消息类型的主题,您可以指定SubscribeMessageTopics = false在该端点的配置中。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

MassTransit AzureServiceBus 生成的队列 的相关文章

  • Service Fabric 无状态服务器自定义 UDP 侦听器

    我们正在尝试定义一个 Service Fabric 无状态服务 用于侦听 UDP 数据 我们正在与 Microsoft 合作 他们表示支持 TCP 并且我应该设置 TCP 以下是 ServiceManifest xml 文件的片段
  • CQRS 项目是否需要像 NServiceBus 这样的消息传递框架?

    过去 6 个月的学习曲线充满挑战 CQRS 和 DDD 是罪魁祸首 这很有趣 我们的项目已经完成了 1 2 我还没有时间深入研究的领域是消息传递框架 目前我不使用 DTC 因此如果我的读取模型未更新 那么很可能会出现读取和写入数据库之间的不
  • Azure ServiceBus QueueClient.OnMessage 是否在不同的线程上执行

    QueueClient OnMessage 方法是否始终在不同线程上执行回调参数 我假设如果 MaxConcurrentCalls 设置为 10 那么queueClient 将最多启动 10 个线程来并行处理消息 如果传入 MaxConcu
  • 如何使用 Function App 身份访问 Azure 服务总线

    我正在按照此处列出的步骤进行操作 但对于 python 代码 https learn microsoft com en us azure azure functions functions identity based connection
  • Azure Function v2 中的 BrokeredMessage 发送和消息使用者

    我有模拟的天蓝色网络作业 它会定期推送BrokeredMessage到服务总线主题 就像这样 public void Simulate TimerTrigger 0 30 RunOnStartup true TimerInfo timerI
  • Azure 服务总线主题分区

    我正在尝试向使用两者创建的主题发送消息启用重复检测 and 启用分区选项已选中 我不设置SessionId and PartitionKey我的属性BrokeredMessage实例 根据this https learn microsoft
  • 如何通过 InMemoryTestHarness 成功驱动 MassTransitStateMachine?

    跟进 如何编写 MassTransitStateMachine 单元测试 https stackoverflow com questions 49763600 how to write masstransitstatemachine uni
  • 使用 Bicep 以编程方式获取服务总线 SharedAccessKey

    我正在使用二头肌来创建天蓝色资源 这些资源之一是服务总线 其定义如下 resource service bus Microsoft ServiceBus namespaces 2021 01 01 preview name service
  • 如何清除服务总线主题订阅的消息

    只是想知道从服务总线主题的订阅中清除消息的最佳方法 即使通过 Portal Powershell 或 C 假设我们有一个包含 4 个订阅的主题 而我们只想清除其中一个订阅中的消息 我有一种感觉 唯一的方法可能是在 while 循环中阅读消息
  • 监听队列(事件驱动,无轮询)服务总线/存储队列

    我试图弄清楚如何侦听队列上的事件 尤其是入队事件 假设我有一个控制台应用程序和一个服务总线队列 主题 如何连接到队列并等待新消息 我试图在没有While true 和不断的轮询 我试图以一种相当监听的方式来做更多的事情 比如保持连接到队列的
  • Service Fabric 重启应用程序

    我有一个在启动时从 KeyVault 读取的服务结构应用程序 当我们更改 KeyVault 值时 我们必须重新启动节点才能读取新值 这会导致同一节点上的其他应用程序出现故障 我正在尝试编写一个 PowerShell 脚本来重新启动服务结构应
  • Azure 服务总线消息队列用户错误指标

    我正在帮助调查和诊断我们遇到的一些问题 并注意到服务总线队列上的用户错误指标正在发生变化 我想确切地知道这个指标的含义 如文档所示https learn microsoft com en us azure service bus messa
  • 无法从 docker 将 RabbitMQ 连接到我的应用程序 [重复]

    这个问题在这里已经有答案了 我目前被这个问题困扰了大约一周 确实找不到合适的解决方案 问题是 当我尝试连接到 dockerized RabbitMQ 时 它每次都会给出相同的错误 wordofthedayapp wordofthedayap
  • 公共交通所有故障消息由一名故障消费者处理

    如何拥有一个通用消费者来处理所有故障消息 我是否需要为每条故障消息注册故障消费者 为何不消费Fault public class WantAllFaultsGimmeThem IConsumer
  • Service Fabric:服务之间的调用有延迟?

    我们正在开发一个由多个不同服务组成的服务结构应用程序 我们的应用程序工作方式的一个关键部分是这些服务需要大量相互调用 直到最近我们增加了应用程序的负载并发现它的速度大大减慢时 我们才遇到任何问题 经过大量调查和对各种事情进行计时后 我们发现
  • 如何创建服务总线触发webjob?

    我检查doc https learn microsoft com en us azure app service webjobs sdk how to service bus trigger configuration version 3x
  • 直接向订阅发送消息

    是否可以将消息直接发送到订阅队列 设想 消息失败 被丢弃到死信中 该消息已使用 defer 手动拾取 克隆 并且需要发送到它首先被发送到死信的队列 但不是主题 我可以直接向订阅者发送消息吗 我考虑过为每个订阅者创建一个单独的重试队列 处理服
  • Service Fabric 有状态服务远程处理 V2

    我有一个由无状态服务调用的有状态服务 在 Visual Studio 15 4 上运行的 Net Standard Asp net Core 2 0 中 我无法使 Service Remoting V2 工作 适用于 V1 的有状态服务中的
  • Azure 服务总线主题请求与消息

    I need help interpreting these graphs 它有 0 订阅 这是否意味着该主题没有任何内容 查看消息图表 在过去 30 天内 没有收到或读取来自此主题的消息 如果没有向该主题写入 读取任何内容 为什么会有 3
  • 在天蓝色辅助角色中使用 QueueClient.OnMessage

    我有一个 Azure 辅助角色 负责检查 4 个服务总线队列 目前 我只是使用循环方法来手动检查队列 while true loop through my queues to check for messages Azure SDK 2 0

随机推荐