jjzjj

mongodb - meteor 发布/订阅行为

coder 2023-11-06 原文

我目前正在我的应用程序中实现实时搜索功能，但我遇到了一些让我感到困惑的行为。

背景是:我的服务器上有两个来自同一个 MongoDB 数据库的订阅，名为 posts。

  1. 第一个订阅订阅最新的50篇帖子，并将数据发送到MiniMongo集合Posts。

  2. 第二个订阅订阅匹配用户输入的任何搜索的帖子，并将此数据发送到 MiniMongo 集合 PostsSearch，如下所示。

    // client

Posts = new Mongo.Collection('posts');

PostsSearch = new Mongo.Collection('postsSearch');

// server

Meteor.publish('postsPub', function(options, search) {

    return Posts.find(search, options);

});

Meteor.publish('postsSearchPub', function(options, search) {

    var self = this;

    var subHandle = Posts.find(search, options).observeChanges({

        added: function (id, fields) {

            self.added("postsSearch", id, fields);

        }

    });

    self.ready();
});

我的问题是，我们从文档中知道:

If you pass a name when you create the collection, then you are declaring a persistent collection — one that is stored on the server and seen by all users. Client code and server code can both access the same collection using the same API.

但是 PostsSearch 不是这种情况。当用户开始在客户端上搜索时，该功能会按预期完美运行——正确的光标会发送到客户端。

但是，我在我的 MongoDB 数据库中没有看到 postsSearch，同样，PostsSearch 没有在我自己以外的任何其他客户端上填充。

这是怎么回事？什么是 self.added("postsSearch", id, fields); 似乎可以将游标发送到客户端而不是 MongoDB 数据库。

最佳答案

根据这个doc , self.added("postsSearch", id, fields); 通知客户端文档已添加到 postsSeach 集合.

并根据Meteor.publish :

Alternatively, a publish function can directly control its published record set by calling the functions added (to add a new document to the published record set), ...

所以我猜测 self.added 执行了这两个操作:将文档添加到已发布的记录集，并通知客户端(已订阅当前出版物)。

现在如果你看到 Meteor.subscribe :

When you subscribe to a record set, it tells the server to send records to the client. The client stores these records in local Minimongo collections, with the same name as the collection argument used in the publish handler's added, changed, and removed callbacks. Meteor will queue incoming records until you declare the Mongo.Collection on the client with the matching collection name.

这表明两件事:

  1. 您必须订阅才能从服务器端数据库接收数据。

  2. 必须存在某种客户端代码才能创建仅限客户端的 postsSearch 集合。 (这是因为你说了，服务器端数据库中不存在这个集合)。

第二点很容易实现，例如:

if(Meteor.isClient) {
  postsSearch = new Mongo.Collection(null);
}

在上面的例子中，postsSearch 集合将只存在于客户端，而不存在于服务器。

关于第一个，订阅 postsSearchPub 会自动将 postsSearch 集合的数据发送到客户端(即使服务器中不存在该集合-端数据库。这是因为显式调用了 self.added)。

要检查的东西:根据这个doc , self.ready(); 调用订阅的onReady 回调。看看这个回调中有什么会很有用，也许客户端专用的 postsSearch 集合定义在那里？

关于mongodb - meteor 发布/订阅行为，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35670372/

mongodbmeteorcodepostsSearchsectionminimongo

