Meteor介绍

24 Jul 2018 in nodejs on meteor, fullstack - Hits()

Meteor(流星)是什么

Meteor is a full-stack JavaScript platform for developing modern web and mobile applications. Meteor includes a key set of technologies for building connected-client reactive applications, a build tool, and a curated set of packages from the Node.js and general JavaScript community.

Meteor是一个full-stack javascript平台，可用于开发web和移动应用。其最大特点是其（通过websocket）保持客户端连接的“实时”框架。数据库（mongodb）的改变可“实时”展示到界面中。

以下列出优缺点更直观的了解meteor。

优点

实时

读取数据使用DDP

数据实时读取使用DDP(distributed data protocal)的pub/sub，一般是websocket实现的的pub/sub方式。

例如不停的请求第三方api来达到实时效果官方示例

const POLL_INTERVAL = 5000;

Meteor.publish('polled-publication', function() {
  const publishedKeys = {};

  const poll = () => {
    // Let's assume the data comes back as an array of JSON documents, with an _id field, for simplicity
    const data = HTTP.get(REST_URL, REST_OPTIONS);

    data.forEach((doc) => {
      if (publishedKeys[doc._id]) {
        this.changed(COLLECTION_NAME, doc._id, doc);
      } else {
        publishedKeys[doc._id] = true;
        this.added(COLLECTION_NAME, doc._id, doc);
      }
    });
  };

  poll();
  this.ready();

  const interval = Meteor.setInterval(poll, POLL_INTERVAL);

  this.onStop(() => {
    Meteor.clearInterval(interval);
  });
});

上例使用的是Meteor自带的DDP API的changed,added方法来实现数据publish, 这种方式有个问题，即没有通过mongodb，创建的是其实是local collection,那么它的改变只对当前连接（websocket）有效，无法做到多个clients共享。其实相当于为每个subscribe客户端创建一个同名local collection。

参见使用底层api自定义publication(Custom publications with the low level API)

Meteor.publish('custom-publication', function() {
  // We can add documents one at a time
  this.added('collection-name', 'id', {field: 'values'});

  // We can call ready to indicate to the client that the initial document sent has been sent
  this.ready();

  // We may respond to some 3rd party event and want to send notifications
  Meteor.setTimeout(() => {
    // If we want to modify a document that we've already added
    this.changed('collection-name', 'id', {field: 'new-value'});

    // Or if we don't want the client to see it any more
    this.removed('collection-name', 'id');
  });

  // It's very important to clean up things in the subscription's onStop handler
  this.onStop(() => {
    // Perhaps kill the connection with the 3rd party server
  });
});

首先需要明确，不管服务端数据源是否来自mongodb,客户端都有一个内存mongodb,客户端都是针对这个mongodb来查询操作。详见这里

再来看看默认的基于服务端Mongodb数据实现:
使用的是MongoDB’s Oplog,对mongo数据库的修改得以立即广播到读取指针(cursor).
示例

Meteor.publish('lists.public', function() {
  return Lists.find({
    userId: {$exists: false}
  }, {
    fields: Lists.publicFields
  });
});

魔法就在于Lists.find，如果对应的集合有所变动，都会向客户端广播。
oplog也有一些限制最主要的是，mongodb必须是replica set,否则还是默认的polling。这一下子就提高了门槛。不过，polling对于同一个进程的修改反映还是蛮快的，而默认的meteor collection实现应该是一个进程中，故还不错。目前meteor1.7的版本使用的是mogon 3.0的driver，还不能使用driver3.1事务,如果自己新开一个cmongo client,则估计是在另外一个process,从测试结果来看，与meteor的collection更新时间间隔有5秒以上的差距，见示例.

修改数据使用method(也属于DDP协议)

method类似RPC； method有一些特点:

客户端调用方法直接引用定义文件调用，直观。
现在客户端调用验证，如果失败，就不会调用服务端。
方便于测试。

不提倡从method获得数据

一般应该是从pub/sub获得数据，method只负责修改，不应该从method的返回获得数据。因为虽然method是能够返回数据的，但这种情况下，你还得手动维护客户端mongodb的数据一致性。

// In client-side code, declare a local collection
// by passing `null` as the argument
ScoreAverages = new Mongo.Collection(null);

import { calculateAverages } from '../api/games/methods.js';

function updateAverages() {
  // Clean out result cache
  ScoreAverages.remove({});

  // Call a Method that does an expensive computation
  calculateAverages.call((err, res) => {
    res.forEach((item) => {
      ScoreAverages.insert(item);
    });
  });
}

