publish-subscribe相关内容

如何从Firebase Cloud功能在Google Pub / Sub中发布消息?

我编写了一个接收http请求并发送电子邮件的函数。但我想发送消息pubsub,但在文档中的示例只显示触发的pubsub请求,并且没有主机,端口,id,代理的passwd等信息。我想收到一个http请求并向移动设备发送一条发布消息,我认为这是mqtt。 exports.weeklyEmail = functions.https.onRequest((req,res)=> { const e ..

通过jQuery tiny PubSub传递数组

jQuery tiny PubSub 在传递原始值或对象时非常棒,但在使用数组时有些麻烦。所以我必须将数组包装到一个对象中。 (function($){ var o = $({ }); $ .subscribe = function(){ o.on.apply(o,arguments); }; $ .unsubscribe = function(){ o.off.apply( ..
发布时间:2019-05-27 11:34:54 前端开发

在发布功能中替换文档的属性

我正在使用meteor,我对发布功能(服务器端)有疑问 Meteor.publish(' users',function(){....} 我现在正在向浏览器发送文档具有其他集合的id。例如,任务文档属于项目 { title:'.. ..', projectId:'KjbJHvJCHTCJGVY234', ... } 我想要的是在此文档中 ..
发布时间:2019-05-27 11:18:28 前端开发

是否可以在JS脚本上接收Amazon SNS消息?

我知道在rails和/或node.js和PubNuB上使用ruby的一些选项,这是一种具有许多API的服务,因此您可以在(几乎)任何平台之间发送/接收通知。 我现在如何使用Amazon SNS从PHP发送消息以及如何在那里接收消息,但是如何在JS / jQuery脚本上接收推送通知(SNS消息)? 谢谢。 解决方案 是的,但不是直接的,你必须在计时器...... 在产品详 ..

流星,一对多关系&在发布中仅向客户端集合添加字段?

任何人都可以看到此代码中可能出现的问题,基本上我想检查当前登录用户是否共享了帖子并将一个临时字段添加到客户端集合中:isCurrentUserShared。 这是第一次加载新页面并从现有共享填充时,或者在加载页面时第一次添加或删除记录到Shares集合时。 1)isSharedByMe只更改状态1次,然后仍按照console.log调用回调,但isSharedByMe在第1次后没有在P ..
发布时间:2019-04-28 09:28:10 前端开发

如何在使用JS时隐藏pubnub键

我在pubnub打开了一张票,上面写着: https://help.pubnub.com/entries/22251291-Can-I-Hide-my-Application-Keys- 但我仍然无法理解如何阻止用户看到我的密钥,因为它仍然在客户端,即使在混淆之后。 我想要做的是我读到的东西这篇文章: PubNub在两个私人频道之间发布消息 为每个用户创建一个公共频道和私有频道 ..
发布时间:2019-04-27 14:56:03 PHP

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

假设存在对套接字服务器进行订阅的对象,如下所示: socket.on('news',obj.socketEvent) 这些对象的生命周期很短,经常被创建,产生许多订阅。这似乎是一个内存泄漏和容易出错的情况,这种情况可以通过这种方式直观地防止: socket.off('news',obj。删除对象之前的socketEvent) 但是,没有 off 套接字中的方法。还有其他方法 ..
发布时间:2019-01-24 00:19:57 前端开发

Meteor docs中的messages-count示例如何工作?

无法完全理解文档中的这个示例...我试过运行它一堆不同的方式,所以我可以观察它是如何工作的等等。 你如何订阅这个?我们可以包含使这项工作所需的客户端代码吗? 是否有一个名为 messages-count 的集合? 房间是一组消息吗?我们可以在示例中包含集合定义吗? 任何关于此的提示都会很棒! 注意:这是最初发布此问题时出现的代码(2012年5月)。它现在更简单。 / ..
发布时间:2019-01-22 19:55:52 前端开发

java中的轻量级发布/订阅框架

是否有一个提供发布/订阅模式的java的轻量级框架? 一些理想的功能 对泛型的支持 向发布者注册多个订阅者 API主要是接口和一些有用的实现 完全不需要内存,持久性和事务保证。 我知道JMS但是对我的需求来说太过分了。发布/订阅数据是扫描文件系统的结果,扫描结果被送到另一个组件进行处理,然后在被送到另一个组件之前进行处理,依此类推。 编辑: 所有这些都在同一个过程中 ..
发布时间:2018-12-10 11:31:12 Java开发

在RTI DDS上获取DataWriter / Publisher的IP地址?

我正在使用 RTI DDS 5.2.3.17 ,并希望获得 DataWriter / Publisher 的I​​P地址添加到一些日志消息。 我将如何做到这一点我在形成做什么的逻辑上遇到了一些麻烦? 解决方案 以标准化方式无法访问DataWriter的IP地址。但是,RTI上下文实现默认使用IP地址作为每个实体的全局唯一标识符(GUID)的一部分。 您可以找到有关GUID以及如 ..
发布时间:2018-09-26 14:30:51 其它硬件开发

如何设置最小CKSubscription?

我想设置一个简单的 CKSubscription ,通知我创建了 recordType ,怎么样? 解决方案 经过一段时间的实验,这是如何设置最小的CKSubscription。您必须在设备上测试它,推送通知在模拟器上不起作用。您可以在仪表板中添加记录,这也会触发推送通知。 func application(应用程序:UIApplication,didFinishLaunching ..

共享WCF服务和客户端之间的接口(标记为W / ServiceContract)

我正在使用VS2010和.NET 4.0。 我在这里查了一下(共享在WCF服务中实现的接口)但不同之处在于我正在尝试完成的工作涉及的接口是标有ServiceContract。 即在服务中,我有一个接口A(标记为ServiceContract)和一个扩展接口B(也标记为ServiceContract)。 B由WCF服务实现。 确切的扩展名如下: 公共接口A 公共 ..
发布时间:2018-08-03 16:19:19 C#/.NET

Google IoT - 接收通知的正确模式(订阅工作)

我正在关注本教程,我已经将代码发布到 / devices / sm1 / events 主题,其中 sm1 是我的设备ID。 我想知道如何订阅这个主题,因为本教程说使用 / devices / sm1 / config 但我收到空消息。我已经尝试使用发布时使用的相同“路径”( / devices / sm1 / events ),但它也不起作用。 奇怪的是,我给这个主题的名字是 sm1 ..

Google云端发布/子重试次数

我们正在从一个不稳定的消息队列服务转移到NodeJS中的Google Pub Sub。它似乎工作正常,但我们想包括错误处理。 我们想限制特定消息的重试次数,例如在我们的测试环境中10次生产100次。现在,如果一条消息失败了10次(测试中),而不是它坐在我们的队列中,并继续处理并失败7天,我们希望将其移至单独的错误队列并发送给我们一封电子邮件。 我们现在已将所有这些设置在我们以前的消息队 ..

使用微服务运行Google App Engine应用程序

我有一个庞大的monolith应用程序,现在是时候将一些模块分隔成微服务了! 我在Google文档中阅读了很多关于pub / sub和microservices的内容,但无法找到我的问题的答案: 如何app.yaml文件看起来像我的模块(微服务)? app.yaml如何为我的应用程序?(我的意思是,与微服务) 在哪里需要声明此模块 - 在应用程序app.yaml中还是在app.yaml ..
发布时间:2018-05-03 18:34:18 Python

Redis node.js - 链接调用以获取用户数据

我有一个用户数据库:用户可以拥有的配置文件,产品,配置和其他内容。我试图找出一种方法来成功连接我的redis调用(一个“getAll”函数),以便我可以返回一个所有这些东西的对象,如: user = { 个人资料:{}, 产品:{}, config:{}, ... } 这是我如何访问/我正在尝试做什么: / p> User.getAll = functio ..
发布时间:2017-09-03 02:16:19 开发方法