publish-subscribe 相关问题

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

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

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

msmq publish-subscribe masstransit

回答 1 投票 1

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

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

python mqtt publish-subscribe

回答 1 投票 1

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

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

google-cloud-platform cloud publish-subscribe google-cloud-pubsub

回答 1 投票 0

Spring Cloud PubSub无法发布到队列中

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

java spring spring-boot spring-cloud publish-subscribe

回答 1 投票 3

open62541：发布温度值

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

server publish-subscribe subscription opc-ua open62541

回答 1 投票 1

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

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

graphql apollo publish-subscribe

回答 1 投票 1

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

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

redis publish-subscribe

回答 1 投票 0

pub / sub中主题和宾语的顺序是什么？

我正在使用RxJava编写一些发布/订阅代码。我发现我们必须使用以下模式：observable.subscribe（observer），但据我了解，我们应该说一个句子，例如“ observer订阅...

rx-java publish-subscribe

回答 1 投票 0

Pubsub Java订阅者在空闲一天后停止接收

我有一个Java代码，通过执行程序提供程序来启动PubsubSubscriber。它的怠速运转时间约为16小时。但是，闲置约1天后，它停止接收来自订阅的消息。如果我...

java google-cloud-platform publish-subscribe google-cloud-pubsub

回答 1 投票 4

有没有一种方法可以使用python polling function提取http响应

我正在使用以下代码来轮询发布/订阅服务器导入请求polling2.poll（lambda：requests.get（'http://google.com'）.status_code == 200，step = 60，poll_forever = True）如果是这个...

python http publish-subscribe polling

回答 1 投票 0

GraphQL：如何从计划的议程作业中发布订阅

[我的问题也在稍后的议程中被问及触发Apollo订阅，但是没有答案，我没有足够的声誉在此发表评论。不确定该怎么办，所以我要发布...

node.js graphql publish-subscribe apollo-server agenda

回答 1 投票 0

发布-订阅设计模式如何在组件之间建立松散耦合？ C＃

[如果正在读一本C＃考试书，我读到：应用程序开发中一种流行的设计模式（一种可重复使用的解决方案）是发布-订阅模式。您可以...

c# design-patterns publish-subscribe

回答 1 投票 0

流星js汇总并发布

我想与meteor.js中的Reservations.userId = users._id的用户和预订集合进行内部联接。我想与用户集合中的userObj发布我的预订集合，所以我...

mongodb cursor aggregate publish-subscribe meteor-blaze

回答 2 投票 0

通过依次调用main函数并在它们之间进行通信来运行两个clojure代码

我在两个不同的文件夹中有两个clojure命名空间，它们都有自己的主要功能（因为我想生成类并最终创建一个jar）（ns reward-module.cli）和（ns nelson_clojure.cli）...

clojure port publish-subscribe channels

回答 1 投票 0

GCP消息在确认后停留在发布/订阅中

我将发布/订阅订阅逻辑封装在一个订阅方法中，该服务在每次订阅的服务初始化期间都会被调用一次：def subscription（self，callback：...

python-3.x google-cloud-platform publish-subscribe google-cloud-pubsub

回答 1 投票 0

在GCP PubSub中收到任何响应之前已超过重试总超时时间

我正在尝试使用@ google-cloud / pubsub模块在节点js中推送PubSub主题。这是Javascript代码const {pubsub} = require（'@ google-cloud / pubsub'）;类MyPubSub {构造函数（容器）...

node.js publish-subscribe google-cloud-pubsub

回答 1 投票 1

submit方法将不会调用onNext FLOW STREAM API JAVA

我正在学习Java中的FLOW Stream API，目前正在基于oracle社区的示例创建一个示例。问题是我看不到预期的输出，而只是...

java reactive-programming publish-subscribe java-9

回答 1 投票 1

限制某些白名单IP的订户连接到google pub sub中的Topic

我们如何限制某些白名单ip的订阅者有权访问google pub子主题？其他具有主题名称的程序正在从主题中读取消息，因此我们...

publish-subscribe google-cloud-pubsub

回答 1 投票 0

用于在pub sub pub / sub中对流数据进行计数的异步或同步pull]]

我想计算最近一小时的消息数（最后一小时是指消息数据中的时间戳字段）。我目前有一个代码，该代码将对邮件进行同步计数（I ...

publish-subscribe google-cloud-pubsub

回答 1 投票 0

接收消息ID（将来）是否指示消息已在PubSub中发送？

我正在使用回调函数将消息发送到google pubsub，该函数会从将来读取消息ID。使用以下代码：“”“使用...

publish-subscribe google-cloud-pubsub

回答 1 投票 0

publish-subscribe 相关问题

最新问题