Method相对于REST API的好处

基于Fibers,编写类似于同步方式的代码，但是不是阻塞(blocking)的

使用fibers将method(请求估计也是websocket，由于每个method都有id，将调用和返回通过id关联，将websocket异步的包装成同步的)封装成同步的形式，这样既保持了websocket的便利，也使得编码逻辑直观。 Fiber不是个新概念，它不同于thread，并不能起到thread的作用，个人理解，更像nodejs里面await/async的一种实现。例如meteor里的method需要返回，是不支持callback的方式的，可以通过Meteor.wrapAsync来包装callback方式的调用。
举个例子

get: function() {
      var limit = this.queryParams.limit;
      limit = parseInt(limit) || 100;
      try {
        var results = Meteor.wrapAsync(callback => {
          service.listing({ limit }, (error, results, fields) => {
            if (error) {
              callback(error);
              return;
            }

            callback(null, results);
          });
        })();
        return results;
      } catch (err) {
        throw err;
      }
    }

请求和返回都是有序的

对于ajax请求，请求和返回不能保证有序，可能后请求的先得到返回。meteor保证了每个客户端的每个请求都是有序的，前一个调用成功后才进行下一个。不过对于特殊的情况，也可以改变这个机制而使得执行无序。例如this.unblock()。

每个DDP(pub/sub和method)都可以是绑定用户信息的

通过this.userId可用于判断用户是否登录，用户系统可自定义，也可使用meteor的api。

商业支持，论坛支持,文档详细

meteor虽然开源，但背后有专门的商业公司支持,目前来看github上有40k+星标，项目活跃程度还算不错其提供hosting服务，也提供商业支持服务，商业支持服务对于商业项目来说是很重要的考虑点。

meteor背后的团队是Meteor Development Group(MDG),也是apollo背后的团队，技术水平是值得信赖的。

支持npm，可以整合其他框架，例如expressjs

Meteor之前是仅通过Atmosphere来扩展，后来开始直接支持npm，这样一来，其他nodejs框架可以直接整合，例如meteor没有官方支持的restapi方式，可通过整合express来实现，这样meteor完全融合到了nodejs生态中。整合express的示例：

import { Meteor } from 'meteor/meteor';
import express from 'express';

import bodyParser from 'body-parser';

export function setupApi() {
  const app = express();

  app.use(bodyParser.json()); // for parsing application/json
  app.use(bodyParser.urlencoded({ extended: true })); // for parsing application/x-www-form-urlencoded

  var t1 = require('./t1');
  var t2 = require('./t2');

  app.use('/t1', t1);
  app.use('/t2', t2);

  WebApp.connectHandlers.use(app);
}

其中用到的是meteor webapp api

atmospherejs示例
meteor add qualia:reval
会在.meteor/pacakge中增加对应信息，且代码中不需要显示import

npm方式
meteor npm i exressjs
会在pacakge.json中添加信息
不要尝试npm i xx直接添加，因为meteor工具自带绑定版本的node和npmj

web前端官方支持react,Angular

对于meteor自带的Blaze,由于其提供了许多便利的特性，一般建议与React,Angular合用

移动端支持

使用Cordova,

使用DDP方式调用meteor服务端

对于ios，可使用meteor-ios框架。
对于小程序，可使用我封装的基于simpleddp的插件simpleddp-wechat-miniprogram-dirver。

缺点

仍算比较冷门，中文支持较少

与普通的nodejs开发方式不太相同，学习曲线稍陡

默认绑定了mongodb

这可以说是个优点，如果你本来就用mongo,然而大部分情况我会认为是个缺点，虽然可以使用其他数据库整合，但mongodb是必须的，你可以不用它，但是这样会丢失DDP很多特性,且必须通过MONGO_URL配置启动。

它可以横向扩展(scale out),但是不是那么简单

meteor圈如果有人问怎么横向扩展，往往得到的回答是类似-先让你的应用达到需要扩展的用户数量再说吧，那时候不管怎么样都是时候重构了。(It helps that we’re not planning at building apps targeted at millions of users, but when you hit that kind of scale, refactoring is anyway going to happen.)

这个回答确实很实际，就像RoR作者DHH说的”在选彩票的时候就开始操心中奖以后买哪个游艇。”(Programmers worrying about whether their architecture will Web Scale is like buying a lottery coupon and fretting about which yacht to buy.)

如果不用mongo,那你就不能使用mongo oplog来scale out.这种情况如果要使用publications,就必须使用服务端local collection,本质上是一种不支持集群的内存数据库，那么就做不到scale out。