messagebroker 相关问题

Message Broker是一种模式,旨在消费来自应用程序的消息并执行转换等操作,提供消息路由机制的点对点和发布 - 订阅模式。它调解应用程序之间的通信,最大限度地减少应用程序之间应该具有的相互意识,以便能够交换消息,有效地实现解耦。

x时间后消费服务总线消息

我正在做一个项目来研究更多的经纪人,我正在使用.NET 6.0和服务总线来做到这一点。 我的问题是:我需要发布一条消息并仅在一段时间后使用同一条消息(我放...

回答 1 投票 0

错误:空响应。没有订阅者正在收听该消息(“x”)

我正在尝试通过 Nestjs 和 Nats 创建微服务,但收到错误错误:空响应。没有订阅者正在收听该消息(“checkUserExists”) 现在我...

回答 1 投票 0

与消息代理的粘性会话

我正在开发一个项目,我们正在尝试利用消息代理,在类型消息开始发送给给定的消费者之后,它会继续发送给该消费者。这本质上是...

回答 1 投票 0

使用 NTLM 进行 RabbitMQ 身份验证(无密码)

我已经配置了 RabbitMQ,但目前它使用简单的用户名/密码连接到队列。这并不理想,因为我必须将密码存储在应用程序配置中。 理想情况下,我

回答 1 投票 0

RabbitMQ 本地主机管理无法启动,日志文件中出现端口 5672 错误

我已经在Windows 10机器上安装了RabbitMQ 3.11.2和Erlang版本25.1.1。 我对 RabbitMQ 非常陌生,无法启动 RabbitMQ 管理门户。我启用了 RabbitMQ 管理...

回答 2 投票 0

RabbitMQ 自动删除超时队列

我有一个k8s服务,使用rabbitMQ作为消息代理。 如果可能有多个 Pod 的服务部署停止,我希望能够删除特定队列。 阅读 Rab 文档...

回答 1 投票 0

MassTransit 状态机等待所有消息

我正在尝试使用公共交通创建一个状态机,在其中等待 3 个状态更改为“已完成”。然后当我确定所有 3 个都已完成时,我想调用一些最终代码或其他东西......

回答 1 投票 0

用于自定义消息传递协议的消息代理?

是否有任何框架或平台能够以可靠、灵活且可扩展的方式提供消息交换?我有以下场景: 我有外部设备与...

回答 2 投票 0

PHP 和 SOAP 消息代理有什么用?

我正在研究一种解决方案,使大型数据库中的某些数据可用于远程网站。我的第一个想法是简单地编写一些肥皂网络服务来从数据中获取某些数据......

回答 1 投票 0

如何在 Apache ActiveMQ“经典”中仅获取组中的最后一条消息?

场景: 用户正在进行长时间测验。每次互动后,我都会将当前分数和位置存储在测验中。我只想在数据库中存储用户在当前期间所做的最后一次交互

回答 2 投票 0

分布式系统消息传递中发布者/订阅者和生产者/消费者之间的区别?

发布者/订阅者和生产者/消费者模型有什么区别? 我经常听到人们交替使用“出版商”和“制作人”这两个词,但我不……

回答 1 投票 0

如何使用 Linux shell 命令订阅多个主题(至少 2 个)并将收到的消息重新发布到 Mosquitto MQTT 的单个主题

我试图找到一种订阅多个主题的方法,然后在收到消息后,该函数应该根据主题将其发布到不同的代理。 我已经想到了

回答 1 投票 0

哪种方案更适合微服务? GRPC 或像 RabbitMQ 这样的消息代理

我想开发一个微服务结构的项目。 我必须使用 php/laravel 和 nodejs/nestjs 我的微服务之间的最佳连接方法是什么?我读到了 RabbitMQ 和 NATS 消息传递...

回答 4 投票 0

ActiveMQ Artemis 最大重新传递延迟和死信队列

我们正在使用代理ActiveMQ Artemis 2.26.0,我正在尝试在队列上设置重新传递机制。 我希望某些消息能够重试最多 72 小时,并逐步回退。 ...

回答 3 投票 0

Apache activemq-broker jar 的替代方案是什么,它支持 Jakarta(如 JDK 17 和 Spring 6)?

我有一个基于 Spring 5 的应用程序,它使用 Apache activemq 客户端和代理库。我们现在正在迁移到 Spring 6,它需要 JDK 17 指定的 Jakarta 命名空间。B...

回答 2 投票 0

EdgeXFoundry Jakarta 2.1 版本支持共享订阅

有人可以深入了解 EdgexFoundry 的 Jakarta 2.1 版本中对共享订阅的支持吗?如本文档所示,共享订阅功能似乎不适用...

回答 1 投票 0

微服务与客户端之间的异步通信

我们有一个基于微服务架构的应用程序,具有以下组件 客户端应用程序:asp.net core mvc API网关:Ocelot 服务A:asp.net core web api 客户端发送

回答 1 投票 0

mule 中的 AMQP 连接器和 JMS 连接器有什么区别?

我对 AMQP 和 JMS 什么时候使用哪个连接器有点困惑?就像如果我有 Rabbit MQ 然后去 AMQP 和 Active MA 然后 JMS。 我如何根据各种客户识别连接器/

回答 0 投票 0

是否有任何方法可以从多个队列中读取来自 RabbitMq 的消息,其中一个队列的优先级高于另一个队列?

我有一个微服务正在处理不同类型的消息。其中一种类型 (A) 需要先于其他类型进行处理。因此,如果队列有 1000 个 B 类型的条目和

回答 0 投票 0

.NET - 微服务之间的 Azure 通信 - 查询

我正在 .NET 和 Azure 上创建一个应用程序,它有一个订单服务和一个支付服务。如果创建了一个订单,付款创建也会发送到消息代理,这是

回答 0 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.