publish-subscribe 相关问题

发布/订阅是一种消息模式,其中消息的发送者(发布者)不对要直接发送到特定接收者(订阅者)的消息进行编程。相反,已发布的消息被表征为频道,而不知道可能存在的订户(如果有的话)。

需要使用Peeklock模型将安装了多个Azure Antivirus的VM订阅到Azure消息队列中

我们已在多个Azure Linux VM中安装了sophos。安装了pip,azure服务总线sdk并使用以下代码,我们可以在消息到达队列时使用消息。来自azure.servicebus ...

回答 1 投票 0

Solar-具有水平可伸缩性的有保证顺序

因此,在非独占队列中,我们已对消息进行了排序(例如,ID 123更新事件将在ID 123创建事件之后)。当我们只有一个使用者时,一切都很好,但是需要水平可伸缩性。 ...

回答 3 投票 2

如何创建消息队列使用者?

我对基于消息队列的体系结构非常陌生。我打算创建一个微服务,该服务从消息队列中获取输入并将结果发布到另一个队列中。这将是...

回答 1 投票 0

使用mosca MQTT的请求响应模式

是否有任何方法可以通过mosca MQTT来实现请求-响应模式,以“检查来自客户端的答复,如果我没有在预期的时间内收到预期的答复,则重新发布”。我相信这是...

回答 2 投票 0

如何使用Eclipse正确订阅主题?

我正在研究IOT应用程序,其中我将把移动应用程序连接到酒吧子经纪人,以从移动电源盒中释放便携式充电器。我有制造...

回答 1 投票 1

如果pubsub主题不可用,则找不到异常

我正在使用Spring Boot与pubsub主题进行交互。此连接的配置类如下所示:import org.slf4j.Logger;导入org.slf4j.LoggerFactory;导入org.springframework.cloud ....

回答 1 投票 0

如何最佳地将Apache Kafka定位为许多独立客户端的消息代理

我的组织有一个AWS托管的Spring Boot应用程序,其中Apache Kafka当前正在促进约50个主题的消息交换(“云应用程序”)。在客户端设施内(物理...

回答 2 投票 1

zeromq同时订阅和发布

我正在尝试在python的debian / multiprocess情况下使用zeromq。我有几个过程可以解码来自多个传感器的原始数据,并在zmq中发布。到目前为止,一切都很好。我有一个...

回答 2 投票 3

Python-如何组织发布订阅邮件?

我有一个项目,该项目大量使用wx pubsub与代码的各个部分进行通信。对于任何给定消息,1-5个不同的订户可能会感兴趣。在以前的版本中...

回答 2 投票 1

DDS与RTPS之间的差异

我正在寻找图像处理管道的框架。在搜索过程中,我发现许多DDS和RTPS术语在这里和那里可以互换使用。它们是一样的吗?如果是,那么为什么2 ...

回答 1 投票 2

具有单个输入和多个输出的Python管道

我熟悉multiprocessing.Pipe,但是我正在寻找可以复制输入数据并将其发送给多个输出使用者的东西。我了解队列支持多个...

回答 1 投票 0

Python-如何将消息(Json Data)发布到主题?

我的目标是将我从Restful api调用中提取的数据发布到我专门创建的主题,使消息显示每个键和值。 #PubSub Vars project_id = ...

回答 1 投票 0

多个消费者的redis发布/订阅

我有一个小型系统,该系统使用Redis的pub子功能进行事件消息传递。我正在使用带有redis库的nodejs。我制作了一个小脚本,以使我的消费者更轻松,... ...>

回答 1 投票 0

永久订阅MassTransit-重新启动后无消息

我希望这对别人来说很容易,因为我指出我做了一些愚蠢的事情!我最近尝试在此处的系统上设置MassTransit,但消息出现问题...

回答 1 投票 1

MQTT如何工作?如果在发送方文件之后启动接收方文件,则无法获取数据

你好,我是MQTT的新手,我想打印一个简单的数字范围,我创建了2个文件,其中第一个文件将数据发送到第二个文件,而脚本是这样的:sender.py。 ..

回答 1 投票 1

如何检查主题队列是否为空,然后终止订户?

在我的业务应用程序中,我必须定期对某个主题中的所有消息进行批处理,因为它比以先到先得的方式处理它们便宜。我当前的方式是...

回答 1 投票 0

Spring Cloud PubSub无法发布到队列中

我有一个正在从一个队列侦听并发布到多个队列的实现。因此,我实现了一个通用接口,以通过传递其名称将消息发送到不同的主题。 ...

回答 1 投票 3

open62541:发布温度值

我目前正在尝试使用称为open62541的OPC UA实现发布日期时间值和温度值。为此,我一直在使用来自open62541 github的测试示例...

回答 1 投票 1

Apollo服务器订阅无法识别异步可迭代

我对Apollo GraphQL的订阅有问题。尝试启动订阅时,我得到以下回报:“订阅字段必须返回异步可迭代。已收到:{pubsub:{ee:...

回答 1 投票 1

Redis如何与每个客户保持联系?

我正在学习如何使用Redis。我专门在学习pub / sub功能。我将ioredis与expressjs和nodejs一起使用。我遇到过这段代码var Redis = require(“ ioredis”); ...

回答 1 投票 0

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