publish-subscribe 相关问题

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

如何使发布接收消息?

我有一个学校作业要使用RabbitMQ。这是一个证券交易所的项目,使用主题仅为对该消息感兴趣的人发送消息。一个例子是,经纪人想买...

回答 1 投票 0

从Sentinel C获取Redis主地址#

我正在尝试使用sentinel来获取我的master的连接地址,问题是Sentinel仅在故障转移时发送地址,但是如果我的主人关闭并且奴隶被提升了......

回答 2 投票 2

如何使用委托跨类触发事件?

我有2个不同的类,需要在main方法中订阅事件。但是我没有在main方法中订阅事件。是否知道如何操作?头等舱***********公共舱数据{...

回答 1 投票 0

在Airflow中的组件之间传输数据

我是Airflow的新手,并阅读了大部分文档。从文档中,我了解DAG中组件之间的小数据可以使用XCom类共享。 ......

回答 1 投票 0

如何取消订阅socket.io订阅?

假设存在对套接字服务器进行订阅的对象,如下所示:socket.on('news',obj.socketEvent)这些对象的生命周期很短,并且经常被创建,生成许多...

回答 10 投票 54

引起:io.grpc.StatusRuntimeException:NOT_FOUND:找不到资源

我尝试编写一个pubsub测试:@Test public void sendTopic()throws Exception {CustomSubscriber customSubscriber = new CustomSubscriber(); customSubscriber.startAndWait(); ...

回答 3 投票 5

如何设置pubsub以便firebase可以通过cloud函数接收pubsub触发器?

我们希望通过带有pubsub触发器的httbase cloud功能(https://firebase.google.com/docs/functions/pubsub-events)接收关于某个主题的pubsub通知。但是,https:// firebase ....

回答 2 投票 0

Vanilla JS事件委托 - 处理目标元素的子元素

我正试图在vanilla JS中进行事件委托。我有一个像这样的容器内的按钮

回答 2 投票 17

跨c#,c ++和可能更多语言的进程间pub / sub模型

我想制作一个包含多个通信流程的系统。主过程正在引发事件。将有不同的事件,每个事件包含结构化数据。几个奴隶进程是......

回答 2 投票 0

Observer,Pub / Sub和Data Binding之间的区别

观察者模式,发布/订阅和数据绑定有什么区别?我在Stack Overflow上搜索了一下,没有找到任何好的答案。我所相信的是......

回答 4 投票 147

为什么Python /在定义了pub.publish()之后Python如何知道执行回调函数?

在此代码中,函数调用被写入,但在定义其中一个变量之后执行,而不会抛出错误。 n / a counter = 0 pub =无def callback_receive_number_data(msg):global ...

回答 1 投票 0

如何在不使用Dataflow且不在Python中使用ACK的情况下排除Pubsub中的重复消息?

我有一个用例,我想在不确认消息的情况下阅读Pubsub中的消息。我需要帮助来解决如何排除“重复消息”的可能性,这些消息将保留在......

回答 1 投票 0

订阅ROS Image和CameraInfo sensor.msgs格式

我正在尝试订阅CameraInfo和格式为sensor_msgs.msg的图像,并使用其数据进行进一步的图像处理。以下是我开始使用的几行代码:来自sensor_msgs.msg ...

回答 2 投票 0

分布式系统 - 如何保证至少一次发布消息?

如何在服务总线中发布消息(可能是队列)之前发生故障时,如何保持不同系统(也称为有界上下文)之间的一致性。我想出了3个选项:1。......

回答 1 投票 0

PUBSUB CHANNELS返回空列表

我有一个python程序,如下导入json导入线程导入redis CHANNELS_PREFIX ='client'类Listener(threading.Thread):STOP = 1 CONTINUE = 0 def __init __(self,r):...

回答 1 投票 0

如何使用Java通过Push in Cloud Pub / Sub接收消息

我正在尝试使用Java实现Google Cloud Pub / Sub来接收消息(通过Push)但我找不到Java的文档。我可以通过pull接收消息,也可以通过设置和...

回答 2 投票 3

如何设计一个pub-sub系统,同一实体可以有多个发布者?

考虑以下情况:有一个User表,其中包含name,email,contact_no等字段。我们有多个产品/系统(带有自己的db),它们使用各种用户信息...

回答 3 投票 1

如何在Angular中创建发布者/订阅者模型?

我一直在玩Angular,并且一直试图找到一种在整个组件树中使用pub / sub机制的方法。似乎EventEmitter只发出一个可以......的事件

回答 2 投票 5

使用分销商时从NServiceBus处理程序调用bus.Publish是否安全?

在横向扩展方案中,一个服务器由主工作端点和工作端点组成,另一个服务器由工作端组成,在完成处理给定的端点时,从端点调用bus.Publish是安全的。

回答 2 投票 0

使用RabbitMQ(或pub / sub)作为变量

我有一个事件(比如活动),可能在给定时间有效或无效。我正在寻找一种方法来使用RabbitMQ来判断事件是否有效。我知道RabbitMQ的用例是pub / sub。 ...

回答 2 投票 6

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