publish-subscribe相关内容

如果pubsub主题不可用，则引发未找到异常

我正在使用Spring Boot与pubsub主题进行交互. 此连接的配置类如下: import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.cloud.gcp.pubsub.core.PubSubTemplate; import org.springframework.clo ..

发布时间：2020-11-18 21:52:10 spring publish-subscribe google-cloud-pubsub 其他开发

Google Cloud Pub-Sub的Avro讯息?

什么是发布到Pub-Sub和从Pub-Sub消费的最佳数据格式?我正在查看Avro消息格式，因为它是二进制格式. 用例是会有实时的微服务应用程序将Avro消息发布到pub-sub.考虑到avro消息最适合在批处理消息(以及二进制消息附带的架构)然后发布消息时使用，对于涉及微服务的这种用例来说，这是否是一种更合适的格式? 解决方案 对于在所有用例中用于消息的最佳格式，将没有一个正确的答案. ..

发布时间：2020-11-18 21:12:51 google-cloud-platform google-cloud-messaging publish-subscribe google-cloud-pubsub 其他开发

Google Pub/Sub每约5条消息仅发送一个订阅

我已经使3个客户端连接到一个订阅，以及1个发布者.在图像2中，订阅位于终端上，并且看不到一个订阅，因为它托管在DigitalOcean Droplet上.似乎每5条消息，它切换哪个订户实际接收到该消息，这不应该发生.我也改变了速度，它总是大约5条消息. 以下是所有客户端上用于订阅的代码: sub.on("message", (msg) => { console.log(`Messa ..

发布时间：2020-11-18 20:35:19 google-cloud-platform publish-subscribe google-cloud-pubsub 其他开发

Google Pub/Sub推送订阅到受IAP保护的App Engine中

我正在测试一个非常基本的发布/订阅订阅.我已将推送端点设置为已通过App Engine中的Python Flex服务部署的应用程序.该服务位于启用了身份识别代理的项目中. IAP配置为允许通过我们的域认证的用户. 我的应用程序未处理任何推送请求. 我关闭了IAP保护，然后看到请求已处理.我重新打开它，它们将不再被处理. 尝试使Cron服务运行时，IAP存在类似问题；在同一个项目中 ..

发布时间：2020-11-16 23:44:53 python google-app-engine push publish-subscribe google-iap Python

我想通过Google Cloud Pub/Sub API接收新的Gmail通知

我在googleapis上经历了非常糟糕的经历，失去了一个星期，但是失败了，所以我提出了一些问题以寻求大家的帮助. 创建主题后&从Google Cloud Flatform Console的PUB/SUB订阅(带有端点URL)，我使用了代号为bellow的nodejs: var gmail = google.gmail({ auth: {---my auth---}, version: ' ..

发布时间：2020-11-16 03:14:20 node.js publish-subscribe gmail-api 其他开发

在Orion负载平衡方案中，订阅和通知的行为是什么?

基于有关如何通过负载平衡扩展Orion Context Broker的答案， https://stackoverflow.com/a/33068119/3706998 订阅和通知的行为应该是什么? 女巫服务器应该来自哪里?什么是工作流程? 是否会导致某些订阅混乱或克隆? 解决方案 让我们考虑不同的情况，具体取决于订阅缓存的使用情况.让我们考虑不失一般性的两个Orion节点(A和 ..

发布时间：2020-11-08 05:42:16 publish-subscribe fiware fiware-orion 其他开发

ZeroMQ订阅服务器未通过inproc：传输类接收到发布者的消息

我对 pyzmq 很陌生。我试图理解 inproc： 运输类，并创建了此示例示例以供使用。 看起来 Publisher 实例正在发布消息，但 Subscriber 实例不接收任何实例。 如果我移动了 Subscriber 实例进入单独的 进程 ，并将 inproc：更改为 tcp： 运输类，该示例有效。 这里是代码： 导入线程 导入时间 导入zmq contex ..

发布时间：2020-10-22 19:01:08 zeromq publish-subscribe distributed-computing pyzmq low-latency 其他开发

直接与最终用户客户端一起使用消息代理

我想找到一种方法，以从服务器向同一终端的多个最终用户客户端实施推送消息。 我发现的一种选择是使用消息代理并使用它来实现 pub / sub 模式。在这种情况下，我不确定应该被认为是消费者。 我认为使用消息代理时的一般体系结构是： 最终用户客户端消息代理服务器（客户端和服务器也可以在与主题消息无关的事情上互相交谈） 我至少认为应该发生的过程是这样的： ..

发布时间：2020-10-21 02:04:42 design-patterns publish-subscribe messagebroker 其他开发

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

我有2个不同的类，需要在main方法中订阅事件。但是我没有在main方法中订阅事件。有人知道怎么做吗？ 第一类 *********** 公共类数据 { 公共字符串ID {得到;组; } 公共字符串说明{get;组; } } 公共类ClsSub { 公共委托void datahandler（Data dt）; 公共事件LogHandler OnDataRetrieve ..

发布时间：2020-10-20 01:17:48 c# .net events delegates publish-subscribe C#/.NET

ejabberd：为什么Websocket连接无法打开

我正在尝试从Strophe.js到Ejabberd建立Websocket连接，但是ejabberd无法建立Websocket连接。 以下是详细信息： ejabberd版本：16.02 Web套接字标题 常规 请求URL：ws：// localhost：5280 / websocket 请求方法：GET 状态码：101交换协议 响应标题 连接 ..

发布时间：2020-10-01 03:54:07 websocket chat publish-subscribe ejabberd 其他开发

使用WCF回调和asp.net来实现发布/订阅模式

这是我使用WCF的第一个Web应用程序。因此，请以新手身份指导我。 我正在尝试使用WCF回调实现发布/订阅模式。我现在想将消息从UserA发送到UserB或将UserA发送给每个客户端。我从此处。 在我的应用程序中，我改用ASP.NET作为客户端连接WCF服务，订阅WCF服务时发现问题。 WCF服务不包含任何其他客户端对象。因此，当我调用 GetAllClients（_guid） ..

发布时间：2020-09-29 00:03:34 asp.net wcf callback publish-subscribe C#/.NET

Redis Pub / Sub和Redis Stream之间的主要区别是什么？

各自的优缺点是什么？ 请建议何时使用一个而不是另一个。 解决方案 数据存储 Pub / Sub是发布者/订阅者平台，它不是数据存储。无论是否有订阅者，发布的消息都会消失。 在Redis Streams中，stream是一种数据类型，它本身就是一种数据结构。消息或条目存储在内存中，并保留在那里直到被命令删除。 同步/异步通信 发布/订阅是同步通信。各方需要同时处于活 ..

发布时间：2020-09-28 04:52:46 database caching redis publish-subscribe 其他开发

XMPP书签的自动加入选项不起作用

我正在尝试使用XEP-0048自动加入会议室-书签( http://xmpp .org/extensions/xep-0048.html ). 我正在使用RobbieHanson XMPPFramework，ejabberd v13.x 到目前为止，我已经可以使用以下代码向房间添加书签: -(void) createBookmarkforRoom:(NSString *)roomJid ..

发布时间：2020-09-22 03:37:55 xmpp publish-subscribe bookmarks ejabberd xmppframework 其他开发

每个制作人的Kafka主题

让我说我有多个设备.每个设备具有不同类型的传感器.现在，我想将每个传感器的每个设备的数据发送到kafka.但是我对卡夫卡话题感到困惑.用于处理此实时数据 每个设备都具有kafka主题是否很好，并且该设备中的所有传感器都会将数据发送到特定的kafka主题，或者我应该创建一个主题，并让所有设备将数据发送到该主题. 如果我采用第一种情况，我们将为每个设备创建主题， 设备1(传感器A，B ..

发布时间：2020-09-20 19:34:07 apache-kafka real-time scalability publish-subscribe bigdata 其他开发

Redis与Service Bus的发布/订阅场景

我在Azure中有几项服务，我想使用某种发布/订阅服务在它们之间同步更改. 我正在研究Redis和Azure Service Bus. 要同步的数据非常简单-大多数字符串最多为100个字符 我想知道什么是我的首选-或者我的方向是否正确. 我的要求很简单: 低延迟-许多小操作 可选-能够在本地而不是在Azure中安装解决方案 解决方案 请勿为此使用Redis. ..

发布时间：2020-09-17 19:26:19 azure redis publish-subscribe azureservicebus 其他开发

使用Python发布到Azure IoT中心-使用C#订阅不起作用

我使用M2MQTT Paho Python库在设备上发布，如下所示: msg = "POS {} {} {} {} {} {} {}" msgtosend=msg.format(tagNum, tagID, x_pos, y_pos, z_pos, qos, unk) print(msgtosend) # qos=1 - (must be when clea ..

发布时间：2020-09-17 05:42:31 c# python-3.x publish-subscribe azure-iot-hub C#/.NET

Azure IoT中心-“订阅"代码不起作用:“连接被拒绝"；

当一些数据发布到MQTT主题devices/device_id/messages/events/时，我试图从IoT中心接收“通知".为了接收数据，我使用以下主题:devices/device_id/messages/devicebound/.我的订阅代码如下(Python): import paho.mqtt.client as mqtt import ssl, random from ti ..

发布时间：2020-09-16 02:13:39 azure iot publish-subscribe azure-iot-hub subscribe 其他开发

如何在c ++中的ZeroMQ中以扩展的PUB-SUB模式与Intermediary同步发布者和订阅者?

扩展的PUB/SUB拓扑 在一个具有1个中介的用例中，我有多个发布者和多个订阅者. 在ZeroMQ指南中，我了解了如何使用其他 REQ/REP 套接字同步1个发布者和1个订阅者.我尝试为用例编写一个同步代码，但是如果我尝试根据1-1 PUB/SUB给出的逻辑编写代码，则会变得很混乱. 只有1个发布者时的发布者代码为: //Socket to receive sync reques ..

发布时间：2020-09-06 19:42:51 c++ architecture synchronization zeromq publish-subscribe C/C++开发

角组件继承和继承订阅

下面是一个组件，我将在其他多个组件中进行扩展，以便重用一些代码. import { Component } from '@angular/core'; @Component ({ selector: 'my-app', template: ` {{appTitle}} To Tutorials Point ..

发布时间：2020-08-31 06:58:16 angular inheritance publish-subscribe subscription 其他开发

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

我一直在使用Angular，一直在尝试寻找一种在整个组件树中使用pub/sub机制的方法. 似乎EventEmitter仅发出可以预订到更高级别的事件-但不能更多.同样，它仅将事件向上发射到树上，而现在向下发射. 朋克车 相关代码在这里: class App { onAncestor($event) { console.log('in ancestor, de ..

发布时间：2020-08-31 06:51:31 angular publish-subscribe 其他开发