publish-subscribe相关内容

如何知道流星中向客户端发送了哪些文档

我有一个出版物，它根据 start 和 limit 发送有限数量的记录 Metero.publish("posts",function(start,limit){return Posts.find({},{"start":start,"limit":limit});}); 我订阅了 autorun 功能中的发布功能. 我的问题是我在客户端中已经很少有 posts 集合的记录，它被另一个 ..
发布时间：2021-06-02 21:09:19 其他开发

使用虚假的即发即忘数据加载 Meteor 客户端应用程序

我正在尝试找出一种好方法来创建使用 Meteor 应用程序的教程.从视觉上看，我想出了一个很好的方法，并将其打包成一个智能包: https://github.com/mizzao/meteor-tutorials. 然而，事实证明还有第二个部分很难弄清楚. 在许多情况下，教程应用需要加载虚假数据，以向用户展示界面，而无需填充可能难以生成的真实数据.(例如，请参阅 https:// ..
发布时间：2021-06-02 20:56:15 其他开发

从客户端保护对集合的访问

我有一个运行良好的流星应用程序原型，但目前非常不安全:我需要显示与当前登录用户匹配的用户列表.首先，我决定发布所有用户，将字段限制为在客户端过滤用户列表所需的字段. Meteor.publish('users', function () {返回 Meteor.users.find({}, {字段:{'profile.picture': 1,'profile.likes': 1,'profile. ..
发布时间：2021-06-02 20:44:59 其他开发

使用 mosca MQTT 请求响应模式

是否有任何方法可以使用 mosca MQTT 实现请求-响应模式，以“检查来自客户端的回复并重新发布，如果我在预期时间内没有收到预期回复". 我相信这在 Mqtt 5 中是可能的，但截至目前，我必须使用具有 QoS 1 的 Mosca 代理(支持直到 Mqtt 3.1.1) 我正在寻找一种 Node js 解决方法来实现这一点. 解决方案 根据我的评论，您可以使用任何 MQTT ..
发布时间：2021-06-02 20:30:21 其他开发

从.net客户端订阅IBM MQ主题

如何在订阅者模型中从.net客户端订阅IBM MQ主题 我已经有一个代码的工作副本，可以从该主题获取消息. 字符串qmName ="Q1";字符串hostName ="MyHost";字符串strPort ="1114";字符串channelName ="MyCh";字符串传输= TRP;Hashtable connectionProperties = new Hashtable();co ..
发布时间：2021-05-15 19:23:16 C#/.NET

具有不同消息类型的Google Cloud Pub/Sub

在同一应用程序中，我发送格式完全不同且完全不相关的不同消息类型.解决此问题的最佳实践是什么? 我在这里看到两种不同的方法: 应用程序级别的过滤器，这意味着我在同一个合并器(相同订阅)上收到所有消息 创建一个新的订阅，这意味着该应用程序将有两个正在运行的Puller(每种消息类型一个) 解决方案 您用2点回答了您的问题.如果消息格式具有完全不同的格式并且完全不相关，则意味着应将 ..
发布时间：2021-05-12 19:54:42 其他开发

我已经从Pub/Sub主题创建了Cloud Function，如果函数失败，是否应该重试从pub/sub传递消息?

我有一个带有简单测试代码的函数，例如: exports.helloPubSub =(事件，上下文)=>{常量消息= event.data?Buffer.from(event.data，'base64').toString(): '你好，世界';console.log(context);抛出新的错误(“失败")；}; 当我向发布/订阅发布消息时，该函数失败，并且由于发布/订阅订阅的确认截止时 ..
发布时间：2021-05-12 19:40:45 其他开发

我可以通过具体方法订阅通用操作吗?

有关此问题的更清晰措辞，请参见谜题的答案. 我要注册一个通用的 Action ，然后将其转换为期望的类型: 公共接口IMyInterface {}公共静态ActionMyAction;公共类MyClass:IMyInterface {}公共无效Subscribe(){MyAction+ = MyMethod;}公共无效MyMethod(IM ..
发布时间：2021-05-10 19:01:02 C#/.NET

在高速公路的pubsub中获取初始值的设计模式

通常，发布-订阅模式与获取内容更新有关.但是，订阅者如何获得订阅更新之前的初始内容? 我在我的应用程序的高速公路框架内使用发布-订阅示例.当关节移动时，发布者后端发布机器人关节的位置.客户端前端有时稍后会订阅该主题.由于数据的性质，客户端上“主题"的初始值与发布者随后进行的更新一样重要.因此，在建立成功的连接之后，我想获取该主题的“当前"值. 框架内是否可以使用某种类型的设计模式来获取 ..
发布时间：2021-04-30 19:28:15 其他开发

“通知和检查"的名称pubsub体系结构?

基本pubsub体系结构问题.从较高的角度来看，在设计pubsub时，有时会在两种体系结构之间做出选择: 发布突变或“新状态". 某些数据库状态发生了变化，发布者通过pubsub通知了该更改.但是它们在消息中包含足够的信息，因此订户不需要在DB上进行查找.假设订户具有数据库的缓存.它可以接收突变或新状态，并在不进行查找的情况下更新其缓存. 通知并检查发布者仅通知“有新变化"，这提 ..
发布时间：2021-04-09 19:04:20 其他开发

是否有用于angular的事件发布/订阅框架?

我来自WPF背景，在Prism中，您具有IEventAggregator接口.您定义可以从控制器预订的事件，然后从另一个控制器发布该事件.这是彼此不认识的控制器之间进行通信的一种方式. Angular JS中有类似的东西吗? 我有一个index.html页面的顶级控制器，该页面包含三个子面板，每个子面板都有自己的控制器.我希望顶级控制器能够在面板控制器上调用refresh()，但是它没有对 ..
发布时间：2021-04-07 19:15:28 C#/.NET

如何从Java程序创建对ibm mq amqp主题的持久订阅?

我们通过提供 clientId 和订户名称，使用 createDurableSubscriber 以编程方式创建了IBM MQ AMQP主题的订户. 我们启动了程序，因此它订阅了TOPIC并停止了该程序.然后将msg发送到主题，然后再次启动接收器程序，但是我们无法接收已发送的msg，并释放消息(如果持久订阅则不会发生此消息). 使用mqsc命令连接订户时，我们可以看到amqp主题及其持 ..
发布时间：2021-04-03 20:04:50 Java开发

SubmissionPublisher在提交时未调用onNext订阅者

每隔一段时间，我都会通过某个查询来检索推文. 这些推文必须传递给计算和处理这些推文的服务. 因此，这些服务已订阅我的发布者.因此Publisher.hasSubscribers()返回true.但是Submit或offer函数不会调用我的订阅者的onNext. 因此，作为“修复"，我循环浏览订户并自己调用它.但这不是事实. 这是我的发布者的构造函数. public TwitterSt ..
发布时间：2021-02-10 19:05:08 Java开发

HTTP中的多个响应合法吗?

我对HTTP协议的细微差别感到生锈，我想知道它是否可以直接支持发布/订阅? HTTP是请求响应协议.因此，客户端发送一个请求，服务器发送回一个响应. 在HTTP 1.0中，为每个请求建立了新的连接. 现在，HTTP 1.1通过允许客户端保持连接打开并发出多个请求来对HTTP 1.0进行了改进. 我意识到您可以将HTTP连接升级到websocket，以进行快速的2向通信.我很好奇的是，这 ..
发布时间：2020-11-24 23:05:59 其他开发