meteor实例—7—发布(Publication)和订阅(Subscription)

发布(Publication)和订阅(Subscription)是 Meteor 的最基本最重要的概念之一,但是如果你是刚刚开始接触 Meteor 的话,也是有些难度的。这已经导致不少误解,比如认为 Meteor 是不安全的,或者说 Meteor 应用无法处理大量数据等等。
人们起初会感觉这些概念很迷惑很大程度上是因为 Meteor 像变魔法一样替你做了很多事儿。尽管这些魔法最终看起来很有效,但是它们掩盖了后台真正做的工作(好像魔术一样)。所以让我们剥去魔法的外衣来看看究竟发生了什么。
过去的日子
首先,让我们回顾一下2011年之前,当 Meteor 还没有诞生的时候的老日子。比如说我们要建立一个简单的 Rails app。当用户来我们的站点,客户端(举例说浏览器)向我们的服务器端的 app 发送请求。
App 的第一个任务就是搞清楚这个客户请求什么数据。这个可能是搜索结果的第12页、玛丽的用户信息、鲍勃的最新20条微博,等等等等。 你可以想想成为一个书店的伙计在书架之间帮你寻找你要的书。
当正确的数据被找到,这个 App 的下一个任务就是把数据转换成好看的,人类可读的 HTML 格式(对于 API 而言是 JSON 串)。
用书店来举例,那就相当于是把你刚买的书包好,然后装入一个漂亮的袋子。这就是著名的 MVC(模型-视图-控制器)模式中的视图部分。
最终,App 把 HTML 代码送到客户端。这个 App 的任务也就交差了。它可以去买瓶啤酒然后等着下一个请求。
Meteor 的方式
让我们看看 Meteor 相对之下是多么的特别。正如我们看到的,Meteor 的关键性创新在于 Rails 程序只跑在服务器上,而一个 Meteor App 还包括在客户端(浏览器)上运行的客户端组件。

