publish-subscribe 相关问题

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

我可以使用XSUB / XPUB zeromq模式并向每个消息添加时间戳/序列号

我正在使用zeromq创建通用动态图设置。我已经有XPUB / XSUB设置,但想知道是否有zmq方式向通过...的每条消息添加序列号/时间戳。

回答 1 投票 0

Rails和Postgresql,在创建新记录时通知/收听

我正在尝试并学习如何根据本教程在制作服务器发送事件的上下文中使用PostgreSQL,即其Notify / Listen功能。本教程发布NOTIFY ...

回答 1 投票 1

DDS阅读器未删除邮件

我正在学习使用RTI的DDS(对于该主题来说还是很新的)。我正在创建一个写到订阅服务器的发布服务器,并且订阅服务器输出消息。我想模拟的一件事是...

回答 1 投票 1


订阅后没有刷新角度的组件

我的角组件userService @Component({选择器:'shopping-productitem',templateUrl:'./productitem.component.html',styleUrls:['./productitem.component.css']})导出类.. 。

回答 1 投票 0

Caliburn Micro发布/订阅

我正在阅读以下教程http://www.mindscapehq.com/blog/index.php/2012/2/1/caliburn-micro-part-4-the-event-aggregator/,目前停留在发布/订阅部分。我...

回答 1 投票 2

GCP PubSub:创建配置类以发布消息

我正在尝试创建一个单独的类以仅用于连接到GCPPUB。我有以下类可以成功连接并将消息推送到gcp。但是问题是每次它验证连接时...

回答 2 投票 1

流星js,铁路由器,在服务器端使用Route.go('...')进行单元测试不起作用

我需要转到特定的路由器以测试发布行为,我使用的是铁路由器包Router.go('...'),但在服务器端不起作用,它抛出了一个错误:/ / XXX,假设没有其他...

回答 1 投票 1

google.api_core.exceptions.ServiceUnavailable:超过503个截止日期

google.api_core.exceptions.ServiceUnavailable:503截止日期使用python 3.7已超过,google-cloud-pubsub == 1.1.0发布有关主题的数据。在我的本地计算机上,它工作正常,并且能够...

回答 1 投票 0

Redis pubsub一个复杂的数据结构

我想将redis PUBSUB功能与哈希表等复杂的数据结构一起使用。我在网上看到的所有示例仅发布字符串。我希望能够做到这一点:redis> HSET ...

回答 2 投票 0



如何在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

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