publish-subscribe 相关问题

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

如何在Python中使用套接字创建频道

我已经数次启动了Python,现在,我正在创建一个套接字服务器。我已经使服务器具有多个具有多个客户端的线程(万岁!),但是我正在寻找...

回答 1 投票 2

在delivery_attempt超过max_delivery_attempts之后,将PubSub转发到死信主题的消息

我的订阅者看起来像这样:从google.cloud导入pubsub_v1从google.cloud.pubsub_v1.types导入DeadLetterPolicy

回答 1 投票 0

Redis PUB / SUB:如何忽略自己的消息?

想法是:我有N个WCF服务,它们已连接并订阅了相同的Redis消息通道。这些服务使用此通道交换消息以同步某些缓存和其他数据。每个...

回答 1 投票 5

如何在ZMQ发布者/订阅者队列中获取消息/事件计数

我们实现了ZMQ PUB / SUB机制,用于在分布式进程之间进行消息传输。但是由于订户的处理时间,消息的处理有些延迟(有时...

回答 1 投票 0

为什么ZeroMQ PUSH / PULL起作用,而PUB / SUB无效?

[环境:Jetson开发板上的NVIDIA风格的Ubuntu 18.01和TX2i处理器。 ZMQ 4.3.2,将cppzmq C ++包装器用于ZMQ。我使用...

回答 1 投票 1

Spring Cloud Stream vs Google Native Library

Google提供了自己的库来访问发布/订阅服务。另一方面,Spring Cloud Stream也提供了相同的功能。一个相对于另一个有什么优势吗?

回答 1 投票 0

什么是Redis pubsub?如何使用它?

[有人问我,PubSub是什么,以及如何创建频道(在我的回答中有注释),我指出他是关于redis.io的文章=> http://redis.io/topics/pubsub。我认为这很清楚,但是...

回答 1 投票 37

需要使用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

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