有关mongodb - meteor 发布/订阅行为的更多相关文章

  1. ruby - 如何根据特征实现 FactoryGirl 的条件行为 - 2

    我有一个用户工厂。我希望默认情况下确认用户。但是鉴于unconfirmed特征，我不希望它们被确认。虽然我有一个基于实现细节而不是抽象的工作实现，但我想知道如何正确地做到这一点。factory:userdoafter(:create)do|user,evaluator|#unwantedimplementationdetailshereunlessFactoryGirl.factories[:user].defined_traits.map(&:name).include?(:unconfirmed)user.confirm!endendtrait:unconfirmeddoenden

  2. 世界前沿3D开发引擎HOOPS全面讲解——集3D数据读取、3D图形渲染、3D数据发布于一体的全新3D应用开发工具 - 2

    无论您是想搭建桌面端、WEB端或者移动端APP应用，HOOPSPlatform组件都可以为您提供弹性的3D集成架构，同时，由工业领域3D技术专家组成的HOOPS技术团队也能为您提供技术支持服务。如果您的客户期望有一种在多个平台（桌面/WEB/APP，而且某些客户端是“瘦”客户端）快速、方便地将数据接入到3D应用系统的解决方案，并且当访问数据时，在各个平台上的性能和用户体验保持一致，HOOPSPlatform将帮助您完成。利用HOOPSPlatform，您可以开发在任何环境下的3D基础应用架构。HOOPSPlatform可以帮您打造3D创新型产品，HOOPSSDK包含的技术有：快速且准确的CAD

  3. ruby-on-rails - 如何在发布新的 Ruby 或 Rails 版本时收到通知？ - 2

    有人知道在发布新版本的Ruby和Rails时收到电子邮件的方法吗？他们有邮件列表，RubyonRails有一个推特，但我不想听到那些随之而来的喧嚣，我只想知道什么时候发布新版本，尤其是那些有安全修复的版本。 最佳答案 从therailsblog获取提要.http://weblog.rubyonrails.org/feed/atom.xml 关于ruby-on-rails-如何在发布新的Ruby或Rails版本时收到通知？，我们在StackOverflow上找到一个类似的问题：

  4. ruby - Ruby gsub 替换中的行为不一致？ - 2

    两个gsub产生不同的结果。谁能解释一下为什么？代码也可在https://gist.github.com/franklsf95/6c0f8938f28706b5644d获得.ver=9999str="\tCFBundleDevelopmentRegion\n\ten\n\tCFBundleVersion\n\t0.1.190\n\tAppID\n\t000000000000000"putsstr.gsub/(CFBundleVersion\n\t.*\.).*()/,"#{$1}#{ver}#{$2}"puts'--------'putsstr.gsub/(CFBundleVersio

  5. ruby-on-rails - Ruby 中意外的大小写行为 - 2

    我在一段非常简单的代码(如我所想)中得到了一个错误的值:org=4caseorgwhenorg=4val='H'endputsval=>nil请不要生气，我希望我错过了一些非常明显的东西，但我真的想不通。谢谢。 最佳答案 这是典型的Ruby错误。case有两种被调用的方法，一种是你传递一个东西作为分支的基础，另一种是你不传递的东西。如果您确实在case中指定了一个表达式语句然后评估所有其他条件并与===进行比较.在这种情况下org评估为false和org===false显然不是真的。所有其他情况也是如此，它们要么是真的，要么是假的。

  6. ruby - 使对象的行为类似于 ruby​​ 中并行分配的数组 - 2

    假设您在Ruby中执行此操作:ar=[1,2]x,y=ar然后，x==1和y==2。是否有一种方法可以在我自己的类中定义，从而产生相同的效果？例如rb=AllYourCode.newx,y=rb到目前为止，对于这样的赋值，我所能做的就是使x==rb和y=nil。Python有这样一个特性:>>>classFoo:...def__iter__(self):...returniter([1,2])...>>>x,y=Foo()>>>x1>>>y2 最佳答案 是的。定义#to_ary。这将使您的对象被视为要分配的数组。irb>o=Obje

  7. ruby - 了解在 Ruby 中与 lambda 一起使用的 inject 行为 - 2

    我经常将预配置的lambda插入可枚举的方法中，例如“map”、“select”等。但是“注入(inject)”的行为似乎有所不同。例如与mult4=lambda{|item|item*4}然后(5..10).map&mult4给我[20,24,28,32,36,40]但是，如果我制作一个2参数lambda用于像这样的注入(inject)，multL=lambda{|product,n|product*n}我想说(5..10).inject(2)&multL因为“inject”有一个可选的单个初始值参数，但这给了我......irb(main):027:0>(5..10).inject

  8. ruby - 奇怪的 ruby​​ for 循环行为(为什么这样做有效) - 2

    defreverse(ary)result=[]forresult[0,0]inaryendresultendassert_equal["baz","bar","foo"],reverse(["foo","bar","baz"])这行得通，我想了解原因。有什么解释吗？ 最佳答案 如果我使用each而不是for/in重写它，它看起来像这样:defreverse(ary)result=[]#forresult[0,0]inaryary.eachdo|item|result[0,0]=itemendresultendforainb基本上就

  9. ruby-on-rails - 获取 ActionController::RoutingError(当尝试使用 AngularJS 将数据发布到 Rails 服务器时，没有路由匹配 [OPTIONS] "/users" - 2

    尝试从我的AngularJS端将数据发布到Rails服务器时出现问题。服务器错误:ActionController::RoutingError(Noroutematches[OPTIONS]"/users"):actionpack(4.1.9)lib/action_dispatch/middleware/debug_exceptions.rb:21:in`call'actionpack(4.1.9)lib/action_dispatch/middleware/show_exceptions.rb:30:in`call'railties(4.1.9)lib/rails/rack/logg

  10. iNFTnews | 周杰伦18年前未发布的作品Demo，藏在了区块链技术里 - 2

    当音乐碰上区块链技术，会擦出怎样的火花？或许周杰伦已经给了我们答案。8月29日下午，B站独家首发周杰伦限定珍藏Demo独家访谈VCR，周杰伦在VCR里分享了《晴天》《青花瓷》《搁浅》《爱在西元前》四首经典歌曲Demo背后的创作故事，并首次公布18年前未发布的神秘作品《纽约地铁》的Demo。在VCR中，方文山和杰威尔音乐提及到“多亏了区块链技术，现在我们可以将这些Demos，变成独一无二具有收藏价值的艺术品，这些Demos可以在薄盒（国内数藏平台）上听到。”如何将音乐与区块链技术相结合，薄盒方面称：“薄盒作为区块链技术服务方，打破传统对于区块链技术只能作为数字收藏的理解。聚焦于区块链技术赋能，在

随机推荐