/node-esb

Base on RabbitMq , ESB system with nodejs

Primary LanguageJavaScript

Node-esb

文档： 中文 | English

目录

项目描述

Esb系统

esb是一个中间件系统，负责链接用户逻辑和第三方接口，主要是处理大量的并发任务，本质是一个消息队列 + 定时任务系统。

安装

#use cli
npm install -g https://github.com/bannerchi/node-esb
#common
npm install --save https://github.com/bannerchi/node-esb

使用说明

v1.0

CLI

为esb提供了一个cli，主要是构建代码，建exchange，queue,cron时使用

构建结构

在根目录下

#可以指定你想要的根目录，默认当前根目录
node-esb build [baseDir]

创建完成的结构如下


--connector
--exchange
--esb-config

其中connector目录中放cronjob的文件

其中esb-config目录中放配置文件

想要直接创建一个exchange

node-esb build -e YOU-WANT-NAME

想要直接创建一个queue

node-esb build -e YOUR-EX-NAME -q YOUR-QUEUE-NAME

你会得到一个文件结构还有个queue的文件模板

把你的执行代码放到

function run(msg) {}

系统会执行你的代码， 请完成一个promise 函数就像示例那样，注意：这是一个消费者的函数。

创建一个cron目录用于放cronjob文件

node-esb build -c YOUR-CRON-NAME

接下来启动一个listener,listenerId是在数据库里面保存的id。

node-esb listen [listenerId]

启动后台运行的listener

node-esb listen [listenerId] -d

cron 的命令和listen的类似

更多的cli命令请使用-h 参数查看

node-esb -h
node-esb build -h
node-esb listen -h

项目进度

  • messagebus 底层封装，主要封装rabbiitMq 方法。
  • daemon 封装，主要用于处理后台程序运行和管理，基于pm2。
  • cron 封装， 处理秒级别cronjob.
  • listener 类， 面向用户使用，也是用户最常用的类。
  • payload 类 ， 结合listener使用处理数据和 exchange queue关系。
  • dispatcher 类， 负责连接数据库和listener关系。
  • cli工具 创建结构;
  • cli工具 创建listener;
  • cli工具 创建cron job;
  • 数据库结构和字段设计;
  • web界面提供;