messagebroker 相关问题

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

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

无法从 ESQL 中的存储过程获取结果集?

我正在从 esql 调用外部存储过程,其中输入也是 clob,输出也是 clob。 我必须发送输入并从 Oracle 数据库存储过程获得响应。 但我收到错误...

回答 2 投票 0

为什么使用 Pika RabbitMQ,消费者在长时间空闲时会默默地断开队列?

在我的公司,我们目前正面临使用 rabbitMQ 的奇怪行为。我们托管在 Kubernetes 集群中的微服务之一是用 Python 构建的(其他的是用 Java 构建的,它们没有显示这个问题......

回答 0 投票 0

在MQTT中,订阅者的数量是否会影响接收时间?

我想知道特定主题的订阅者数量是否会导致每个订阅者接收消息的延迟?如果是的话,是与broker的实现有关还是与...有关?

回答 1 投票 0

从性能上看,RabbitMQ交换的意义是什么?

我已经试图找到一个答案,但无法找到任何固体。比方说,我有一个系统,分裂到3个模块。(只是一个例子)用户产品订单,我可以创建3个交易所,每个1 ....

回答 1 投票 0

RabbitMQ在同一组中保持处理作业的顺序。

我的应用队列(RabbitMQ)中有一个作业列表。其中一些作业是分组的,必须按照顺序来做。(不是连续的,而是按照发送时间的顺序)例如,考虑这个4 ...

回答 1 投票 -1

如何编写JMS Broker?

Java消息服务是如何涉及到经纪人的?我看到了创建ProducerConsumer客户端的教程和示例,但我不明白如何用JMS涉及到一个经纪人。我看到...

回答 1 投票 0

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