publish-subscribe相关内容

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

任何人都可以看到这段代码中可能有什么问题,基本上我想检查当前登录用户是否已共享帖子并向客户端集合添加一个临时字段:isCurrentUserShared. 这在加载新页面并从现有共享中填充时第一次起作用,或者在页面加载后仅在第一次向共享集合中添加或删除记录时. 1) isSharedByMe 仅更改状态 1 次,然后仍会根据 console.log 调用回调,但在我第一次添加或删除记录 ..
发布时间:2021-12-22 22:56:48 前端开发

当所有模板项目在 Meteor 中完成渲染时回调?

我正在获取一组记录并将它们放置在模板中,让它们呈现 {{#each}} 并且我想显示一个加载图标,直到呈现最后一个 DOM 节点. 我的问题是我还没有找到一种方法来查询状态/触发最后一项呈现的回调,也就是最后一个要更新/重新绘制的 DOM 节点. 它在我的 HTML 文件中看起来有点像这样: {{#每件物品}} {{cool_stuff}} ..
发布时间:2021-12-22 22:55:17 其他开发

流星集合获取返回空数组但已订阅

我卸载了自动订阅并重新启动了流星应用程序.从那以后,我一直无法在客户端访问我的集合数据. 每个与空数组返回相关的问题都会得到相同的答案:订阅的数据尚不可用.但无论我等多久,我都看不到客户端上的数据. 服务器: Meteor.startup(function () {Meteor.publish("states", function () {返回 states.find();});}) ..
发布时间:2021-12-22 22:51:52 其他开发

Observer、Pub/Sub 和数据绑定之间的区别

观察者模式、发布/订阅和 解决方案 以下是我对这三个方面的看法: 数据绑定 本质上,从本质上讲,这只是意味着“对象 Y 上的属性 X 的值在语义上绑定到对象 B 上的属性 A 的值.没有假设 Y 如何知道或馈送对象 B 上的更改. 观察者,或可观察者/观察者 一种设计模式,通过该模式,对象能够将特定事件通知其他人 - 通常使用实际事件完成,这些事件有点像对象中具有特 ..

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

各自的优缺点是什么?请建议何时使用一种而不是另一种. 解决方案 数据存储 Pub/Sub 是一个发布者/订阅者平台,它不是数据存储.无论是否有订阅者,已发布的消息都会消失. 在Redis Streams中,流是一种数据类型,本身就是一种数据结构.消息或条目存储在内存中并一直留在那里,直到被命令删除. 同步/异步通信(推/拉) Pub/Sub 是同步通信(推送 协议) ..
发布时间:2021-12-20 11:10:53 其他开发

使用 Promise 进行一次性事件处理?

非常常见的场景.我想要一些解耦的代码,即在准备就绪时触发事件.对于整个应用程序运行,这只会发生一次. 另一方面,还有另一段代码,我希望在触发两个或多个事件时发生其他事情.我的意思是像所有这些一样,像依赖一样. 好吧,更多的异步事情在一起......肯定是对的吗? 然后我开始思考.将 pub/sub 用于一次性事件真的明智吗?做出可访问的承诺不是更好,一旦该事件即将被触发就解决了吗 ..
发布时间:2021-12-19 22:57:31 前端开发

Azure 事件中心和多个消费者组

在以下场景中需要有关使用 Azure 事件中心的帮助.我认为消费者群体可能是这种情况的正确选择,但我无法在网上找到具体的例子. 这是问题的粗略描述以及使用事件中心的建议解决方案(我不确定这是否是最佳解决方案.感谢您的反馈) 我有多个事件源,它们生成大量事件数据(来自传感器的遥测数据),这些数据需要保存到我们的数据库中,并且一些分析(例如运行平均值、最小值-最大值)应该并行执行强>. ..
发布时间:2021-12-06 18:40:18 其他开发

Meteor:集合、变量、发布和订阅的名称之间的区别?

在 Discover Meteor 示例中,“帖子"和“帖子"之间的区别是什么?为什么当我们从服务器插入时我们使用“posts",而当从浏览器查询时我们使用“Posts"?系统不会被大小写差异混淆吗? 我在posts.js 中看到了客户端帖子到服务器帖子的变量分配.将客户端大写并使用小型大写字母表示服务器是一种传统的表示法吗? Posts = new Meteor.Collection(' ..
发布时间:2021-12-05 18:17:31 其他开发

Meteor 文档中的消息计数示例如何工作?

无法完全理解 文档 中的这个示例......我尝试运行它一堆不同的方式,所以我可以观察它是如何工作的,等等. 你如何订阅这个?我们可以包含使这项工作正常工作所需的客户端代码吗? 是否有一个名为 messages-count 的集合?Room 是消息的集合吗?我们可以在示例中包含集合定义吗? 任何有关此的提示都会很棒! 注意:这是最初发布此问题时(2012 年 5 月)出现的 ..
发布时间:2021-12-05 17:53:47 前端开发

了解 Meteor 发布/订阅

我有一个简单的应用程序设置,它显示了一个 项目 列表.我已经删除了 autopublish 包,这样我就不会向客户端发送所有内容. {{#每个项目}}{{姓名}}{{/每个}} 当 autopublish 开启时,这将显示所有项目: if Meteor.isClientTemplate.projectsIndex.projects = Projects.find() 删除后,我还必须做: ..
发布时间:2021-12-05 17:39:03 前端开发

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

扩展PUB/SUB拓扑 在一个有 1 个中介的用例中,我有多个发布者和多个订阅者. 在 ZeroMQ 指南中,我了解了如何使用额外的 REQ/REP 套接字同步 1 个发布者和 1 个订阅者.我尝试为我的用例编写同步代码,但是如果我尝试根据 1-1 PUB/SUB 给出的逻辑编写代码,它会变得混乱. 当我们只有 1 个发布者时的发布者代码是: //接收同步请求的套接字zmq:: ..

“通知和检查"的名称发布订阅架构?

基本的发布订阅架构问题.在高层次上,在设计 pubsub 时,我有时会面临两种架构之间的选择: 发布突变或“新状态". 某些数据库状态发生了变化,发布者通过 pubsub 通知该更改.但是它们在消息中包含了足够的信息,因此订阅者不需要在数据库上进行查找.想象一下,订阅者有一个数据库缓存.它可以接收突变或新状态,并在不进行查找的情况下更新其缓存. 我的问题是,这两种类型的架构有通用 ..

zmq 与 redis 的 pub-sub 模式

redis 支持 发布订阅 zmq 还支持 通过消息代理发布订阅 在它们之间进行选择的架构优点\缺点是什么? 我的目标是超出明显的用例特定性能基准测试应该完成的点(这里是 一个很好的例子). 假设使用 Python 等高级语言. 解决方案 我使用 Python 处理过 ZeroMQ 和 Redis.我会说 ZeroMQ 更健壮,它提供了真正简单的负载平衡,而且不仅仅是发布- ..

Lagom 使用 Kafka 发布消息

此处仅描述了一种发布方式.还有别的方法吗?我需要使用动态主题 ID 和自定义事件制作发布而不使用 persistentEntityRegistry 的示例?以及如何使用 eventId 发布事件? @Override默认描述符描述符(){返回named("helloservice").withCalls(pathCall("/api/hello/:id", this::hello),pathC ..
发布时间:2021-11-12 03:22:22 Java开发

Kafka 有持久订阅功能吗?

我有兴趣在我的一个项目中使用 Kafka,但是当其中一个订阅者(消费者)断开连接时,消息代理必须保留这些消息. 我看到 JMS 有这个功能. 在网站上说 Kafka 具有耐用性特性. 是和JMS一样还是意思不同? 解决方案 Consumer 从 kafka(brokers)拉取数据.消费者指定它想要收集数据的位置的偏移量.如果消费者断开连接并返回,它可以从离开的地方继续. ..
发布时间:2021-11-12 02:55:20 其他开发