publish-subscribe 相关问题

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

在nodejs中创建大量Google pubsub订阅者的推荐方法是什么?

我需要听大约40个订阅(在未来几天内,这个数量将增加)。如果只有一个订阅,那么我将执行以下操作,const subName ='...

回答 1 投票 0

使用Redis,Python和PHP的基于事件的邮件

我想经常将消息从Python组件发布到Redis服务器。然后,在另一个也可以访问此Redis服务器的PHP组件中,我想根据...

回答 1 投票 3

在脉冲星生产者上使用`SendAsync`方法时收到`收到邮件意外收到的邮件警告'

我有一个Pulsar主题,我正在通过多个生产者向其发布消息。这些生产者只是goroutines,我在生产者上使用SendAsync方法发送消息,但我保留...

回答 1 投票 0

CoAP发布/订阅传输可靠性

我正在做有关CoAP扩展的工作,使其可以使用发布/订阅代理模型,而我目前正在分析Transmision Reliabilty的完成方式。在CoAP中使用...

回答 2 投票 0

Terraform GCPt:值与主题名称中的正则表达式不匹配

我为我的警报创建了一个通知通道:资源“ google_monitoring_notification_channel”“ slack_notification_channel” {display_name =“ $ {var.project_name_prefix} -notification-channel” ...

回答 1 投票 0

合并中的连锁请求

我正在努力结合两个请求。我需要第一个ID,然后从接收到的列表中的第一个ID开始第二个ID。我找不到通过Swift Combine做到这一点的不错的解决方案。 ...

回答 1 投票 0

aws-放大PubSub.publish TypeError:无法读取未定义的属性'byteLength'

我正在尝试访问aws-amplify PubSub.publish以发布到AWS IoT Core中的主题。我正在使用版本“ aws-amplify”:“ 2.1.0”。 handleSubmit = async()=> {等待PubSub.publish('topic',{...

回答 1 投票 0

替换Redux时是否存在React(与状态相关)事件pub子模式?

在我看来,趋势是用React Context API和useReducer代替Redux。我个人不喜欢从用户数据状态到是否打开对话框都混在一起的根本存储空间。...

回答 2 投票 0

与nodejs的Azure Redis键空间通知问题

我正在尝试使用以下代码从Azure Redis密钥空间通知中获取所有通知,但是它没有收到任何通知,我检查了密钥,它是在Azure Redis中创建的...

回答 1 投票 0

我如何使用QUnit(或其他js单元测试框架)对发布/订阅进行单元测试

[就像标题说的那样,我想对我的JavaScript进行单元测试,如何隔离$ .publish()和$ .subscribe()调用?我现在正在使用QUnit,但是只有几个测试,所以我愿意...

回答 2 投票 1

在paho-mqtt中订阅和发布多个主题的最佳方法是什么?

我正在使用MQTT来干扰我的网络中的消息,并且对将多条消息发布和订阅到代理的最干净方法有疑问。首先,我有两个列表:request_list ...

回答 1 投票 0

即使关闭应用程序也试图保持MQTT客户端连接

我当前在我的Android应用程序中使用MQTT协议,当我的应用程序打开或在后台运行时,我能够接收消息,但是当我完全关闭我的应用程序时,连接......]

回答 1 投票 0

防止PyPubSub“死听器”错误

我正在Python项目中使用PyPubSub包,因此我可以在程序运行时向通道订阅方法并在这些通道上发布。作为压力测试的一部分,我将程序设置为运行在...

回答 1 投票 1

为什么重新连接后Pubnub心跳停止?

我的代码,该代码在重新启动wifi(基本上是重新连接互联网)之后重新连接PubNub,但您可以在下面的图片中看到我的第一个心跳停止。如果我在浏览器中打开链接,则会看到...

回答 1 投票 0

使用事件处理程序处理C#中的多个发布者

我目前正在尝试学习一些C#中的事件处理,并且我目前正在测试东西,并且已经创建了这个小测试程序。公共类消息:EventArgs {public ...

回答 1 投票 0

Rails和Postgresql,每当在不存在竞争条件的情况下在管理仪表板上创建新记录时通知/监听

我有一个管理控制台,我希望每当创建一个用户时(在单独的页面上)都会发出警报。下面的代码有效,但是,存在竞争条件。如果创建两个用户非常接近...

回答 1 投票 0


nodejs解构变量返回未定义

因此,我在nodejs中构建了一个区块链,当我运行该应用程序时,我的构造函数变量未定义传递,尽管我这样做是为了使它向下传递变量作为索引文件中的对象。 ...

回答 1 投票 0

ZMQ-python:一对一的推/拉

我正在使用以下代码尝试zmq,但是订户正在逐个获取对象。以下是我的PUSH脚本:#zmq服务器-一次运行即可运行zmq导入时间#服务器#...

回答 1 投票 1

ESP32 Arduino PubSub的可变字符数组发布错误?

我正在用Arduino编程ESP32,并正在使用标准的pubsubclient库发布MQTT消息。在下面的循环中,我注意到我的“内部循环”已发布,但是,第二个...

回答 1 投票 0

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