delktsai / clouds

lightweight microservices framework, simple to call remote functions 轻量级微服务框架

分布式服务框架

• 基于Redis来传递消息
• 无管理主机，由节点自主维护
• 服务提供者动态加入，自动负载均衡
• 简单出错处理机制：调用超时自动重新调用，超过一定次数时返回调用失败错误

安装

$ npm install clouds --save

服务提供者（Server）

var clouds = require('clouds');

// 创建服务提供者
var server = new clouds.Server({
  // redis连接配置
  redis: {
    host: '127.0.0.1',
    port: 6379,
    db: 3
  },
  // 心跳周期，如果服务提供者异常下线，超过指定时间将自动从服务器端删除，单位：秒
  heartbeat: 2
});

// 注册服务处理程序
server.register('test.hello', function (name, msg, callback) {
  // 函数的最后一个参数表示回调函数，客户端在调用的时候必须保证参数数量是一致的
  // 回调函数第一个参数表示是否出错，第二个参数起表示返回的结果
  callback(null, 'Hello ' + name + ', ' + msg);
});

客户端（Client）

var clouds = require('clouds');

var client = new clouds.Client({
  // redis连接配置
  redis: {
    host: '127.0.0.1',
    port: 6379,
    db: 3
  },
  // 调用超时时间，如果服务器超过指定时间没有响应结果，则认为调用失败，单位：秒
  timeout: 2
});

// 返回一个函数，用于直接调用远程服务
var testHello = client.bind('test.hello');

// 调用远程服务，跟使用本地普通函数差不多
testHello('Glen', 'timestamp is ' + Date.now(), function (err, ret) {
  console.log(err, ret);
});

// 也可以这样直接调用，第一个参数是服务名，第二个参数是调用参数数组，第三个参数是回调函数
client.call('test.hello', ['Glen', 'timestamp is ' + Date.now()], function (err, ret) {
  console.log(err, ret);
});

监视器（Monitor）

var clouds = require('clouds');

// 创建服务器
var monitor = new clouds.Monitor({
  // redis连接配置
  redis: {
    host: '127.0.0.1',
    port: 6379,
    db: 3
  }
});

// 获取状态
monitor.status(function (err, info) {
  console.log(err, info);
  // info.methods服务名对应的服务器ID列表
  // info.servers服务器对应的服务名列表
});

出错处理

客户端在初始化时可设置一个超时时间，如果调用的服务超过该时间没有返回结果，将返回一个服务超时的错误。

在Client.bind()时可以指定自动重试的次数（仅当重试次数超过指定值时才放弃，并执行回调函数，默认为0，即不重试），比如：

// 返回一个函数，用于直接调用远程服务，第一个参数是服务名，第二个参数最大重试次数
var testHello = client.bind('test.hello', 5);

// 调用远程服务，跟使用本地普通函数差不多
testHello('Glen', 'timestamp is ' + Date.now(), function (err, ret) {
  console.log(err, ret);
});

客户端之间消息通信

客户端和服务端均可互相发送消息：

// 接收消息
client.on('message', function (sender, msg) {
  // sender表示消息发送者的ID
  // msg为消息内容，可以为对象、字符串、数值等任何可以转换成JSON字符串的内容
});

// 发送消息
client.send('receiver', 'msg');

单元测试

$ ./run_test

单元测试覆盖率

$ ./run_coverage

94% coverage, 512 SLOC

性能测试

clouds-benchmark项目

License

Copyright (c) 2012-2015 Zongmin Lei (雷宗民) <[email protected]>
http://ucdok.com

The MIT License

Permission is hereby granted, free of charge, to any person obtaining
a copy of this software and associated documentation files (the
"Software"), to deal in the Software without restriction, including
without limitation the rights to use, copy, modify, merge, publish,
distribute, sublicense, and/or sell copies of the Software, and to
permit persons to whom the Software is furnished to do so, subject to
the following conditions:

The above copyright notice and this permission notice shall be
included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.