推送数据库子集到客户端
这就相当于书店的伙计不仅仅在书店里帮你找书,还跟你回家,每天晚上读给你听(这听起来怪怪的)。
这种架构可以让 Meteor 做更多很酷的事情,其中一件主要的就是 Metoer 变得数据库无处不在。简单说,Meteor 把你的数据拿出一部分子集复制到客户端。
这样后两个主要结果:第一,服务器不再发送 HTML 代码到客户端,而是发送真实的原始数据,让客户端决定如何处理线传数据(http://docs.meteor.com/#sevenprinciples) 。第二,你可以不必等待服务器传回数据,而是立即访问甚至修改数据(延迟补偿 latency compensation (http://docs.meteor.com/#sevenprinciples) )。

发布
一个 App 的数据库可能用上万条数据,其中一些还可能是私用和保密敏感数据。显而易见我们不能简单地把数据库镜像到客户端去,无论是安全原因还是扩展性原因。
所以我们需要告诉 Meteor 那些数据子集是需要送到客户端,我们将用发布功能来做这个事儿。
让我们来回到 Microscope。

尽管实际上不存在但是我们还是假设我们的帖子中有几条因为言语不当被打了特殊标记的。我们需要把他们留在数据库中但是不希望让用户看到(发送去客户端)。
我们第一个任务就是告诉 Meteor 那些数据我们要发送去客户端。我们告诉 Meteor 我们只发布没有打标记的帖子。

排除做过标记的帖子
这里是对应的代码,在服务器端代码中。比如帖子有个flaged属性(字段)

// 在服务器端
Meteor.publish(‘posts‘, function() {
return Posts.find({flagged: false});
});

这就保证客户端无论如何也无法看到打了标记的帖子了。这就是 Meteor App 如何做到安全性的:保证只发布你让这个当前用户看到的数据。

DDP
基本上我们可以把发布/订阅模式想象成为一个漏斗,从服务器端(数据源)过滤数据传送到客户端(目标)。
这个漏斗的专属协议叫做 DDP(分布式数据协议 Distributed Data Protocol 的缩写)。如果想了解 DDP 的更多细节,可以通过看 Matt DeBergalis(Meteor 创始人之一)在 Real-time 大会上的讲演视频(http://2012.realtimeconf.com/video/matt-debergalis) ,或者来自 Chris Mather 的这个截屏视频(http://www.eventedmind.com/posts/meteor-subscriptions-and-ddp) ,来学习关于这个概念更多的细节。

订阅
就算是我们想把打了标记的帖子也发送给客户端,我们也不能把成千上万的帖子一股脑都发出去。我们需要一个机制让客户端来确定那些子集是他们在某个特别时候特别需要的,这就是订阅这个功能的用途。
通过 MiniMongo,客户端 MongoDB 的应用,你订阅的数据会被镜像到客户端。
举个例子,让我们现在浏览一下 Bob Smith 的个人页面,这里只会显示他的帖子。

订阅 Bob 的帖子镜像到客户端
首先,我们给发布功能加一个参数:

// 在服务器端
Meteor.publish(‘posts‘, function(auth) {
    return Posts.find({flagged: false, author: auth});
});

然后我们在客户端订阅这个发布时定义同一个参数。

// 在客户端
Meteor.subscribe(‘posts‘, ‘bob-smith‘);

这就是我们让 Meteor 程序在客户端能够具有可伸缩性:不去订阅全部数据,而是指选择你现在需要的数据去订阅。这样的话,你就可以避免消耗大量的客户端内存,无论服务器端的总数据量有多大。

查找
现在 Bob 的帖子恰巧涵盖了多个类别(比如:“JavaScript”、“Ruby”和“Python”)。也许我们仍然需要把 Bob 的所有帖子都装入内存,但是我们现在只想显示属“JavaScript”类别的帖子。这就是“查找”的用途。

在客户端选择一个数据子集
正如我们在服务器上做的一样,我们用了Posts.find() 函数来选择数据的子集:

// 在客户端
Template.posts.helpers({
    posts: function(){
         return Posts.find({author: ‘bob-smith‘, category: ‘JavaScript‘});
    }
});

现在我们应该明白订阅和发布机制了,让我们在深入了解一些常见的应用模式。

自动发布
如果你从头开始建立一个 Meteor 项目(比如,使用meteor create 命令),系统会自动包含并启用一个叫做autopublish 的包。让我们说说这个包是干什么的。
autopublish 的目的是让 Meteor 应用有个简单的起步阶段,它简单地直接把服务器上的全部数据镜像到客户端,因此你就不用管发布和订阅了。

那么这究竟是如何工作的呢?假设在服务器端我们有一个集合叫做posts 。自动发布包就会自动地把 Mongo 数据库中这个集合的所有的数据(帖子)发送到客户端的名为‘posts’ 的集合中(假设客户端的确有这样一个集合)。
因此,如果你使用自动发布,你就不需要考虑发布。数据一致,而且事情变得十分简单。当然,这样的话会有一个明显的问题,就是你的所有数据都被缓存到所有用户的电脑中。
基于这个原因,自动发布只在你起步阶段且还未考虑发布之前时使用。

发布全部集合
一旦你删除掉autopublish 这个包,你马上就会发现在浏览器上没有数据了。一个简单的解决方法就是重复自动发布所做的工作, 那就是发布所有数据。比如:

Meteor.publish(‘allPosts‘, function(){
    return Posts.find();
});

我们还是发布了所有集合,但是至少我们现在可以自己控制哪个集合我们发布哪个不发布(假设数据库中有两个集合(表)Posts和Comments )。比如现在这个例子,我们发布了Posts 集合但是并没有发布Comments 。

发布部分集合
下一步我们要做的是发布集合中的部分记录。比如我们只发布来自于某个作者的帖子:

Meteor.publish(‘somePosts‘, function(){
    return Posts.find({‘author‘: ‘Tom‘});
});

发布部分字段
我们已经看到如何发布部分帖子,但是我们还需要再精简!让我们看看如何只发布指定的部分字段。
如同以前我们使用find() 返回一个游标,现在我们来去掉一些字段。

Meteor.publish(‘allPosts‘, function(){
    return Posts.find({}, {fields: {
        date: false
    }});
});

该方法会将date字段屏蔽掉,也就是说显示除date字段之外的所有字段,真的是很方便。

实际上,我们可以同时使用上述两种技术,只发布作者是 Tom 的帖子,并且隐藏 date 日期字段:

Meteor.publish(‘allPosts‘, function(){
    return Posts.find({‘author‘: ‘Tom‘}, {fields: {
        date: false
    }});
});

总结
我们已经从发布所有集合的所有文档的所有字段(通过autopublish ),到发布个别集合的个别文档的个别字段。
这已经覆盖了 Meteor 的发布的基本内容,而且这些基本技巧已经足够涵盖大部分的用例了。
有时,你需要进一步来组合、连接或融合发布。我们在以后的章节中讲到这些内容!

时间: 2024-10-03 13:14:55

meteor实例—7—发布(Publication)和订阅(Subscription)的相关文章

ROS学习(三)——创建一个简单的发布节点和订阅节点

暑假在家有些懈怠,不,非常懈怠- -||!良心已经发痛了,想快些补回原来的进度,但忽然发现,中断了一段时间再重新去学习,有的地方连最基本的符号都忘记了 ,这次特意弄个最最基础的,恢复一下,以前的进度. 1.建立一个工作空间 $ mkdir -p ~/catkin_xi/src $ cd ~/catkin_xi/src 在home文件夹里面发现新建好了相应的文件夹,当然里面,空空的,什么都没有. 接着,使用catkin_make命令在catkin 工作空间中新建文件夹,当前目录应该能看到'buil

ROS 自定义消息发布器和订阅器测试 +代码详解(入门级)

既对ros tutorial 上的例子有了一定的了解之后,今天对发布器和订阅器代码(http://wiki.ros.org/cn/ROS/Tutorials/WritingPublisherSubscriber%28c%2B%2B%29)进行了研究,同时稍作改动进行了验证, 发布器-------------------------------------------------------------------------------------------------------------

ros 发布节点和订阅节点

1 发布节点: #include "ros/ros.h" #include "std_msgs/String.h" #include <sstream> /** * This tutorial demonstrates simple sending of messages over the ROS system. */ int main(int argc, char **argv) { /** * The ros::init() function nee

ROS学习(十二)—— 编写简单的消息发布器和订阅器(C++)

一.创建发布器节点 1 节点功能: 不断的在ROS网络中广播消息 2 创建节点 (1)打开工作空间目录 cd ~/catkin_ws/src/beginner_tutorials p { margin-bottom: 0.25cm; line-height: 120% } a:link { } 创建一个发布器节点("talker"),它将不断的在ROS网络中广播消息. --> { } (2)创建src文件夹 mkdir -p ~/catkin_ws/src/beginner_tu

redis笔记——消息发布与消息订阅

1.publish channel message:发布频道 publish news "hello" 发布消息到news 频道 2.subscribe channel [channel2] : 订阅频道(可以同时订阅多个频道) 3.unsubscribe channel [channel2] : 退订指定的频道 (可以退订多个频道) 4.psubscribe channel* :订阅一个或多个符合给定模式的频道 p(pattern) 5.pubsubscribe channel* :

先发布,后订阅

var Event = (function() { var global = this, Event, _default = 'default'; Event = function() { var _listen, _trigger, _remove, _slice = Array.prototype.slice, _shift = Array.prototype.shift, _unshift = Array.prototype.unshift, namespaceCache = {}, _c

观察者模式(Observer)和发布(Publish/订阅模式(Subscribe)的区别

最近在学习dubbo,学到dubbo自然要接触注册中心zookeeper,zookeeper里涉及发布和订阅问题. 观察者模式之JAVA实现:JAVA设计模式之观察者模式 发布订阅模式之JAVA实现:发布者订阅者模式之JAVA实现 在翻阅资料的时候,有人把观察者(Observer)模式等同于发布(Publish)/订阅(Subscribe)模式,也有人认为这两种模式还是存在差异,而我认为确实是存在差异的,本质上的区别是调度的地方不同. 观察者模式 比较概念的解释是,目标和观察者是基类,目标提供维

meteor实例—4—(helper等)

上面的一些{{}}标记,其中的数据来龙去脉基本已经清楚了,但是还有一个{{domain}}没有提到,就是post_item.html中的<h3><a href="{{url}}">{{title}}</a><span>{{domain}}</span></h3>这一句,这个东西是干什么用的呢,查看一下客户端源代码,会发现<span>和</span>中间是空的,就算删除了{{domain}}也

ROS教程2 编写简单的消息发布器和订阅器 (C++ catkin)

创建工作环境 创建文件夹,创建包 mkdir -p ~/catkin_arduino_ros/src catkin_create_pkg test1_pub_sub std_msgs rospy roscpp 在桌面打开终端,添加工作路径 echo "source /home/dongdong/catkin_arduino_ros/devel/setup.bash" >> ~/.bashrc source ~/.bashrc 创建项目文件 1创建src/talker.cpp